Package net.rubyeye.xmemcached.aws
Class ConfigurationPoller
- java.lang.Object
-
- net.rubyeye.xmemcached.aws.ConfigurationPoller
-
- All Implemented Interfaces:
java.lang.Runnable
public class ConfigurationPoller extends java.lang.Object implements java.lang.RunnableAWS ElastiCache configuration poller
-
-
Field Summary
Fields Modifier and Type Field Description private AWSElasticCacheClientclientprivate ClusterConfigurationclusterConfigrationprivate static org.slf4j.Loggerlogprivate java.util.Map<java.lang.String,java.lang.Integer>ordersMapprivate longpollIntervalMillsprivate java.util.concurrent.ScheduledExecutorServicescheduledExecutorServiceprivate java.util.concurrent.atomic.AtomicIntegerserverOrderCounter
-
Constructor Summary
Constructors Constructor Description ConfigurationPoller(AWSElasticCacheClient client, long pollIntervalMills)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intgetCacheNodeOrder(CacheNode node)ClusterConfigurationgetClusterConfiguration()Return current ClusterConfigration.voidremoveCacheNodeOrder(CacheNode node)voidrun()voidstart()voidstop()
-
-
-
Field Detail
-
serverOrderCounter
private final java.util.concurrent.atomic.AtomicInteger serverOrderCounter
-
ordersMap
private java.util.Map<java.lang.String,java.lang.Integer> ordersMap
-
log
private static final org.slf4j.Logger log
-
client
private final AWSElasticCacheClient client
-
pollIntervalMills
private final long pollIntervalMills
-
scheduledExecutorService
private java.util.concurrent.ScheduledExecutorService scheduledExecutorService
-
clusterConfigration
private volatile ClusterConfiguration clusterConfigration
-
-
Constructor Detail
-
ConfigurationPoller
public ConfigurationPoller(AWSElasticCacheClient client, long pollIntervalMills)
-
-
Method Detail
-
getClusterConfiguration
public ClusterConfiguration getClusterConfiguration()
Return current ClusterConfigration.- Returns:
-
getCacheNodeOrder
public int getCacheNodeOrder(CacheNode node)
-
removeCacheNodeOrder
public void removeCacheNodeOrder(CacheNode node)
-
start
public void start()
-
stop
public void stop()
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable
-
-