ClusterWideConfigurationService (Hazelcast Root 3.12-BETA-1 API)

java.lang.Object
- com.hazelcast.internal.dynamicconfig.ClusterWideConfigurationService

All Implemented Interfaces:: ClusterVersionListener, ConfigurationService, CoreService, ManagedService, PreJoinAwareService, SplitBrainHandlerService

public class ClusterWideConfigurationService
extends Object
implements PreJoinAwareService, CoreService, ClusterVersionListener, ManagedService, ConfigurationService, SplitBrainHandlerService

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class ClusterWideConfigurationService.Merger

Nested Classes
Modifier and Type	Class and Description
`static class`	`ClusterWideConfigurationService.Merger`

Field Summary

Fields
Modifier and Type Field and Description

static int CONFIG_PUBLISH_MAX_ATTEMPT_COUNT

static String SERVICE_NAME

Fields
Modifier and Type	Field and Description
`static int`	`CONFIG_PUBLISH_MAX_ATTEMPT_COUNT`
`static String`	`SERVICE_NAME`

Constructor Summary

Constructors
Constructor and Description

ClusterWideConfigurationService(NodeEngine nodeEngine, DynamicConfigListener dynamicConfigListener)

Constructors
Constructor and Description
`ClusterWideConfigurationService(NodeEngine nodeEngine, DynamicConfigListener dynamicConfigListener)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`broadcastConfig(IdentifiedDataSerializable config)` Registers a dynamic configurations to all cluster members.
`ICompletableFuture<Object>`	`broadcastConfigAsync(IdentifiedDataSerializable config)`
`AtomicLongConfig`	`findAtomicLongConfig(String name)` Finds existing AtomicLong config.
`AtomicReferenceConfig`	`findAtomicReferenceConfig(String name)` Finds existing AtomicReference config.
`EventJournalConfig`	`findCacheEventJournalConfig(String name)` Finds existing CacheEventJournal config.
`CacheSimpleConfig`	`findCacheSimpleConfig(String name)` Finds existing Cache config.
`CardinalityEstimatorConfig`	`findCardinalityEstimatorConfig(String name)` Finds existing Cardinality Estimator config.
`CountDownLatchConfig`	`findCountDownLatchConfig(String name)` Finds existing CountDownLatch config.
`DurableExecutorConfig`	`findDurableExecutorConfig(String name)` Finds existing Durable Executor config.
`ExecutorConfig`	`findExecutorConfig(String name)` Finds existing Executor config.
`FlakeIdGeneratorConfig`	`findFlakeIdGeneratorConfig(String baseName)` Finds existing FlakeIdGeneratorConfig config.
`ListConfig`	`findListConfig(String name)` Finds existing List config.
`LockConfig`	`findLockConfig(String name)` Finds existing Lock config.
`MapConfig`	`findMapConfig(String name)` Finds existing Map config.
`EventJournalConfig`	`findMapEventJournalConfig(String name)` Finds existing MapEventJournal config.
`MerkleTreeConfig`	`findMapMerkleTreeConfig(String name)` Finds an existing map `MerkleTreeConfig`.
`MultiMapConfig`	`findMultiMapConfig(String name)` Finds existing Multimap config.
`PNCounterConfig`	`findPNCounterConfig(String name)` Finds existing PN counter config.
`QueueConfig`	`findQueueConfig(String name)` Finds existing Queue config.
`ReliableTopicConfig`	`findReliableTopicConfig(String name)` Finds existing Reliable Topic config.
`ReplicatedMapConfig`	`findReplicatedMapConfig(String name)` Finds existing ReplicatedMap config.
`RingbufferConfig`	`findRingbufferConfig(String name)` Finds existing Ringbuffer config.
`ScheduledExecutorConfig`	`findScheduledExecutorConfig(String name)` Finds existing Scheduled Executor config.
`SemaphoreConfig`	`findSemaphoreConfig(String name)` Finds existing Semaphore config.
`SetConfig`	`findSetConfig(String name)` Finds existing Set config.
`TopicConfig`	`findTopicConfig(String name)` Finds existing Topic config.
`Map<String,AtomicLongConfig>`	`getAtomicLongConfigs()` Returns all registered AtomicLong configurations.
`Map<String,AtomicReferenceConfig>`	`getAtomicReferenceConfigs()` Returns all registered AtomicReference configurations.
`Map<String,EventJournalConfig>`	`getCacheEventJournalConfigs()` Returns all registered CacheEventJournal configurations.
`Map<String,CacheSimpleConfig>`	`getCacheSimpleConfigs()` Returns all registered cache configurations.
`ConcurrentMap<String,CardinalityEstimatorConfig>`	`getCardinalityEstimatorConfigs()` Returns all registered cardinality estimator configurations.
`Map<String,CountDownLatchConfig>`	`getCountDownLatchConfigs()` Returns all registered CountDownLatchConfig configurations.
`ConcurrentMap<String,DurableExecutorConfig>`	`getDurableExecutorConfigs()` Returns all registered durable executor configurations.
`ConcurrentMap<String,ExecutorConfig>`	`getExecutorConfigs()` Returns all registered executor configurations.
`Map<String,FlakeIdGeneratorConfig>`	`getFlakeIdGeneratorConfigs()` Returns all registered FlakeIdGenerator configurations.
`ConcurrentMap<String,ListConfig>`	`getListConfigs()` Returns all registered list configurations.
`Map<String,LockConfig>`	`getLockConfigs()` Returns all registered lock configurations.
`Map<String,MapConfig>`	`getMapConfigs()` Returns all registered map configurations.
`Map<String,EventJournalConfig>`	`getMapEventJournalConfigs()` Returns all registered MapEventJournal configurations.
`Map<String,MerkleTreeConfig>`	`getMapMerkleTreeConfigs()` Returns a map of all registered IMap `MerkleTreeConfig`s.
`ConcurrentMap<String,MultiMapConfig>`	`getMultiMapConfigs()` Returns all registered multimap configurations.
`ConcurrentMap<String,PNCounterConfig>`	`getPNCounterConfigs()` Returns all registered PN counter configurations.
`Operation`	`getPreJoinOperation()` An operation to be executed on the joining member before it is set as joined.
`Map<String,QueueConfig>`	`getQueueConfigs()` Returns all registered queue configurations.
`ConcurrentMap<String,ReliableTopicConfig>`	`getReliableTopicConfigs()` Returns all registered reliable topic configurations.
`ConcurrentMap<String,ReplicatedMapConfig>`	`getReplicatedMapConfigs()` Returns all registered replicated map configurations.
`ConcurrentMap<String,RingbufferConfig>`	`getRingbufferConfigs()` Returns all registered ringbuffer configurations.
`ConcurrentMap<String,ScheduledExecutorConfig>`	`getScheduledExecutorConfigs()` Returns all registered scheduled executor configurations.
`ConcurrentMap<String,SemaphoreConfig>`	`getSemaphoreConfigs()` Returns all registered semaphore configurations.
`ConcurrentMap<String,SetConfig>`	`getSetConfigs()` Returns all registered set configurations.
`ConcurrentMap<String,TopicConfig>`	`getTopicConfigs()` Returns all registered topic configurations.
`void`	`init(NodeEngine nodeEngine, Properties properties)` Initializes this service.
`void`	`onClusterVersionChange(Version newVersion)` Invoked on registered listeners after the new cluster version has been applied.
`Runnable`	`prepareMergeRunnable()` When the two separate clusters merge (resolve a split-brain), this method is called to return a `Runnable`, that will merge the clusters.
`void`	`registerConfigLocally(IdentifiedDataSerializable newConfig, ConfigCheckMode configCheckMode)` Register a dynamic configuration in a local member.
`void`	`reset()` Resets this service back to its initial state.
`void`	`shutdown(boolean terminate)` Shuts down this service.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - SERVICE_NAME
```
public static final String SERVICE_NAME
```
    See Also:
    
    Constant Field Values
  - CONFIG_PUBLISH_MAX_ATTEMPT_COUNT
```
public static final int CONFIG_PUBLISH_MAX_ATTEMPT_COUNT
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - ClusterWideConfigurationService
```
public ClusterWideConfigurationService(NodeEngine nodeEngine,
                                       DynamicConfigListener dynamicConfigListener)
```
- Method Detail
  - getPreJoinOperation
```
public Operation getPreJoinOperation()
```
    Description copied from interface: PreJoinAwareService
    
    An operation to be executed on the joining member before it is set as joined. As is the case with PostJoinAwareService.getPostJoinOperation()s, no partition locks, no key-based locks, no service level locks, no database interaction are allowed. Additionally, a pre-join operation is executed while the cluster lock is being held on the joining member, so it is important that the operation finishes quickly and does not interact with other locks. The Operation.getPartitionId() method should return a negative value. This means that the operations should not implement PartitionAwareOperation.
    Pre join operations should return response, which may also be a null response.
    
    Specified by:
    
    getPreJoinOperation in interface PreJoinAwareService
    
    Returns:
    
    an operation to be executed on joining member before it is set as joined. Can be null.
  - onClusterVersionChange
```
public void onClusterVersionChange(Version newVersion)
```
    Description copied from interface: ClusterVersionListener
    
    Invoked on registered listeners after the new cluster version has been applied. Listeners are executed synchronously immediately after ClusterStateManager#version has been updated and while the cluster service lock ClusterServiceImpl#lock is still locked, as part of the commit phase of the transaction changing the cluster version. Unhandled exceptions from listeners implementation will break the new version commit and a slow implementation will stall the system and may cause a transaction timeout. If new cluster version is null and property GroupProperty.INIT_CLUSTER_VERSION is set, the version set by this property will be provided as argument to the listener. If neither are set, running node's codebase version will be used.
    
    Specified by:
    
    onClusterVersionChange in interface ClusterVersionListener
    
    Parameters:
    
    newVersion - the new version
  - init
```
public void init(NodeEngine nodeEngine,
                 Properties properties)
```
    Description copied from interface: ManagedService
    
    Initializes this service.
    
    Specified by:
    
    init in interface ManagedService
    
    Parameters:
    
    nodeEngine - the NodeEngine that this service belongs to
    
    properties - the Properties (can be used to pass settings to the service)
  - reset
```
public void reset()
```
    Description copied from interface: ManagedService
    
    Resets this service back to its initial state.
    TODO: what is the purpose of reset
    
    Specified by:
    
    reset in interface ManagedService
  - shutdown
```
public void shutdown(boolean terminate)
```
    Description copied from interface: ManagedService
    
    Shuts down this service.
    TODO: what is the purpose of the terminate variable
    
    Specified by:
    
    shutdown in interface ManagedService
    
    Parameters:
    
    terminate - true to shut down this service
  - broadcastConfig
```
public void broadcastConfig(IdentifiedDataSerializable config)
```
    Description copied from interface: ConfigurationService
    
    Registers a dynamic configurations to all cluster members.
    
    Specified by:
    
    broadcastConfig in interface ConfigurationService
    
    Parameters:
    
    config - configuration to register
  - broadcastConfigAsync
```
public ICompletableFuture<Object> broadcastConfigAsync(IdentifiedDataSerializable config)
```
  - registerConfigLocally
```
public void registerConfigLocally(IdentifiedDataSerializable newConfig,
                                  ConfigCheckMode configCheckMode)
```
    Register a dynamic configuration in a local member. When a dynamic configuration with the same name already exists then this call has no effect.
    
    Parameters:
    
    newConfig - Configuration to register.
    
    configCheckMode - behaviour when a config is detected
    
    Throws:
    
    UnsupportedOperationException - when given configuration type is not supported
    
    ConfigurationException - when conflict is detected and configCheckMode is on THROW_EXCEPTION
  - findMultiMapConfig
```
public MultiMapConfig findMultiMapConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Multimap config.
    
    Specified by:
    
    findMultiMapConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Multimap config or null when requested MultiMap configuration does not exist
  - getMultiMapConfigs
```
public ConcurrentMap<String,MultiMapConfig> getMultiMapConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered multimap configurations.
    
    Specified by:
    
    getMultiMapConfigs in interface ConfigurationService
    
    Returns:
    
    registered multimap configurations
  - findMapConfig
```
public MapConfig findMapConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Map config.
    
    Specified by:
    
    findMapConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Map config or null when requested Map configuration does not exist
  - getMapConfigs
```
public Map<String,MapConfig> getMapConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered map configurations.
    
    Specified by:
    
    getMapConfigs in interface ConfigurationService
    
    Returns:
    
    registered map configurations
  - findTopicConfig
```
public TopicConfig findTopicConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Topic config.
    
    Specified by:
    
    findTopicConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Topic config or null when requested Topic configuration does not exist
  - getTopicConfigs
```
public ConcurrentMap<String,TopicConfig> getTopicConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered topic configurations.
    
    Specified by:
    
    getTopicConfigs in interface ConfigurationService
    
    Returns:
    
    registered topic configurations
  - findCardinalityEstimatorConfig
```
public CardinalityEstimatorConfig findCardinalityEstimatorConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Cardinality Estimator config.
    
    Specified by:
    
    findCardinalityEstimatorConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Cardinality Estimator config or null when requested Cardinality Estimator configuration does not exist
  - getCardinalityEstimatorConfigs
```
public ConcurrentMap<String,CardinalityEstimatorConfig> getCardinalityEstimatorConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered cardinality estimator configurations.
    
    Specified by:
    
    getCardinalityEstimatorConfigs in interface ConfigurationService
    
    Returns:
    
    registered cardinality estimator configurations
  - findPNCounterConfig
```
public PNCounterConfig findPNCounterConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing PN counter config.
    
    Specified by:
    
    findPNCounterConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    PN counter config or null when requested PN counter configuration does not exist
  - getPNCounterConfigs
```
public ConcurrentMap<String,PNCounterConfig> getPNCounterConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered PN counter configurations.
    
    Specified by:
    
    getPNCounterConfigs in interface ConfigurationService
    
    Returns:
    
    registered PN counter configurations
  - findExecutorConfig
```
public ExecutorConfig findExecutorConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Executor config.
    
    Specified by:
    
    findExecutorConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Executor config or null when requested Executor configuration does not exist
  - getExecutorConfigs
```
public ConcurrentMap<String,ExecutorConfig> getExecutorConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered executor configurations.
    
    Specified by:
    
    getExecutorConfigs in interface ConfigurationService
    
    Returns:
    
    registered executor configurations
  - findScheduledExecutorConfig
```
public ScheduledExecutorConfig findScheduledExecutorConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Scheduled Executor config.
    
    Specified by:
    
    findScheduledExecutorConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Scheduled Executor config or null when requested Scheduled Executor configuration does not exist
  - getScheduledExecutorConfigs
```
public ConcurrentMap<String,ScheduledExecutorConfig> getScheduledExecutorConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered scheduled executor configurations.
    
    Specified by:
    
    getScheduledExecutorConfigs in interface ConfigurationService
    
    Returns:
    
    registered scheduled executor configurations
  - findDurableExecutorConfig
```
public DurableExecutorConfig findDurableExecutorConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Durable Executor config.
    
    Specified by:
    
    findDurableExecutorConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Durable Executor config or null when requested Durable Executor configuration does not exist
  - getDurableExecutorConfigs
```
public ConcurrentMap<String,DurableExecutorConfig> getDurableExecutorConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered durable executor configurations.
    
    Specified by:
    
    getDurableExecutorConfigs in interface ConfigurationService
    
    Returns:
    
    registered durable executor configurations
  - findSemaphoreConfig
```
public SemaphoreConfig findSemaphoreConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Semaphore config.
    
    Specified by:
    
    findSemaphoreConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Semaphore config or null when requested Semaphore configuration does not exist
  - getSemaphoreConfigs
```
public ConcurrentMap<String,SemaphoreConfig> getSemaphoreConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered semaphore configurations.
    
    Specified by:
    
    getSemaphoreConfigs in interface ConfigurationService
    
    Returns:
    
    registered semaphore configurations
  - findRingbufferConfig
```
public RingbufferConfig findRingbufferConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Ringbuffer config.
    
    Specified by:
    
    findRingbufferConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Ringbuffer config or null when requested Ringbuffer configuration does not exist
  - getRingbufferConfigs
```
public ConcurrentMap<String,RingbufferConfig> getRingbufferConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered ringbuffer configurations.
    
    Specified by:
    
    getRingbufferConfigs in interface ConfigurationService
    
    Returns:
    
    registered ringbuffer configurations
  - findAtomicLongConfig
```
public AtomicLongConfig findAtomicLongConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing AtomicLong config.
    
    Specified by:
    
    findAtomicLongConfig in interface ConfigurationService
    
    Returns:
    
    AtomicLong Config or null when requested AtomicLong configuration does not exist
  - getAtomicLongConfigs
```
public Map<String,AtomicLongConfig> getAtomicLongConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered AtomicLong configurations.
    
    Specified by:
    
    getAtomicLongConfigs in interface ConfigurationService
    
    Returns:
    
    registered AtomicLong configurations
  - findAtomicReferenceConfig
```
public AtomicReferenceConfig findAtomicReferenceConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing AtomicReference config.
    
    Specified by:
    
    findAtomicReferenceConfig in interface ConfigurationService
    
    Returns:
    
    AtomicReference Config or null when requested AtomicReference configuration does not exist
  - findCountDownLatchConfig
```
public CountDownLatchConfig findCountDownLatchConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing CountDownLatch config.
    
    Specified by:
    
    findCountDownLatchConfig in interface ConfigurationService
    
    Returns:
    
    CountDownLatch Config or null when requested CountDownLatch configuration does not exist
  - getAtomicReferenceConfigs
```
public Map<String,AtomicReferenceConfig> getAtomicReferenceConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered AtomicReference configurations.
    
    Specified by:
    
    getAtomicReferenceConfigs in interface ConfigurationService
    
    Returns:
    
    registered AtomicReference configurations
  - getCountDownLatchConfigs
```
public Map<String,CountDownLatchConfig> getCountDownLatchConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered CountDownLatchConfig configurations.
    
    Specified by:
    
    getCountDownLatchConfigs in interface ConfigurationService
    
    Returns:
    
    registered CountDownLatchConfig configurations
  - findLockConfig
```
public LockConfig findLockConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Lock config.
    
    Specified by:
    
    findLockConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Lock config or null when requested Lock configuration does not exist
  - getLockConfigs
```
public Map<String,LockConfig> getLockConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered lock configurations.
    
    Specified by:
    
    getLockConfigs in interface ConfigurationService
    
    Returns:
    
    registered lock configurations
  - findListConfig
```
public ListConfig findListConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing List config.
    
    Specified by:
    
    findListConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    List config or null when requested List configuration does not exist
  - getListConfigs
```
public ConcurrentMap<String,ListConfig> getListConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered list configurations.
    
    Specified by:
    
    getListConfigs in interface ConfigurationService
    
    Returns:
    
    registered list configurations
  - findQueueConfig
```
public QueueConfig findQueueConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Queue config.
    
    Specified by:
    
    findQueueConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Queue config or null when requested Queue configuration does not exist
  - getQueueConfigs
```
public Map<String,QueueConfig> getQueueConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered queue configurations.
    
    Specified by:
    
    getQueueConfigs in interface ConfigurationService
    
    Returns:
    
    registered queue configurations
  - findSetConfig
```
public SetConfig findSetConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Set config.
    
    Specified by:
    
    findSetConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Set config or null when requested Set configuration does not exist
  - getSetConfigs
```
public ConcurrentMap<String,SetConfig> getSetConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered set configurations.
    
    Specified by:
    
    getSetConfigs in interface ConfigurationService
    
    Returns:
    
    registered set configurations
  - findReplicatedMapConfig
```
public ReplicatedMapConfig findReplicatedMapConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing ReplicatedMap config.
    
    Specified by:
    
    findReplicatedMapConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    ReplicatedMap config or null when requested ReplicatedMap configuration does not exist
  - getReplicatedMapConfigs
```
public ConcurrentMap<String,ReplicatedMapConfig> getReplicatedMapConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered replicated map configurations.
    
    Specified by:
    
    getReplicatedMapConfigs in interface ConfigurationService
    
    Returns:
    
    registered replicated map configurations
  - findReliableTopicConfig
```
public ReliableTopicConfig findReliableTopicConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Reliable Topic config.
    
    Specified by:
    
    findReliableTopicConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Reliable Topic config or null when requested Reliable Topic configuration does not exist
  - getReliableTopicConfigs
```
public ConcurrentMap<String,ReliableTopicConfig> getReliableTopicConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered reliable topic configurations.
    
    Specified by:
    
    getReliableTopicConfigs in interface ConfigurationService
    
    Returns:
    
    registered reliable topic configurations
  - findCacheSimpleConfig
```
public CacheSimpleConfig findCacheSimpleConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing Cache config.
    
    Specified by:
    
    findCacheSimpleConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    Cache config or null when requested Cache configuration does not exist
  - getCacheSimpleConfigs
```
public Map<String,CacheSimpleConfig> getCacheSimpleConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered cache configurations.
    
    Specified by:
    
    getCacheSimpleConfigs in interface ConfigurationService
    
    Returns:
    
    registered cache configurations
  - findCacheEventJournalConfig
```
public EventJournalConfig findCacheEventJournalConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing CacheEventJournal config.
    
    Specified by:
    
    findCacheEventJournalConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    CacheEventJournal config or null when requested CacheEventJournal configuration does not exist
  - getCacheEventJournalConfigs
```
public Map<String,EventJournalConfig> getCacheEventJournalConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered CacheEventJournal configurations.
    
    Specified by:
    
    getCacheEventJournalConfigs in interface ConfigurationService
    
    Returns:
    
    registered CacheEventJournal configurations
  - findMapEventJournalConfig
```
public EventJournalConfig findMapEventJournalConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds existing MapEventJournal config.
    
    Specified by:
    
    findMapEventJournalConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    MapEventJournal config or null when requested MapEventJournal configuration does not exist
  - getMapEventJournalConfigs
```
public Map<String,EventJournalConfig> getMapEventJournalConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered MapEventJournal configurations.
    
    Specified by:
    
    getMapEventJournalConfigs in interface ConfigurationService
    
    Returns:
    
    registered MapEventJournal configurations
  - findMapMerkleTreeConfig
```
public MerkleTreeConfig findMapMerkleTreeConfig(String name)
```
    Description copied from interface: ConfigurationService
    
    Finds an existing map MerkleTreeConfig.
    
    Specified by:
    
    findMapMerkleTreeConfig in interface ConfigurationService
    
    Parameters:
    
    name - name of the config
    
    Returns:
    
    map MerkleTreeConfig or null when the requested configuration does not exist
  - getMapMerkleTreeConfigs
```
public Map<String,MerkleTreeConfig> getMapMerkleTreeConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns a map of all registered IMap MerkleTreeConfigs.
    
    Specified by:
    
    getMapMerkleTreeConfigs in interface ConfigurationService
    
    Returns:
    
    a map of registered IMap MerkleTreeConfigs
  - findFlakeIdGeneratorConfig
```
public FlakeIdGeneratorConfig findFlakeIdGeneratorConfig(String baseName)
```
    Description copied from interface: ConfigurationService
    
    Finds existing FlakeIdGeneratorConfig config.
    
    Specified by:
    
    findFlakeIdGeneratorConfig in interface ConfigurationService
    
    Parameters:
    
    baseName - name of the config
    
    Returns:
    
    FlakeIdGenerator config or null when requested FlakeIdGenerator configuration does not exist
  - getFlakeIdGeneratorConfigs
```
public Map<String,FlakeIdGeneratorConfig> getFlakeIdGeneratorConfigs()
```
    Description copied from interface: ConfigurationService
    
    Returns all registered FlakeIdGenerator configurations.
    
    Specified by:
    
    getFlakeIdGeneratorConfigs in interface ConfigurationService
    
    Returns:
    
    registered FlakeIdGenerator configurations
  - prepareMergeRunnable
```
public Runnable prepareMergeRunnable()
```
    Description copied from interface: SplitBrainHandlerService
    
    When the two separate clusters merge (resolve a split-brain), this method is called to return a Runnable, that will merge the clusters.
    
    Specified by:
    
    prepareMergeRunnable in interface SplitBrainHandlerService
    
    Returns:
    
    a Runnable that will merge the clusters

Class ClusterWideConfigurationService

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

SERVICE_NAME

CONFIG_PUBLISH_MAX_ATTEMPT_COUNT

Constructor Detail

ClusterWideConfigurationService

Method Detail

getPreJoinOperation

onClusterVersionChange

init

reset

shutdown

broadcastConfig

broadcastConfigAsync

registerConfigLocally

findMultiMapConfig

getMultiMapConfigs

findMapConfig

getMapConfigs

findTopicConfig

getTopicConfigs

findCardinalityEstimatorConfig

getCardinalityEstimatorConfigs

findPNCounterConfig

getPNCounterConfigs

findExecutorConfig

getExecutorConfigs

findScheduledExecutorConfig

getScheduledExecutorConfigs

findDurableExecutorConfig

getDurableExecutorConfigs

findSemaphoreConfig

getSemaphoreConfigs

findRingbufferConfig

getRingbufferConfigs

findAtomicLongConfig

getAtomicLongConfigs

findAtomicReferenceConfig

findCountDownLatchConfig

getAtomicReferenceConfigs

getCountDownLatchConfigs

findLockConfig

getLockConfigs

findListConfig

getListConfigs

findQueueConfig

getQueueConfigs

findSetConfig

getSetConfigs

findReplicatedMapConfig

getReplicatedMapConfigs

findReliableTopicConfig

getReliableTopicConfigs

findCacheSimpleConfig

getCacheSimpleConfigs

findCacheEventJournalConfig

getCacheEventJournalConfigs

findMapEventJournalConfig

getMapEventJournalConfigs

findMapMerkleTreeConfig

getMapMerkleTreeConfigs

findFlakeIdGeneratorConfig

getFlakeIdGeneratorConfigs

prepareMergeRunnable