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

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

All Implemented Interfaces:

java.lang.Runnable

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

Author:

Mahesh Kannan

Constructor Summary

ReplicationCommandTransmitter()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationCommandTransmitter

public ReplicationCommandTransmitter()

Method Detail

initialize

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

addCommand

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

run

public void run()

Specified by:

run in interface java.lang.Runnable