import org.apache.curator.ensemble.exhibitor.ExhibitorRestClient; //导入依赖的package包/类
@Test
@SuppressWarnings("unchecked")
public void instance_BindingOptionalsWithExhibitor_UsesParametersInExhibitorInstance() throws Exception {
    Injector inj = Guice.createInjector(module, new AbstractModule() {
        @Override
        protected void configure() {
            bindConstant().annotatedWith(Names.named("Cultivar.zookeeper.connectionString")).to("localhost:2181");
            bindConstant().annotatedWith(Names.named("Cultivar.zookeeper.exhibitorString")).to("localhost");
            bindConstant().annotatedWith(Names.named("Cultivar.properties.exhibitor.pollingTimeMillis")).to(1000);
            bindConstant().annotatedWith(Names.named("Cultivar.properties.exhibitor.restPath")).to("/exhibitor");
            bindConstant().annotatedWith(Names.named("Cultivar.properties.exhibitor.restPort")).to(8081);

            bind(ExhibitorRestClient.class).toInstance(client);
            bind(RetryPolicy.class).annotatedWith(Names.named("Cultivar.properties.exhibitor.retryPolicy"))
                    .toInstance(new RetryNTimes(RETRY_NUMBER, 1));
        }
    });

    ExhibitorEnsembleProvider provider = (ExhibitorEnsembleProvider) inj.getInstance(EnsembleProvider.class);

    provider.pollForInitialEnsemble();

    verify(client, times(RETRY_NUMBER + 1)).getRaw(eq("localhost"), eq(8081), eq("/exhibitor"), anyString());
    verifyNoMoreInteractions(client);
}
 

import org.apache.curator.ensemble.exhibitor.ExhibitorRestClient; //导入依赖的package包/类
@Test
@SuppressWarnings("unchecked")
public void instance_BindingOptionalsWithExhibitor_UsesParametersInExhibitorInstance() throws Exception {
    Injector inj = Guice.createInjector(module, new AbstractModule() {
        @Override
        protected void configure() {
            bindConstant().annotatedWith(Names.named("Cultivar.zookeeper.connectionString")).to("localhost:2181");
            bindConstant().annotatedWith(Names.named("Cultivar.zookeeper.exhibitorString")).to("localhost");
            bindConstant().annotatedWith(Names.named("Cultivar.properties.exhibitor.pollingTimeMillis")).to(1000);
            bindConstant().annotatedWith(Names.named("Cultivar.properties.exhibitor.restPath")).to("/exhibitor");
            bindConstant().annotatedWith(Names.named("Cultivar.properties.exhibitor.restPort")).to(8081);

            bind(ExhibitorRestClient.class).toInstance(client);
            bind(RetryPolicy.class).annotatedWith(Names.named("Cultivar.properties.exhibitor.retryPolicy"))
                    .toInstance(new RetryNTimes(RETRY_NUMBER, 1));
        }
    });

    ExhibitorEnsembleProvider provider = (ExhibitorEnsembleProvider) inj.getInstance(Key.get(
            EnsembleProvider.class, Curator.class));

    provider.pollForInitialEnsemble();

    verify(client, times(RETRY_NUMBER + 1)).getRaw(eq("localhost"), eq(8081), eq("/exhibitor"), anyString());
    verifyNoMoreInteractions(client);
}
 

import org.apache.curator.ensemble.exhibitor.ExhibitorRestClient; //导入依赖的package包/类
ExhibitorEnsembleProvider(final Exhibitors exhibitors, final ExhibitorRestClient restClient,
                                 final String restUriPath, final int pollingMs, final RetryPolicy retryPolicy) {
    super(exhibitors, restClient, restUriPath, pollingMs, retryPolicy);
}
 

import org.apache.curator.ensemble.exhibitor.ExhibitorRestClient; //导入依赖的package包/类
@Inject(optional = true)
public void setRestClient(final ExhibitorRestClient client) {
    this.restClient = client;
}
 

import org.apache.curator.ensemble.exhibitor.ExhibitorRestClient; //导入依赖的package包/类
/**
 * @param exhibitors  the current set of exhibitor instances (can be changed later via {@link #setExhibitors(org.apache.curator.ensemble.exhibitor.Exhibitors)})
 * @param restClient  the rest client to use (use {@link org.apache.curator.ensemble.exhibitor.DefaultExhibitorRestClient} for most cases)
 * @param restUriPath the path of the REST call used to get the server set. Usually: <code>/exhibitor/v1/cluster/list</code>
 * @param pollingMs   how ofter to poll the exhibitors for the list
 * @param retryPolicy retry policy to use when connecting to the exhibitors
 */
public KixeyeExhibitorEnsembleProvider(Exhibitors exhibitors, ExhibitorRestClient restClient, String restUriPath, int pollingMs, RetryPolicy retryPolicy) {
    super(exhibitors, restClient, restUriPath, pollingMs, retryPolicy);
    this.initialExhibitors = exhibitors;
}