Java 类com.google.inject.Binder 实例源码

/**
 * auto bind interface impl
 *
 * @param binder
 */
private void beanBind(Binder binder) {

    List<Class> classes = ClassScanner.scanClassByAnnotation(Bean.class, true);
    for (Class impl : classes) {
        Class<?>[] interfaceClasses = impl.getInterfaces();
        Bean bean = (Bean) impl.getAnnotation(Bean.class);
        String name = bean.name();
        for (Class interfaceClass : interfaceClasses) {
            if (interfaceClass == Serializable.class) {
                continue;
            }
            try {
                if (StringUtils.isBlank(name)) {
                    binder.bind(interfaceClass).to(impl);
                } else {
                    binder.bind(interfaceClass).annotatedWith(Names.named(name)).to(impl);
                }
            } catch (Throwable ex) {
                System.err.println(String.format("can not bind [%s] to [%s]", interfaceClass, impl));
            }
        }
    }
}

private void configurePanoptes(Binder binder) {
    String endpoint = config.getString("panoptes.service.url");
    String clientSecret = config.getString("panoptes.service.client.secret");
    Duration timeout = config.getDuration("panoptes.service.timeout");
    PanoptesWebServiceFactory factory = new PanoptesWebServiceFactory(endpoint, timeout);
    RetrofitServiceFactory authFactory = new BasicJWTAuthServiceFactorySC(endpoint, timeout);
    AuthService authService = new BasicJWTAuthService(authFactory,
            new Authorization("APIKEY", clientSecret));
    binder.bind(String.class)
            .annotatedWith(Names.named("PANOPTES_ENDPOINT"))
            .toInstance(endpoint);
    binder.bind(AuthService.class)
            .annotatedWith(Names.named("PANOPTES_AUTH"))
            .toInstance(authService);
    PanoptesService service = new PanoptesService(factory, authService);
    binder.bind(Long.class)
            .annotatedWith(Names.named("PANOPTES_TIMEOUT"))
            .toInstance(timeout.toMillis());
    binder.bind(PanoptesWebServiceFactory.class).toInstance(factory);
    binder.bind(ImageArchiveService.class).toInstance(service);

}

@Before
public void setUp() throws Exception {
  final RMContext mockRMContext =
      TestRMWebApp.mockRMContext(3, numberOfRacks, numberOfNodesPerRack,
        8 * TestRMWebApp.GiB);
  injector =
      WebAppTests.createMockInjector(RMContext.class, mockRMContext,
        new Module() {
          @Override
          public void configure(Binder binder) {
            try {
              binder.bind(ResourceManager.class).toInstance(
                TestRMWebApp.mockRm(mockRMContext));
            } catch (IOException e) {
              throw new IllegalStateException(e);
            }
          }
        });
}

protected DynamicAnnouncementBinder(Binder binder)
{
    keyBinder = newSetBinder(binder,
            SERVICE_PROPERTY_TYPE,
            ForDynamicAnnouncements.class);
    getterBinder = newMapBinder(binder,
            SERVICE_PROPERTY_TYPE,
            new TypeLiteral<Function<Object, String>>() {},
            ForDynamicAnnouncements.class);
    objectBinder = newMapBinder(binder,
            SERVICE_PROPERTY_TYPE,
            new TypeLiteral<Object>() {},
            ForDynamicAnnouncements.class);
}

@Override
public void configure(Binder binder)
{
    binder.bind(ThriftCodecFactory.class).to(CompilerThriftCodecFactory.class).in(Scopes.SINGLETON);
    binder.bind(ThriftCatalog.class).in(Scopes.SINGLETON);
    binder.bind(ThriftCodecManager.class).in(Scopes.SINGLETON);
    newSetBinder(binder, new TypeLiteral<ThriftCodec<?>>() {}, InternalThriftCodec.class).permitDuplicates();

    binder.bind(ClassLoader.class)
            .annotatedWith(ForCompiler.class)
            .toInstance(parent);
}

@Override
public void configure(Binder binder) {
  try (InputStream is1 = ClassLoader
      .getSystemResourceAsStream("test-config.xml")) {
    WxXmlCpInMemoryConfigStorage config = fromXml(
        WxXmlCpInMemoryConfigStorage.class, is1);
    WxCpServiceImpl wxService = new WxCpServiceImpl();
    wxService.setWxCpConfigStorage(config);

    binder.bind(WxCpServiceImpl.class).toInstance(wxService);
    binder.bind(WxCpConfigStorage.class).toInstance(config);
  } catch (IOException e) {
    e.printStackTrace();
  }
}

/**
 * Creates a new duplex binder.
 *
 * @param binder the enclosing (public) binder
 * @return a new duplex binder
 */
@NonNull
static DuplexBinder create(@NonNull final Binder binder) {
  if(binder instanceof DuplexBinder) {
    return (DuplexBinder) binder;
  }
  return new DuplexBinderImpl(binder, binder.newPrivateBinder());
}

@Override
public void configure(Binder binder)
{
    httpClientBinder(binder).addGlobalFilterBinding()
            .to(DynamicAnnouncementFilter.class)
            .asEagerSingleton();

    jsonCodecBinder(binder).bindJsonCodec(JsonAnnouncement.class);

    // Initialize various multibinders
    DynamicAnnouncementBinder.dynamicAnnouncementBinder(binder);
}

@SuppressWarnings("unchecked")
@Override
public void configure(Binder binder) {
    try {
        // try to instantiate platform specific implementation
        // will fail currently on Mac, thus the binding does not happen there
        Class<? extends ISolidityCompiler> solidityCompilerClass = (Class<? extends ISolidityCompiler>) Class
                .forName("com.yakindu.solidity.compiler.builder.SolidityCompiler");
        binder.bind(ISolidityCompiler.class).to(solidityCompilerClass);
    } catch (ClassNotFoundException e) {
        System.err.println("SolidityCompilerModule: " + e.getMessage());
    }
    binder.bind(IPreferenceStore.class)
            .toInstance((IPreferenceStore) SolidityActivator.getInstance().getPreferenceStore());
}

@Override
public void configure(Binder binder) {
    binder.bind(ActionMapping.class).toInstance(new ActionMapping());
    binder.bind(ActionHandler.class).toInstance(new ActionHandler());

    binder.bind(ViewFactory.class).to(DefaultViewFactory.class).in(Singleton.class);
    binder.bind(ViewResolver.class).to(DefaultViewResolver.class).in(Singleton.class);

    configureCaptcha(binder);
}

public ListProvider(Binder binder, List<Class<? extends T>> clazzes)
{
    this.binder = binder;
    this.clazzes.addAll(clazzes);
    for( Class<? extends T> clazz : clazzes )
    {
        binder.bind(clazz);
    }
}

/**
 * Binds a specific label provider for the content assist use case.
 */
@Override
public void configureContentProposalLabelProvider(com.google.inject.Binder binder) {
    binder.bind(org.eclipse.jface.viewers.ILabelProvider.class)
            .annotatedWith(org.eclipse.xtext.ui.editor.contentassist.ContentProposalLabelProvider.class)
            .to(N4JSContentAssistLabelProvider.class);
}

protected SetBinder(Binder binder, @Nullable Key<T> key) {
    if(key == null) {
        key = Key.get(new ResolvableType<T>(){}.in(getClass()));
    }

    this.binder = binder.skipSources(SetBinder.class);
    this.elementType = key.getTypeLiteral();
    this.collectionType = new ResolvableType<Set<T>>(){}.with(new TypeArgument<T>(this.elementType){});
    this.multibinder = Multibinder.newSetBinder(binder, key);
}

@Override
public void configure(Binder binder) {
    binder.bind(EthereumConnector.class).in(Scopes.SINGLETON);
    binder.bind(EthereumMetadata.class).in(Scopes.SINGLETON);
    binder.bind(EthereumWeb3jProvider.class).in(Scopes.SINGLETON);

    binder.bind(EthereumSplitManager.class).in(Scopes.SINGLETON);
    binder.bind(EthereumRecordSetProvider.class).in(Scopes.SINGLETON);

    configBinder(binder).bindConfig(EthereumConnectorConfig.class);
    jsonBinder(binder).addDeserializerBinding(Type.class).to(TypeDeserializer.class);
}

private void configureConceptService(Binder binder) {
    String endpoint = config.getString("concept.service.url");
    Duration timeout = config.getDuration("concept.service.timeout");
    KBWebServiceFactory factory = new KBWebServiceFactory(endpoint, timeout, defaultExecutor);
    KBConceptService service = new KBConceptService(factory);
    // --- Using a local cache
    CachedConceptService cachedService = new CachedConceptService(service);
    List<String> cachedConceptTemplates = config.getStringList("app.annotation.details.cache");
    cachedService.prefetch(cachedConceptTemplates);
    binder.bind(String.class)
            .annotatedWith(Names.named("CONCEPT_ENDPOINT"))
            .toInstance(endpoint);
    binder.bind(KBWebServiceFactory.class).toInstance(factory);
    binder.bind(ConceptService.class).toInstance(cachedService);
}

/**
 * Sets the scope provider to use as delegate for the local scope provider. This delegate is used to handle imported
 * elements. The customization makes elements that name is equal to the resource name both referenceable by e.g
 * my/pack/A/A as well as my/pack/A if the resource name is A. In this delegate later the import of the built in
 * types should be made.
 */
public void configureIScopeProviderDelegate(Binder binder) {
    binder.bind(org.eclipse.xtext.scoping.IScopeProvider.class)
            .annotatedWith(
                    com.google.inject.name.Names
                            .named(org.eclipse.xtext.scoping.impl.AbstractDeclarativeScopeProvider.NAMED_DELEGATE))
            .to(N4JSImportedNamespaceAwareLocalScopeProvider.class);
}

/** Configures the formatter preference value provider */
@Override
public void configureFormatterPreferences(Binder binder) {
    binder
            .bind(IPreferenceValuesProvider.class)
            .annotatedWith(FormatterPreferences.class)
            .to(N4JSSimpleFormattingPreferenceProvider.class);
}

@Override
    public void configure(Binder binder) {
        binder.bind(PluginDependenciesResolver.class).to(NbPluginDependenciesResolver.class);
        binder.bind(Roles.componentKey(RepositoryConnectorFactory.class, "offline")).to(OfflineConnector.class);
        //#212214 the EnhancedLocalRepositoryManager will claim artifact is not locally present even if file is there but some metadata is missing
        //we just replace it with the simple variant that relies on file's presence only. 
        //I'm a bit afraid to remove the binding altogether, that's why we map simple to enhanced.
        binder.bind(Roles.componentKey(LocalRepositoryManagerFactory.class, "enhanced")).to(SimpleLocalRepositoryManagerFactory.class);

        //exxperimental only.
//        binder.bind(InheritanceAssembler.class).to(NbInheritanceAssembler.class);
        binder.bind(ModelBuilder.class).to(NBModelBuilder.class);
    }

@Test
public void testFairSchedulerWebAppPage() {
  List<RMAppState> appStates = Arrays.asList(RMAppState.NEW,
      RMAppState.NEW_SAVING, RMAppState.SUBMITTED);
  final RMContext rmContext = mockRMContext(appStates);
  Injector injector = WebAppTests.createMockInjector(RMContext.class,
      rmContext,
      new Module() {
        @Override
        public void configure(Binder binder) {
          try {
            ResourceManager mockRmWithFairScheduler =
                mockRm(rmContext);
            binder.bind(ResourceManager.class).toInstance
                (mockRmWithFairScheduler);
            binder.bind(ApplicationBaseProtocol.class).toInstance(
              mockRmWithFairScheduler.getClientRMService());
          } catch (IOException e) {
            throw new IllegalStateException(e);
          }
        }
      });
  FairSchedulerPage fsViewInstance = injector.getInstance(FairSchedulerPage
      .class);
  fsViewInstance.render();
  WebAppTests.flushOutput(injector);
}

public void configureBuilderPreferenceStoreInitializer(Binder binder) {
    binder.bind(IPreferenceStoreInitializer.class)
        .annotatedWith(Names.named("builderPreferenceInitializer"))
        .to(BuilderPreferenceAccess.Initializer.class);
}

@Override
public void configure(Binder binder) {
    binder.bind(DataSourceManager.class).toInstance(dataSourceManager);
    binder.bind(PageScopeFactory.class).toInstance(pageScopeFactory);
}

public void configureIgnoreCaseLinking(com.google.inject.Binder binder) {
    binder.bindConstant().annotatedWith(org.eclipse.xtext.scoping.IgnoreCaseLinking.class).to(false);
}

public void configureIScopeProviderDelegate(com.google.inject.Binder binder) {
    binder.bind(org.eclipse.xtext.scoping.IScopeProvider.class).annotatedWith(com.google.inject.name.Names.named(org.eclipse.xtext.scoping.impl.AbstractDeclarativeScopeProvider.NAMED_DELEGATE)).to(org.eclipse.xtext.scoping.impl.SimpleLocalScopeProvider.class);
}

public void configureIResourceDescriptions(Binder binder) {
    binder.bind(IResourceDescriptions.class).to(ResourceSetBasedResourceDescriptions.class);
}

public void configureResourceUIServiceLabelProvider(Binder binder) {
    binder.bind(ILabelProvider.class).annotatedWith(ResourceServiceDescriptionLabelProvider.class).to(OCCIDescriptionLabelProvider.class);
}

public void configureResourceUIServiceLabelProvider(Binder binder) {
    binder.bind(ILabelProvider.class).annotatedWith(ResourceServiceDescriptionLabelProvider.class).to(DSLPoliciesDescriptionLabelProvider.class);
}

public MessageBinder(Binder binder) {
    this.messages = Multibinder.newSetBinder(binder, new Key<MessageMeta<?>>(){});
}

protected SetBinder(Binder binder, @Nullable TypeLiteral<T> type) {
    this(binder, type == null ? null : Key.get(type));
}

public void configureHighlightingTokenDefProvider(Binder binder) {
    binder.bind(ITokenDefProvider.class)
        .annotatedWith(Names.named(LexerIdeBindings.HIGHLIGHTING))
        .to(AntlrTokenDefProvider.class);
}

public void configureFileExtensions(Binder binder) {
    if (properties == null || properties.getProperty(Constants.FILE_EXTENSIONS) == null)
        binder.bind(String.class).annotatedWith(Names.named(Constants.FILE_EXTENSIONS)).toInstance("gexpressions");
}

@Override
public void configure(Binder binder) {
    binder.install(new FactoryModuleBuilder().build(MediaWrapperFactory.class));
}

public void configureHighlightingTokenDefProvider(Binder binder) {
    binder.bind(ITokenDefProvider.class)
        .annotatedWith(Names.named(LexerIdeBindings.HIGHLIGHTING))
        .to(AntlrTokenDefProvider.class);
}

public void configureIgnoreCaseLinking(Binder binder) {
    binder.bindConstant().annotatedWith(IgnoreCaseLinking.class).to(false);
}

@Override
public void configure(final Binder binder) {
    binder.bind(TestTreeTransformer.class).to(DefaultTestTreeTransformer.class);
}

@Override
public void configure(Binder binder) {
    properties = tryBindProperties(binder, "xtext/QueryIT.properties");
    super.configure(binder);
}

public MockBinder(Binder binder) {
    this.binder = binder;
}

public void configureLanguageName(Binder binder) {
    binder.bind(String.class).annotatedWith(Names.named(Constants.LANGUAGE_NAME)).toInstance("com.ms.qaTools.saturn.Kronus");
}

public void configureFileExtensions(Binder binder) {
    if (properties == null || properties.getProperty(Constants.FILE_EXTENSIONS) == null)
        binder.bind(String.class).annotatedWith(Names.named(Constants.FILE_EXTENSIONS)).toInstance("n4ts");
}

public void configureResourceUIServiceLabelProvider(Binder binder) {
    binder.bind(ILabelProvider.class).annotatedWith(ResourceServiceDescriptionLabelProvider.class).to(MyDslDescriptionLabelProvider.class);
}

public void configureIPreferenceStoreInitializer(Binder binder) {
    binder.bind(IPreferenceStoreInitializer.class)
        .annotatedWith(Names.named("RefactoringPreferences"))
        .to(RefactoringPreferences.Initializer.class);
}