java类org.springframework.context.annotation.Conditional的实例源码

@Bean
@ConditionalOnMissingBean(CloudSqlJdbcInfoProvider.class)
@Conditional(AppEngineCondition.class)
public CloudSqlJdbcInfoProvider appengineCloudSqlJdbcInfoProvider() {
    CloudSqlJdbcInfoProvider appEngineProvider = new AppEngineCloudSqlJdbcInfoProvider(this.gcpCloudSqlProperties);

    if (LOGGER.isInfoEnabled()) {
        LOGGER.info("App Engine JdbcUrl provider. Connecting to "
                + appEngineProvider.getJdbcUrl() + " with driver "
                + appEngineProvider.getJdbcDriverClass());
    }

    setCredentialsProperty();

    return appEngineProvider;
}

public static boolean matches(ConditionContext context) {
    Class<AuthorizationServerEndpointsConfigurationBeanCondition> type = AuthorizationServerEndpointsConfigurationBeanCondition.class;
    Conditional conditional = AnnotationUtils.findAnnotation(type,
            Conditional.class);
    StandardAnnotationMetadata metadata = new StandardAnnotationMetadata(type);
    for (Class<? extends Condition> conditionType : conditional.value()) {
        Condition condition = BeanUtils.instantiateClass(conditionType);
        if (condition.matches(context, metadata)) {
            return true;
        }
    }
    return false;
}

/**
 * Returns {@link ClientFactory#DEFAULT} which is used as the default {@link ClientFactory} of a
 * {@link CentralDogma} client.
 */
@Bean
@ForCentralDogma
@Conditional(MissingCentralDogmaClientFactory.class)
public ClientFactory clientFactory() {
    return ClientFactory.DEFAULT;
}

@Bean
@Conditional(Development.class)
public WebMvcConfigurer webMvcConfigurer() {
    return new WebMvcConfigurerAdapter() {
        @Override
        public void addCorsMappings(final CorsRegistry registry) {
            registry.addMapping("/**");
        }
    };
}

@Bean
@Conditional(PostgreSqlUrlCondition.class)
public DataSource dataSource(Environment env) throws URISyntaxException {
  final String DATABASE_URL = env.getProperty("DATABASE_URL");

  return createHerokuDataSource(DATABASE_URL);
}

@SuppressWarnings("unchecked")
private List<String[]> getConditionClasses(AnnotatedTypeMetadata metadata) {
    MultiValueMap<String, Object> attributes = metadata
            .getAllAnnotationAttributes(Conditional.class.getName(), true);
    Object values = (attributes != null ? attributes.get("value") : null);
    return (List<String[]>) (values != null ? values : Collections.emptyList());
}

/**
 * The @Bean annotation tells Spring that this method will return an object that should <br>
 * be registered as a bean in the Spring application context.
 *
 * @return userService
 */
@Bean
@Conditional(UserCondition.class)
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
public UserService userService() {
    logger.debug("userService");
    return new UserServiceImpl();
}

/**
 * When the domain variable is set, we lookup the elasticsearch domain url dynamically, using the
 * AWS api. Otherwise, we assume the URL specified in ES_HOSTS is correct.
 */
@Bean
@Conditional(AwsDomainSetCondition.class)
InternalElasticsearchClient.Builder clientBuilder(
    ZipkinElasticsearchStorageProperties es,
    ZipkinElasticsearchAwsStorageProperties aws,
    @Qualifier("zipkinElasticsearchHttp") OkHttpClient client) {
  String domain = aws.getDomain();
  String region = region(es, aws);

  ElasticsearchDomainEndpoint hosts = new ElasticsearchDomainEndpoint(
      client, HttpUrl.parse("https://es." + region + ".amazonaws.com"), domain);

  return HttpClientBuilder.create(client).hosts(hosts);
}

/** Setup {@link AWSSecurityTokenService} client an IAM role to assume is given. */
@Bean
@ConditionalOnMissingBean
@Conditional(STSSetCondition.class)
AWSSecurityTokenService securityTokenService(ZipkinSQSCollectorProperties properties) {
  return AWSSecurityTokenServiceClientBuilder.standard()
      .withCredentials(getDefaultCredentialsProvider(properties))
      .withRegion(properties.awsStsRegion)
      .build();
}

/** Setup {@link AWSSecurityTokenService} client an IAM role to assume is given. */
@Bean
@ConditionalOnMissingBean
@Conditional(STSSetCondition.class)
AWSSecurityTokenService securityTokenService(ZipkinKinesisCollectorProperties properties) {
  return AWSSecurityTokenServiceClientBuilder.standard()
      .withCredentials(getDefaultCredentialsProvider(properties))
      .withRegion(properties.awsStsRegion)
      .build();
}

public static boolean matches(ConditionContext context) {
    Class<AuthorizationServerEndpointsConfigurationBeanCondition> type = AuthorizationServerEndpointsConfigurationBeanCondition.class;
    Conditional conditional = AnnotationUtils.findAnnotation(type,
            Conditional.class);
    StandardAnnotationMetadata metadata = new StandardAnnotationMetadata(type);
    for (Class<? extends Condition> conditionType : conditional.value()) {
        Condition condition = BeanUtils.instantiateClass(conditionType);
        if (condition.matches(context, metadata)) {
            return true;
        }
    }
    return false;
}

@SuppressWarnings("unchecked")
private List<String[]> getConditionClasses(AnnotatedTypeMetadata metadata) {
    MultiValueMap<String, Object> attributes = metadata
            .getAllAnnotationAttributes(Conditional.class.getName(), true);
    Object values = (attributes != null ? attributes.get("value") : null);
    return (List<String[]>) (values != null ? values : Collections.emptyList());
}

/**
 * REST server for listening to POST/GET requests
 * @return
 */
@Bean
@Conditional(RestEnabledCondition.class)
public Serveable restServer()
{
  return new WebbitRestServerBean(port, nThreads, basePkg);

}

/**
 * Asynchronous REST processor
 * @return
 */
@Bean
@Conditional(RestEnabledCondition.class)
public AsyncEventReceiverBean asyncRestProcessor()
{
  return new AsyncEventReceiverBean();
}

/**
 * Jar module loader.
 * @return
 */
@Bean
@Conditional(RestEnabledCondition.class)
public JarModuleLoader dllLoader()
{
  try 
  {
    if(StringUtils.isEmpty(dllRoot))
      throw new BeanCreationException("'restserver.jaxrs.extDir' path not found");
    File f = ResourceLoaderHelper.loadFromFileOrClassPath(dllRoot, false);
    return new JarModuleLoader(f);
  } catch (IOException e) {
    throw new BeanCreationException("'restserver.jaxrs.extDir' path not found", e);
  }
}

/**
 * Jar distribution agent.
 * @return
 */
@Bean
@Conditional(RestEnabledCondition.class)
public JarFileSharingAgent jarSharingAgent()
{
  return new JarFileSharingAgent();
}

public static boolean matches(ConditionContext context) {
    Class<AuthorizationServerEndpointsConfigurationBeanCondition> type = AuthorizationServerEndpointsConfigurationBeanCondition.class;
    Conditional conditional = AnnotationUtils.findAnnotation(type,
            Conditional.class);
    StandardAnnotationMetadata metadata = new StandardAnnotationMetadata(type);
    for (Class<? extends Condition> conditionType : conditional.value()) {
        Condition condition = BeanUtils.instantiateClass(conditionType);
        if (condition.matches(context, metadata)) {
            return true;
        }
    }
    return false;
}

@SuppressWarnings("unchecked")
private List<String[]> getConditionClasses(AnnotatedTypeMetadata metadata) {
    MultiValueMap<String, Object> attributes = metadata
            .getAllAnnotationAttributes(Conditional.class.getName(), true);
    Object values = (attributes != null ? attributes.get("value") : null);
    return (List<String[]>) (values != null ? values : Collections.emptyList());
}

@Bean(name = TriggerConstants.TRIGGER_BEAN_NAME)
@Conditional(PeriodicTriggerCondition.class)
public Trigger periodicTrigger() {
    PeriodicTrigger trigger = new PeriodicTrigger(triggerProperties.getFixedDelay(),
            triggerProperties.getTimeUnit());
    trigger.setInitialDelay(triggerProperties.getInitialDelay());
    return trigger;
}

@Bean(name = "historyLevelAutoConfiguration")
@ConditionalOnMissingBean(CamundaHistoryLevelAutoHandlingConfiguration.class)
@ConditionalOnProperty(prefix = "camunda.bpm", name = "history-level", havingValue = "auto", matchIfMissing = false)
@Conditional(NeedsHistoryAutoConfigurationCondition.class)
public static CamundaHistoryLevelAutoHandlingConfiguration historyLevelAutoHandlingConfiguration() {
  return new DefaultHistoryLevelAutoHandlingConfiguration();
}

public static boolean matches(ConditionContext context) {
    Class<AuthorizationServerEndpointsConfigurationBeanCondition> type = AuthorizationServerEndpointsConfigurationBeanCondition.class;
    Conditional conditional = AnnotationUtils.findAnnotation(type,
            Conditional.class);
    StandardAnnotationMetadata metadata = new StandardAnnotationMetadata(type);
    for (Class<? extends Condition> conditionType : conditional.value()) {
        Condition condition = BeanUtils.instantiateClass(conditionType);
        if (condition.matches(context, metadata)) {
            return true;
        }
    }
    return false;
}

@SuppressWarnings("unchecked")
private List<String[]> getConditionClasses(AnnotatedTypeMetadata metadata) {
    MultiValueMap<String, Object> attributes = metadata
            .getAllAnnotationAttributes(Conditional.class.getName(), true);
    Object values = (attributes != null ? attributes.get("value") : null);
    return (List<String[]>) (values != null ? values : Collections.emptyList());
}

@Bean
@Conditional(UseMarkLogicBatchCondition.class)
public BatchConfigurer batchConfigurer(
        @Qualifier(value = "markLogicJobRepositoryDatabaseClientProvider") DatabaseClientProvider databaseClientProvider,
        BatchProperties batchProperties) {
    return new MarkLogicBatchConfigurer(databaseClientProvider, batchProperties);
}

@Bean
@Conditional(TenancyFiltersAutoConfiguration.TenantCondition.class)
public FilterRegistrationBean tenancyContextIntegrationFilter(TenantProvider tenantProvider,
        List<TenantIdentificationStrategy> strategyList) {
    FilterRegistrationBean registration = new FilterRegistrationBean();
    TenancyContextIntegrationFilter filter = new TenancyContextIntegrationFilter(strategyList, tenantProvider);
    registration.setFilter(filter);
    // just after all Security Filters
    registration.setOrder(TENANCY_CONTEXT_INTEGRATION_FILTER_ORDER);
    return registration;
}

@Bean
@Conditional(AlcoholCondition.class)
public Drink beer() {
    return new Drink() {
        @Override
        public String getName() {
            return "Beer";
        }
    };
}

@Bean
@Conditional(AlcoholCondition.class)
public Drink wine() {
    return new Drink() {
        @Override
        public String getName() {
            return "Wine";
        }
    };
}

@Bean
@Conditional(SodaCondition.class)
public Drink cola() {
    return new Drink() {
        @Override
        public String getName() {
            return "cola";
        }
    };
}

@Bean
@Conditional(SodaCondition.class)
public Drink fanta() {
    return new Drink() {
        @Override
        public String getName() {
            return "fanta";
        }
    };
}

@Bean
@Conditional(NoTestSchedulerPresent.class)
public PoolConfiguration localPoolConfiguration() {
    return new PoolConfiguration(Schedulers.from(Executors.newFixedThreadPool(threadPoolSize)), observeOnCapacity);
}

@Bean
@Conditional(ConfigCondition1.class)
public ZuulFilter zuulFilter1() {
    return createZuulFilter(0);
}