public class FederatedScheme extends DistributedScheme
FederatedScheme
creates the infrastructure required for federated caches.Modifier and Type | Class and Description |
---|---|
static class |
FederatedScheme.NameConverter
The NameConverter is an implementation of
Converter that converts an internal cache name to a cache-mapping, binding it to a federated scheme. |
static class |
FederatedScheme.TopologyReference
The TopologyReference class is used to reference a Federation defined in the operational config.
|
DistributedScheme.BackupConfig
MapBuilder.Dependencies
m_serviceDependencies
DELIM_APPLICATION_SCOPE, DELIM_DOMAIN_PARTITION
Constructor and Description |
---|
FederatedScheme() |
Modifier and Type | Method and Description |
---|---|
AddressProvider |
getAddressProvider()
Return the configured address-provider builder.
|
Set<String> |
getInternalCacheNames()
Return a set of internal cache names.
|
FederatedServiceLoadBalancerBuilder |
getLoadBalancerBuilder()
Return the load-balancer builder.
|
Converter<String,String> |
getNameConverter()
Return a converter that converts an internal cache name to a cache-mapping that ties it to this federated scheme.
|
String |
getServiceType()
Return the service type.
|
com.oracle.common.net.SocketProvider |
getSocketProvider()
Return the configured socket provider.
|
List<FederatedScheme.TopologyReference> |
getTopologies()
Return the list of topology references.
|
BackingMapManager |
realizeBackingMapManager(ConfigurableCacheFactory factory)
Realize a
BackingMapManager to be scoped by the specified ConfigurableCacheFactory . |
Service |
realizeService(com.tangosol.config.expression.ParameterResolver resolver, ClassLoader loader, Cluster cluster)
Realize (ensure) a Service.
|
void |
setAddressProvider(ParameterizedBuilder<AddressProvider> addrProviderBuilder)
Set the address provider.
|
void |
setJournalcacheHighunits(int nHighUnits)
Set the high-units limit for the journal cache used in the federation.
|
void |
setLoadBalancer(FederatedServiceLoadBalancerBuilder bldrLoadBalancer)
Set the load-balancer builder.
|
void |
setSendOldValue(boolean fSendOldValue)
Set the flag to indicate if the old value should be sent when replicating.
|
void |
setSocketProvider(com.oracle.common.net.SocketProvider socketProvider)
Set the
SocketProvider . |
void |
setTopologies(List<FederatedScheme.TopologyReference> listRefs)
Set the list of topology references.
|
getBackingMapScheme, getBackupMapConfig, getBundleManager, getEventInterceptorBuilders, isRunningClusterNeeded, setBackingMapScheme, setBackupMapConfig, setBundleManager, setEventInterceptorBuilders
establishMapListeners, getDefaultParameterResolver, getListenerBuilder, realizeCache, realizeMap, setListenerBuilder, validate
getScopedServiceName, getScopeName, getServiceBuilder, getServiceDependencies, getServiceName, getXml, injectScopeNameIntoService, isAutoStart, setApplicationContext, setAutoStart, setScopeName, setServiceDependencies, setServiceName, setXml
getSchemeName, isAnonymous, setSchemeName, validate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getScopedServiceName, getServiceBuilder, getServiceName, isAutoStart
getSchemeName, isAnonymous
public String getServiceType()
getServiceType
in interface ServiceScheme
getServiceType
in class DistributedScheme
public Service realizeService(com.tangosol.config.expression.ParameterResolver resolver, ClassLoader loader, Cluster cluster)
realizeService
in interface ServiceBuilder
realizeService
in class AbstractServiceScheme<com.tangosol.internal.net.service.grid.PartitionedCacheDependencies>
resolver
- the ParameterResolverloader
- the ClassLoadercluster
- the Cluster which will already be running if necessarypublic BackingMapManager realizeBackingMapManager(ConfigurableCacheFactory factory)
AbstractCachingScheme
BackingMapManager
to be scoped by the specified ConfigurableCacheFactory
.realizeBackingMapManager
in interface BackingMapManagerBuilder
realizeBackingMapManager
in class AbstractCachingScheme<com.tangosol.internal.net.service.grid.PartitionedCacheDependencies>
factory
- the ConfigurableCacheFactory
BackingMapManager
public FederatedServiceLoadBalancerBuilder getLoadBalancerBuilder()
@Injectable(value="load-balancer") public void setLoadBalancer(FederatedServiceLoadBalancerBuilder bldrLoadBalancer)
bldrLoadBalancer
- the federation service load-balancerpublic List<FederatedScheme.TopologyReference> getTopologies()
@Injectable public void setTopologies(List<FederatedScheme.TopologyReference> listRefs)
listRefs
- the list of topology references@Injectable public void setJournalcacheHighunits(int nHighUnits)
nHighUnits
- the high-units limit.@Injectable public void setSendOldValue(boolean fSendOldValue)
fSendOldValue
- true if the old value should be sent.public AddressProvider getAddressProvider()
@Injectable(value="address-provider") public void setAddressProvider(ParameterizedBuilder<AddressProvider> addrProviderBuilder)
addrProviderBuilder
- the federation service address provider builderpublic com.oracle.common.net.SocketProvider getSocketProvider()
@Injectable(value="socket-provider") public void setSocketProvider(com.oracle.common.net.SocketProvider socketProvider)
SocketProvider
.socketProvider
- the configured socket providerpublic Set<String> getInternalCacheNames()