本文整理汇总了Java中com.jivesoftware.os.routing.bird.shared.TenantsServiceConnectionDescriptorProvider类的典型用法代码示例。如果您正苦于以下问题:Java TenantsServiceConnectionDescriptorProvider类的具体用法?Java TenantsServiceConnectionDescriptorProvider怎么用?Java TenantsServiceConnectionDescriptorProvider使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
TenantsServiceConnectionDescriptorProvider类属于com.jivesoftware.os.routing.bird.shared包,在下文中一共展示了TenantsServiceConnectionDescriptorProvider类的6个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: Builder
import com.jivesoftware.os.routing.bird.shared.TenantsServiceConnectionDescriptorProvider; //导入依赖的package包/类
private Builder(OAuthSignerProvider signerProvider,
TenantsServiceConnectionDescriptorProvider<T> connectionPoolProvider,
ClientHealthProvider clientHealthProvider) {
this.signerProvider = signerProvider;
this.connectionPoolProvider = connectionPoolProvider;
this.clientHealthProvider = clientHealthProvider;
}
开发者ID:jivesoftware,项目名称:routing-bird,代码行数:9,代码来源:TenantRoutingHttpClientInitializer.java
示例2: initialize
import com.jivesoftware.os.routing.bird.shared.TenantsServiceConnectionDescriptorProvider; //导入依赖的package包/类
public MiruRebalanceDirector initialize(MiruClusterRegistry clusterRegistry,
MiruWALClient miruWALClient,
OrderIdProvider orderIdProvider,
TenantAwareHttpClient<String> readerClient,
HttpResponseMapper responseMapper,
TenantsServiceConnectionDescriptorProvider<String> readerConnectionDescriptorsProvider) throws Exception {
return new MiruRebalanceDirector(clusterRegistry, miruWALClient, orderIdProvider, readerClient, responseMapper, readerConnectionDescriptorsProvider);
}
开发者ID:jivesoftware,项目名称:miru,代码行数:10,代码来源:MiruRebalanceInitializer.java
示例3: MiruRebalanceDirector
import com.jivesoftware.os.routing.bird.shared.TenantsServiceConnectionDescriptorProvider; //导入依赖的package包/类
public MiruRebalanceDirector(MiruClusterRegistry clusterRegistry,
MiruWALClient miruWALClient,
OrderIdProvider orderIdProvider,
TenantAwareHttpClient<String> readerClient,
HttpResponseMapper responseMapper,
TenantsServiceConnectionDescriptorProvider<String> readerConnectionDescriptorsProvider) {
this.clusterRegistry = clusterRegistry;
this.miruWALClient = miruWALClient;
this.orderIdProvider = orderIdProvider;
this.readerClient = readerClient;
this.responseMapper = responseMapper;
this.readerConnectionDescriptorsProvider = readerConnectionDescriptorsProvider;
}
开发者ID:jivesoftware,项目名称:miru,代码行数:14,代码来源:MiruRebalanceDirector.java
示例4: run
import com.jivesoftware.os.routing.bird.shared.TenantsServiceConnectionDescriptorProvider; //导入依赖的package包/类
@Override
public void run() {
try {
TenantRoutingProvider tenantRoutingProvider = deployable.getTenantRoutingProvider();
TenantsServiceConnectionDescriptorProvider connections = tenantRoutingProvider.getConnections(serviceName, "main", discoveryIntervalMillis);
ConnectionDescriptors selfConnections = connections.getConnections("");
for (ConnectionDescriptor connectionDescriptor : selfConnections.getConnectionDescriptors()) {
InstanceDescriptor routingInstanceDescriptor = connectionDescriptor.getInstanceDescriptor();
RingMember routingRingMember = new RingMember(
Strings.padStart(String.valueOf(routingInstanceDescriptor.instanceName), 5, '0') + "_" + routingInstanceDescriptor.instanceKey);
if (!blacklistRingMembers.contains(routingRingMember)) {
HostPort hostPort = connectionDescriptor.getHostPort();
InstanceDescriptor instanceDescriptor = connectionDescriptor.getInstanceDescriptor();
AmzaRingStoreWriter ringWriter = amzaService.getRingWriter();
ringWriter.register(routingRingMember,
new RingHost(instanceDescriptor.datacenter,
instanceDescriptor.rack,
hostPort.getHost(),
hostPort.getPort()),
-1,
false);
}
}
systemRingSize.set(selfConnections.getConnectionDescriptors().size());
} catch (Exception x) {
LOG.warn("Failed while calling routing bird discovery.", x);
}
}
开发者ID:jivesoftware,项目名称:amza,代码行数:31,代码来源:RoutingBirdAmzaDiscovery.java
示例5: builder
import com.jivesoftware.os.routing.bird.shared.TenantsServiceConnectionDescriptorProvider; //导入依赖的package包/类
public Builder<T> builder(
TenantsServiceConnectionDescriptorProvider<T> connectionPoolProvider,
ClientHealthProvider clientHealthProvider) {
return new Builder<>(signerProvider, connectionPoolProvider, clientHealthProvider);
}
开发者ID:jivesoftware,项目名称:routing-bird,代码行数:6,代码来源:TenantRoutingHttpClientInitializer.java
示例6: RoutingBirdHostPortProvider
import com.jivesoftware.os.routing.bird.shared.TenantsServiceConnectionDescriptorProvider; //导入依赖的package包/类
public RoutingBirdHostPortProvider(TenantsServiceConnectionDescriptorProvider<T> connectionDescriptorProvider, T tenantId) {
this.connectionDescriptorProvider = connectionDescriptorProvider;
this.tenantId = tenantId;
}
开发者ID:jivesoftware,项目名称:miru,代码行数:5,代码来源:RoutingBirdHostPortProvider.java
注:本文中的com.jivesoftware.os.routing.bird.shared.TenantsServiceConnectionDescriptorProvider类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论