org.infinispan.remoting
Class ReplicationQueue

java.lang.Object
  org.infinispan.remoting.ReplicationQueue

public class ReplicationQueue
extends Object

Periodically (or when certain size is exceeded) takes elements and replicates them.

Since:

4.0

Author:

Bela Ban, Mircea.Markus@jboss.com

Constructor Summary

ReplicationQueue()

Method Summary

void	add(ReplicableCommand job) Adds a new method call.
void	flush() Flushes existing method calls.
int	getElementsCount()
boolean	isEnabled()
void	reset()
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

ReplicationQueue

public ReplicationQueue()

Method Detail

isEnabled

public boolean isEnabled()

start

public void start()

Starts the asynchronous flush queue.

stop

public void stop()

Stops the asynchronous flush queue.

add

public void add(ReplicableCommand job)

Adds a new method call.

flush

public void flush()

Flushes existing method calls.

getElementsCount

public int getElementsCount()

reset

public void reset()