public class BucketSplitRequestMessage extends BucketRequestMessage<BucketSplitReplyMessage>
NetworkBucketDispatcher
,
Serialized FormbucketID
messageID, navigationPath
Constructor and Description |
---|
BucketSplitRequestMessage(int bucketID,
SplitPolicy splitPolicy,
int whoStays)
Creates a new instance of BucketSplitRequestMessage.
|
Modifier and Type | Method and Description |
---|---|
BucketSplitReplyMessage |
execute(BucketDispatcher bucketDispatcher)
Executes this request on the specified bucket dispatcher.
|
SplitPolicy |
getSplitPolicy() |
java.lang.Class<BucketSplitReplyMessage> |
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 BucketSplitRequestMessage(int bucketID, SplitPolicy splitPolicy, int whoStays)
bucketID
- the ID of a remote bucket to be splitsplitPolicy
- split policy for given bucketwhoStays
- Identification of a partition whose objects stay in the split bucketpublic SplitPolicy getSplitPolicy()
public BucketSplitReplyMessage execute(BucketDispatcher bucketDispatcher) throws java.lang.RuntimeException, BucketStorageException
BucketRequestMessage
execute
in class BucketRequestMessage<BucketSplitReplyMessage>
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<BucketSplitReplyMessage> replyMessageClass()
BucketRequestMessage
replyMessageClass
in class BucketRequestMessage<BucketSplitReplyMessage>