org.shoal.ha.cache.impl.interceptor
Class ReplicationCommandTransmitterWithList<K,V>

java.lang.Object
  org.shoal.ha.cache.impl.interceptor.ReplicationCommandTransmitterWithList<K,V>

All Implemented Interfaces:

java.lang.Runnable, CommandCollector<K,V>

public class ReplicationCommandTransmitterWithList<K,V>
extends java.lang.Object
implements java.lang.Runnable, CommandCollector<K,V>

Author:

Mahesh Kannan

Constructor Summary

ReplicationCommandTransmitterWithList()

Method Summary

void	addCommand(Command<K,V> cmd)
void	close()
void	initialize(java.lang.String targetName, DataStoreContext<K,V> rsInfo)
void	removeCommand(Command<K,V> cmd)
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReplicationCommandTransmitterWithList

public ReplicationCommandTransmitterWithList()

Method Detail

initialize

public void initialize(java.lang.String targetName,
                       DataStoreContext<K,V> rsInfo)

Specified by:

initialize in interface CommandCollector<K,V>

close

public void close()

Specified by:

close in interface CommandCollector<K,V>

addCommand

public void addCommand(Command<K,V> cmd)
                throws DataStoreException

Specified by:

addCommand in interface CommandCollector<K,V>

Throws:

DataStoreException

removeCommand

public void removeCommand(Command<K,V> cmd)
                   throws DataStoreException

Specified by:

removeCommand in interface CommandCollector<K,V>

Throws:

DataStoreException

run

public void run()

Specified by:

run in interface java.lang.Runnable