@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(); }
/** * 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(); }
@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(); }
@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); }
@Bean @Conditional(ConfigCondition2.class) public ZuulFilter zuulFilter2() { return createZuulFilter(1); }
@Bean @Conditional(ConfigCondition3.class) public ZuulFilter zuulFilter3() { return createZuulFilter(2); }
@Bean @Conditional(ConfigCondition4.class) public ZuulFilter zuulFilter4() { return createZuulFilter(3); }
@Bean @Conditional(ConfigCondition5.class) public ZuulFilter zuulFilter5() { return createZuulFilter(4); }
@Bean @Conditional(ConfigCondition6.class) public ZuulFilter zuulFilter6() { return createZuulFilter(5); }
@Bean @Conditional(ConfigCondition7.class) public ZuulFilter zuulFilter7() { return createZuulFilter(6); }
@Bean @Conditional(ConfigCondition8.class) public ZuulFilter zuulFilter8() { return createZuulFilter(7); }
@Bean @Conditional(ConfigCondition9.class) public ZuulFilter zuulFilter9() { return createZuulFilter(8); }
@Bean @Conditional(ConfigCondition10.class) public ZuulFilter zuulFilter10() { return createZuulFilter(9); }
@Bean @Conditional(ConfigCondition1.class) public FilterRegistrationBean bucket4JFilter1() { return getFilterRegistrationBean(0); }