T
- the type of reply that is expected as a result for this requestpublic abstract class BucketRequestMessage<T extends BucketReplyMessage> extends Message
Modifier and Type | Field and Description |
---|---|
protected int |
bucketID
ID of a remote bucket on which to process the request
|
messageID, navigationPath
Modifier | Constructor and Description |
---|---|
protected |
BucketRequestMessage(int bucketID)
Creates a new instance of BucketRequestMessage.
|
Modifier and Type | Method and Description |
---|---|
abstract T |
execute(BucketDispatcher bucketDispatcher)
Executes this request on the specified bucket dispatcher.
|
abstract java.lang.Class<T> |
replyMessageClass()
Returns the class of the reply message that is received as a response to this request message.
|
clone, deregisterOperStats, equals, getDestination, getMessageID, getNavigationPathLength, getOriginalSender, getPathElements, getSender, getSenderList, hashCode, registerBoundStat, registerBoundStat, setNavigationPathStatistics, toString
protected final int bucketID
protected BucketRequestMessage(int bucketID)
bucketID
- the ID of a remote bucket on which to process the requestpublic abstract T execute(BucketDispatcher bucketDispatcher) throws java.lang.RuntimeException, BucketStorageException
bucketDispatcher
- the dispatcher that can provide the bucket of for the requestjava.lang.RuntimeException
- if there was an error processing this requestBucketStorageException
- if there was an error processing this requestpublic abstract java.lang.Class<T> replyMessageClass()