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

java.lang.Object
  org.shoal.ha.cache.impl.command.Command<K,V>
      org.shoal.ha.cache.impl.command.BroadcastLoadRequestCommand<K,V>

public class BroadcastLoadRequestCommand<K,V>
extends Command<K,V>

Author:

Mahesh Kannan

Field Summary

Fields inherited from class org.shoal.ha.cache.impl.command.Command

dsc

Constructor Summary

BroadcastLoadRequestCommand()

BroadcastLoadRequestCommand(K key)

Method Summary

protected BroadcastLoadRequestCommand<K,V>	createNewInstance()
void	execute(java.lang.String initiator)
DataStoreEntry<K,V>	getResult(long waitFor, java.util.concurrent.TimeUnit unit)
void	readCommandPayload(ReplicationInputStream ris)
protected void	writeCommandPayload(ReplicationOutputStream ros)

Methods inherited from class org.shoal.ha.cache.impl.command.Command

getCommandManager, getDataStoreContext, getOpcode, getTargetName, initialize, prepareToExecute, prepareTransmit, setTargetName, write

Methods inherited from class java.lang.Object

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

Constructor Detail

BroadcastLoadRequestCommand

public BroadcastLoadRequestCommand()

BroadcastLoadRequestCommand

public BroadcastLoadRequestCommand(K key)

Method Detail

createNewInstance

protected BroadcastLoadRequestCommand<K,V> createNewInstance()

Specified by:

createNewInstance in class Command<K,V>

writeCommandPayload

protected void writeCommandPayload(ReplicationOutputStream ros)
                            throws java.io.IOException

Specified by:

writeCommandPayload in class Command<K,V>

Throws:

java.io.IOException

readCommandPayload

public void readCommandPayload(ReplicationInputStream ris)
                        throws java.io.IOException

Specified by:

readCommandPayload in class Command<K,V>

Throws:

java.io.IOException

execute

public void execute(java.lang.String initiator)

Specified by:

execute in class Command<K,V>

getResult

public DataStoreEntry<K,V> getResult(long waitFor,
                                     java.util.concurrent.TimeUnit unit)
                              throws DataStoreException

Throws:

DataStoreException