me.prettyprint.cassandra.connection
Class CassandraHostRetryService
java.lang.Object
me.prettyprint.cassandra.connection.BackgroundCassandraHostService
me.prettyprint.cassandra.connection.CassandraHostRetryService
public class CassandraHostRetryService
- extends BackgroundCassandraHostService
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEF_QUEUE_SIZE
public static final int DEF_QUEUE_SIZE
- See Also:
- Constant Field Values
DEF_RETRY_DELAY
public static final int DEF_RETRY_DELAY
- See Also:
- Constant Field Values
CassandraHostRetryService
public CassandraHostRetryService(HConnectionManager connectionManager,
CassandraHostConfigurator cassandraHostConfigurator)
add
public void add(CassandraHost cassandraHost)
remove
public boolean remove(CassandraHost cassandraHost)
contains
public boolean contains(CassandraHost cassandraHost)
getDownedHosts
public Set<CassandraHost> getDownedHosts()
applyRetryDelay
public void applyRetryDelay()
flushQueue
public void flushQueue()
Copyright © 2011. All Rights Reserved.