public class BucketProcessQueryRequestMessage extends BucketRequestMessage<BucketProcessQueryReplyMessage>
NetworkBucketDispatcher
,
Serialized FormbucketID
messageID, navigationPath
Constructor and Description |
---|
BucketProcessQueryRequestMessage(int bucketID,
QueryOperation<?> query)
Creates a new instance of BucketProcessQueryRequestMessage.
|
Modifier and Type | Method and Description |
---|---|
BucketProcessQueryReplyMessage |
execute(BucketDispatcher bucketDispatcher)
Executes this request on the specified bucket dispatcher.
|
java.lang.Class<BucketProcessQueryReplyMessage> |
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
public BucketProcessQueryRequestMessage(int bucketID, QueryOperation<?> query)
bucketID
- the ID of a remote bucket on which to process the requestquery
- the query operation to process on a remote bucketpublic BucketProcessQueryReplyMessage execute(BucketDispatcher bucketDispatcher) throws java.lang.RuntimeException, BucketStorageException
BucketRequestMessage
execute
in class BucketRequestMessage<BucketProcessQueryReplyMessage>
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 java.lang.Class<BucketProcessQueryReplyMessage> replyMessageClass()
BucketRequestMessage
replyMessageClass
in class BucketRequestMessage<BucketProcessQueryReplyMessage>