本文整理汇总了Java中org.springframework.cloud.service.ServiceConnectorConfig类的典型用法代码示例。如果您正苦于以下问题:Java ServiceConnectorConfig类的具体用法?Java ServiceConnectorConfig怎么用?Java ServiceConnectorConfig使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ServiceConnectorConfig类属于org.springframework.cloud.service包,在下文中一共展示了ServiceConnectorConfig类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
/**
* Creates an {@link S3Connector} instance with embedded {@link AmazonS3 Amazon Web Services S3 SDK Client} from
* {@link S3ServiceInfo}.
* @param serviceInfo S3ServiceInfo provided by {@link org.springframework.cloud.cloudfoundry.CloudFoundryServiceInfoCreator}
* implementation included within the application.
* @param serviceConnectorConfig
* @return
*/
@Override
public S3Connector create(S3ServiceInfo serviceInfo, ServiceConnectorConfig serviceConnectorConfig) {
AWSCredentials credentials = new BasicAWSCredentials(serviceInfo.getAccessKey(), serviceInfo.getSecretKey());
AWSCredentialsProvider credentialsProvider = new AWSStaticCredentialsProvider(credentials);
AwsClientBuilder.EndpointConfiguration endpointConfig = new AwsClientBuilder.EndpointConfiguration(
serviceInfo.getEndpoint(), Region.getRegion(Regions.DEFAULT_REGION).getName());
AmazonS3 amazonS3 = AmazonS3ClientBuilder
.standard()
.withEndpointConfiguration(endpointConfig)
.withCredentials(credentialsProvider)
.enablePathStyleAccess()
.build();
if (serviceInfo.getBucket() != null) {
log.debug("Creating connector addressing ECS bucket: " + serviceInfo.getBucket());
return new S3Connector(amazonS3, serviceInfo.getEndpoint(), serviceInfo.getBucket());
} else {
log.debug("Creating connector addressing ECS namespace.");
return new S3Connector(amazonS3, serviceInfo.getEndpoint());
}
}
开发者ID:spiegela,项目名称:spring-cloud-ecs-connector,代码行数:29,代码来源:S3ServiceConnectorCreator.java
示例2: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public ClientCache create(GemfireServiceInfo serviceInfo, ServiceConnectorConfig serviceConnectorConfig) {
for (URI locator : serviceInfo.getLocators()) {
factory.addPoolLocator(locator.getHost(), locator.getPort());
}
if (serviceInfo.getUsername() != null) {
factory.set("security-client-auth-init", "io.pivotal.spring.cloud.service.gemfire.UserAuthInitialize.create");
factory.set("security-username", serviceInfo.getUsername());
}
if (serviceInfo.getPassword() != null) {
factory.set("security-password", serviceInfo.getPassword());
}
if (serviceConnectorConfig != null && serviceConnectorConfig.getClass().isAssignableFrom(GemfireServiceConnectorConfig.class)) {
apply((GemfireServiceConnectorConfig) serviceConnectorConfig);
}
return factory.create();
}
开发者ID:pivotal-cf,项目名称:spring-cloud-gemfire-connector,代码行数:18,代码来源:GemfireClientCacheCreator.java
示例3: testCreate
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Test
public void testCreate() {
final CloudantServiceInfo badUrlServiceInfo = new CloudantServiceInfo(
"id",
"username",
"password",
"hostname",
443,
"url"
);
assertNull(creator.create(badUrlServiceInfo, new ServiceConnectorConfig() {
}));
final CloudantServiceInfo serviceInfo = new CloudantServiceInfo(
"testId",
"username",
"password",
"username.cloudant.com",
443,
"https://username:[email protected]"
);
assertTrue(creator.create(serviceInfo, new ServiceConnectorConfig() {
}) instanceof CouchDbInstance);
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:25,代码来源:CloudantInstanceCreatorTest.java
示例4: testCreate
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Test
public void testCreate() {
final String test1_hostname = "example.com";
final String test1_username = "username";
final String test1_password = "password";
final String test1_database = "database";
final List<ServerAddress> servers = ImmutableList.of(
new ServerAddress(test1_hostname)
);
final List<MongoCredential> credentials = ImmutableList.of(
MongoCredential.createCredential(test1_username, test1_database, test1_password.toCharArray())
);
final MongoClientOptions options = new MongoClientOptions.Builder().build();
final ComposeForMongoDBServiceInfo serviceInfo
= new ComposeForMongoDBServiceInfo("id", servers, credentials, options);
assertTrue(creator.create(serviceInfo, new ServiceConnectorConfig() {
}) instanceof MongoClient);
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:22,代码来源:ComposeForMongoDBInstanceCreatorTest.java
示例5: filterPooledDataSourceCreators
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
private Collection<PooledDataSourceCreator<SI>> filterPooledDataSourceCreators(ServiceConnectorConfig serviceConnectorConfig) {
if (serviceConnectorConfig != null) {
List<String> pooledDataSourceNames = ((DataSourceConfig) serviceConnectorConfig).getPooledDataSourceNames();
if (pooledDataSourceNames != null) {
List<PooledDataSourceCreator<SI>> filtered = new ArrayList<PooledDataSourceCreator<SI>>();
for (String name : pooledDataSourceNames) {
for (String key : pooledDataSourceCreators.keySet()) {
if (key.contains(name)) {
filtered.add(pooledDataSourceCreators.get(key));
}
}
}
return filtered;
}
}
return pooledDataSourceCreators.values();
}
开发者ID:spring-cloud,项目名称:spring-cloud-connectors,代码行数:20,代码来源:DataSourceCreator.java
示例6: setBasicDataSourceProperties
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
protected void setBasicDataSourceProperties(DataSource basicDataSource, RelationalServiceInfo serviceInfo,
ServiceConnectorConfig serviceConnectorConfig,
String driverClassName, String validationQuery) {
BeanWrapper target = new BeanWrapperImpl(basicDataSource);
target.setPropertyValue("driverClassName", driverClassName);
target.setPropertyValue("url", serviceInfo.getJdbcUrl());
if (validationQuery != null) {
target.setPropertyValue("validationQuery", validationQuery);
target.setPropertyValue("testOnBorrow", true);
}
if (serviceConnectorConfig == null) {
// choose sensible values so that we set max connection pool size to what
// free tier services on Cloud Foundry and Heroku allow
serviceConnectorConfig = new DataSourceConfig(new PoolConfig(4, 30000), null);
}
configurer.configure(basicDataSource, (DataSourceConfig)serviceConnectorConfig);
}
开发者ID:spring-cloud,项目名称:spring-cloud-connectors,代码行数:19,代码来源:DbcpLikePooledDataSourceCreator.java
示例7: createSpringConnectionFactory
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
private CachingConnectionFactory createSpringConnectionFactory(AmqpServiceInfo serviceInfo,
ServiceConnectorConfig serviceConnectorConfiguration,
com.rabbitmq.client.ConnectionFactory connectionFactory) {
CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory(connectionFactory);
if (serviceInfo.getUris() != null) {
cachingConnectionFactory.setAddresses(getAddresses(serviceInfo));
}
if (serviceConnectorConfiguration != null) {
Integer channelCacheSize = ((RabbitConnectionFactoryConfig) serviceConnectorConfiguration).getChannelCacheSize();
if (channelCacheSize != null) {
cachingConnectionFactory.setChannelCacheSize(channelCacheSize);
}
}
return cachingConnectionFactory;
}
开发者ID:spring-cloud,项目名称:spring-cloud-connectors,代码行数:19,代码来源:RabbitConnectionFactoryCreator.java
示例8: postProcessBeanFactory
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@SuppressWarnings({ "unchecked", "rawtypes" })
@Override
public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {
try {
Constructor<?> ctor = serviceConnectorFactoryType.getConstructor(String.class, ServiceConnectorConfig.class);
AbstractCloudServiceConnectorFactory<?> serviceFactory = (AbstractCloudServiceConnectorFactory<?>)ctor.newInstance(serviceId, serviceConnectorConfig);
serviceFactory.setServiceConnectorType((Class)serviceConnectorType);
serviceFactory.setBeanFactory(beanFactory);
serviceFactory.afterPropertiesSet();
// id is the beanId if specified, otherwise the serviceId
if (StringUtils.hasText(beanId)) {
beanFactory.registerSingleton(beanId, serviceFactory);
} else {
beanFactory.registerSingleton(serviceFactory.getServiceId(), serviceFactory);
}
} catch (Exception ex) {
throw new BeanCreationException("Error registering service factory", ex);
}
}
开发者ID:spring-cloud,项目名称:spring-cloud-connectors,代码行数:20,代码来源:AbstractCloudServiceFactoryParser.java
示例9: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public VaultTemplate create(VaultServiceInfo serviceInfo,
ServiceConnectorConfig serviceConnectorConfig) {
TokenAuthentication tokenAuthentication = new TokenAuthentication(new String(
serviceInfo.getToken()));
SimpleSessionManager sessionManager = new SimpleSessionManager(
tokenAuthentication);
// early pre-init
assert sessionManager.getSessionToken() != null;
ClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
if (serviceConnectorConfig != null
&& serviceConnectorConfig instanceof VaultServiceConnectorConfig) {
VaultServiceConnectorConfig config = (VaultServiceConnectorConfig) serviceConnectorConfig;
requestFactory = config.getClientHttpRequestFactory();
}
VaultEndpoint endpoint = VaultEndpoint.from(URI.create(serviceInfo.getUri()));
return new VaultTemplate(endpoint, requestFactory, sessionManager);
}
开发者ID:pivotal-cf,项目名称:spring-cloud-vault-connector,代码行数:27,代码来源:VaultTemplateCreator.java
示例10: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
/**
* Creates a {@link FeatureFlagsService} by given
* {@link FeatureFlagsServiceInfo} and {@link ServiceConnectorConfig}.
*/
@Override
public FeatureFlagsService create(FeatureFlagsServiceInfo serviceInfo,
ServiceConnectorConfig serviceConnectorConfig) {
URI baseUri = createBaseUri(serviceInfo.getUri());
RestOperations restOperations = createRestOperations(serviceInfo.getUserName(), serviceInfo.getPassword());
return new FeatureFlagsService(baseUri, restOperations);
}
开发者ID:SAP,项目名称:cloud-cf-feature-flags-sample,代码行数:14,代码来源:FeatureFlagsServiceConnectorCreator.java
示例11: createGemfireConnectorConfig
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
public ServiceConnectorConfig createGemfireConnectorConfig() {
// Create a custom service connector config object which sets specific properties
// for the ClientCache as exposed by the GemfireServiceConnectorConfig.
GemfireServiceConnectorConfig gemfireConfig = new GemfireServiceConnectorConfig();
gemfireConfig.setPoolIdleTimeout(7777L);
return gemfireConfig;
}
开发者ID:gemfire,项目名称:cf-gemfire-connector-examples,代码行数:9,代码来源:ClientConfiguration.java
示例12: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public CouchDbInstance create(CloudantServiceInfo serviceInfo,
ServiceConnectorConfig serviceConnectorConfig) {
HttpClient httpClient;
try {
httpClient = new StdHttpClient.Builder()
.url(serviceInfo.getUrl())
.build();
return new StdCouchDbInstance(httpClient);
} catch (MalformedURLException e) {
LOG.logp(Level.WARNING, CloudantInstanceCreator.class.getName(), "create", "Error parsing URL", e);
return null;
}
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:15,代码来源:CloudantInstanceCreator.java
示例13: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public KafkaConsumer create(
final MessageHubServiceInfo serviceInfo,
final ServiceConnectorConfig serviceConnectorConfig) {
// Producer Configuration
final Map<String, Object> consumerConfiguration = new HashMap<>();
consumerConfiguration.put("bootstrap.servers", Joiner.on(',').join(serviceInfo.getBrokers()));
consumerConfiguration.put("security.protocol", "SASL_SSL");
consumerConfiguration.put("sasl.mechanism", "PLAIN");
consumerConfiguration.put("ssl.protocol", "TLSv1.2");
consumerConfiguration.put("ssl.enabled.protocols", "TLSv1.2");
consumerConfiguration.put("ssl.truststore.location", System.getProperty("java.home") + "/lib/security/cacerts");
consumerConfiguration.put("ssl.truststore.password", "changeit");
consumerConfiguration.put("ssl.truststore.type", "jks");
if (serviceConnectorConfig != null && serviceConnectorConfig instanceof MessageHubFactoryConfig) {
consumerConfiguration.putAll((MessageHubFactoryConfig) serviceConnectorConfig);
}
// JAAS Login Module Configuration
final Map<String, Object> loginModuleConfiguration = new HashMap<>();
loginModuleConfiguration.put("serviceName", "kafka");
loginModuleConfiguration.put("username", serviceInfo.getUsername());
loginModuleConfiguration.put("password", serviceInfo.getPassword());
MemoryConfiguration.use().addConfigurationEntry("KafkaClient",
"kafka", REQUIRED, loginModuleConfiguration
);
return new KafkaConsumer(consumerConfiguration);
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:31,代码来源:MessageHubConsumerCreator.java
示例14: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public Discovery create(
final WatsonDiscoveryServiceInfo serviceInfo,
final ServiceConnectorConfig serviceConnectorConfig) {
final Discovery service = new Discovery("2016-12-01");
service.setEndPoint(serviceInfo.getUrl());
service.setUsernameAndPassword(serviceInfo.getUsername(), serviceInfo.getPassword());
return service;
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:10,代码来源:WatsonDiscoveryCreator.java
示例15: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public NaturalLanguageClassifier create(
final WatsonNaturalLanguageClassifierServiceInfo serviceInfo,
final ServiceConnectorConfig serviceConnectorConfig) {
final NaturalLanguageClassifier service = new NaturalLanguageClassifier();
service.setEndPoint(serviceInfo.getUrl());
service.setUsernameAndPassword(serviceInfo.getUsername(), serviceInfo.getPassword());
return service;
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:10,代码来源:WatsonNaturalLanguageClassifierCreator.java
示例16: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public V3 create(IBMObjectStorageServiceInfo serviceInfo,
ServiceConnectorConfig serviceConnectorConfig) {
final Identifier domainIdent = Identifier.byName(serviceInfo.getDomainName());
final Identifier projectIdent = Identifier.byName(serviceInfo.getProject());
return OSFactory.builderV3().endpoint(serviceInfo.getAuthUrl())
.credentials(serviceInfo.getUserId(), serviceInfo.getPassword())
.scopeToProject(projectIdent, domainIdent);
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:10,代码来源:V3InstanceCreator.java
示例17: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public ToneAnalyzer create(
final WatsonToneAnalyzerServiceInfo serviceInfo,
final ServiceConnectorConfig serviceConnectorConfig) {
final ToneAnalyzer service = new ToneAnalyzer(ToneAnalyzer.VERSION_DATE_2016_05_19);
service.setEndPoint(serviceInfo.getUrl());
service.setUsernameAndPassword(serviceInfo.getUsername(), serviceInfo.getPassword());
return service;
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:10,代码来源:WatsonToneAnalyzerCreator.java
示例18: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public RetrieveAndRank create(
final WatsonRetrieveAndRankServiceInfo serviceInfo,
final ServiceConnectorConfig serviceConnectorConfig) {
final RetrieveAndRank service = new RetrieveAndRank();
service.setEndPoint(serviceInfo.getUrl());
service.setUsernameAndPassword(serviceInfo.getUsername(), serviceInfo.getPassword());
return service;
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:10,代码来源:WatsonRetrieveAndRankCreator.java
示例19: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public ConversationService create(
final WatsonConversationServiceInfo serviceInfo,
final ServiceConnectorConfig serviceConnectorConfig) {
final ConversationService service = new ConversationService(ConversationService.VERSION_DATE_2016_09_20);
service.setEndPoint(serviceInfo.getUrl());
service.setUsernameAndPassword(serviceInfo.getUsername(), serviceInfo.getPassword());
return service;
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:10,代码来源:WatsonConversationCreator.java
示例20: create
import org.springframework.cloud.service.ServiceConnectorConfig; //导入依赖的package包/类
@Override
public LanguageTranslator create(
final WatsonDiscoveryServiceInfo serviceInfo,
final ServiceConnectorConfig serviceConnectorConfig) {
final LanguageTranslator service = new LanguageTranslator();
service.setEndPoint(serviceInfo.getUrl());
service.setUsernameAndPassword(serviceInfo.getUsername(), serviceInfo.getPassword());
return service;
}
开发者ID:IBM-Cloud,项目名称:bluemix-cloud-connectors,代码行数:10,代码来源:WatsonLanguageTranslatorCreator.java
注:本文中的org.springframework.cloud.service.ServiceConnectorConfig类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论