org.shoal.adapter.store.commands
Class StoreableBroadcastLoadRequestCommand<K,V extends org.glassfish.ha.store.api.Storeable>

java.lang.Object
  org.shoal.ha.cache.impl.command.Command<K,V>
      org.shoal.adapter.store.commands.StoreableBroadcastLoadRequestCommand<K,V>

public class StoreableBroadcastLoadRequestCommand<K,V extends org.glassfish.ha.store.api.Storeable>
extends Command<K,V>

Author:

Mahesh Kannan

Field Summary

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

dsc

Constructor Summary

StoreableBroadcastLoadRequestCommand()

StoreableBroadcastLoadRequestCommand(K key, java.lang.Long version)

Method Summary

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

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

getCommandManager, getDataStoreContext, getKeyMappingInfo, getName, getOpcode, getTargetName, initialize, prepareToExecute, prepareTransmit, selectReplicaInstance, setTargetName, write

Methods inherited from class java.lang.Object

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

Constructor Detail

StoreableBroadcastLoadRequestCommand

public StoreableBroadcastLoadRequestCommand()

StoreableBroadcastLoadRequestCommand

public StoreableBroadcastLoadRequestCommand(K key,
                                            java.lang.Long version)

Method Detail

createNewInstance

protected StoreableBroadcastLoadRequestCommand<K,V> createNewInstance()

Specified by:

createNewInstance in class Command<K,V extends org.glassfish.ha.store.api.Storeable>

writeCommandPayload

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

Specified by:

writeCommandPayload in class Command<K,V extends org.glassfish.ha.store.api.Storeable>

Throws:

java.io.IOException

readCommandPayload

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

Specified by:

readCommandPayload in class Command<K,V extends org.glassfish.ha.store.api.Storeable>

Throws:

java.io.IOException

execute

public void execute(java.lang.String initiator)

Specified by:

execute in class Command<K,V extends org.glassfish.ha.store.api.Storeable>

getRespondingInstanceName

public java.lang.String getRespondingInstanceName()

getResult

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

Throws:

DataStoreException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object