org.shoal.ha.cache.impl.command
Class CommandManager<K,V>

java.lang.Object
  org.shoal.ha.cache.impl.util.MessageReceiver
      org.shoal.ha.cache.impl.command.CommandManager<K,V>

All Implemented Interfaces:

CallBack

public class CommandManager<K,V>
extends MessageReceiver

Author:

Mahesh Kannan

Constructor Summary

CommandManager(DataStoreContext<K,V> dsc)

Method Summary

Command<K,V>	createNewInstance(byte opcode)
void	execute(Command<K,V> cmd)
void	executeCommand(Command<K,V> cmd, boolean forward, java.lang.String initiator)
protected void	handleMessage(java.lang.String sourceMemberName, java.lang.String token, byte[] messageData)
void	registerCommand(Command<K,V> command)
void	registerExecutionInterceptor(AbstractCommandInterceptor<K,V> interceptor)

Methods inherited from class org.shoal.ha.cache.impl.util.MessageReceiver

processNotification

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandManager

public CommandManager(DataStoreContext<K,V> dsc)

Method Detail

registerCommand

public void registerCommand(Command<K,V> command)

registerExecutionInterceptor

public void registerExecutionInterceptor(AbstractCommandInterceptor<K,V> interceptor)

execute

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

Throws:

DataStoreException

executeCommand

public final void executeCommand(Command<K,V> cmd,
                                 boolean forward,
                                 java.lang.String initiator)
                          throws DataStoreException

Throws:

DataStoreException

createNewInstance

public Command<K,V> createNewInstance(byte opcode)
                               throws java.io.IOException

Throws:

java.io.IOException

handleMessage

protected void handleMessage(java.lang.String sourceMemberName,
                             java.lang.String token,
                             byte[] messageData)

Specified by:

handleMessage in class MessageReceiver