|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.infinispan.remoting.ReplicationQueueImpl
public class ReplicationQueueImpl
A default implementation of the ReplicationQueue interface.
Constructor Summary | |
---|---|
ReplicationQueueImpl()
|
Method Summary | |
---|---|
void |
add(ReplicableCommand job)
Adds a new command to the replication queue. |
protected List<ReplicableCommand> |
drainReplQueue()
|
int |
flush()
Flushes existing jobs in the replication queue, and returns the number of jobs flushed. |
int |
getElementsCount()
|
void |
injectDependencies(ScheduledExecutorService executor,
RpcManager rpcManager,
Configuration configuration,
CommandsFactory commandsFactory)
|
boolean |
isEnabled()
|
void |
reset()
Resets the replication queue, typically used when a cache is restarted. |
void |
start()
Starts the asynchronous flush queue. |
void |
stop()
Stops the asynchronous flush queue. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ReplicationQueueImpl()
Method Detail |
---|
public boolean isEnabled()
isEnabled
in interface ReplicationQueue
public void injectDependencies(ScheduledExecutorService executor, RpcManager rpcManager, Configuration configuration, CommandsFactory commandsFactory)
public void start()
start
in interface Lifecycle
public void stop()
stop
in interface Lifecycle
public void add(ReplicableCommand job)
ReplicationQueue
add
in interface ReplicationQueue
job
- command to add to the queuepublic int flush()
ReplicationQueue
flush
in interface ReplicationQueue
protected List<ReplicableCommand> drainReplQueue()
public int getElementsCount()
getElementsCount
in interface ReplicationQueue
public void reset()
ReplicationQueue
reset
in interface ReplicationQueue
|
--> | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |