Package | Description |
---|---|
messif.algorithms |
Search algorithms base classes.
|
messif.netbucket |
Networked objects and buckets.
|
messif.netcreator |
Utilization of resources using on-demand requirements of distributed structures.
|
messif.network |
Message-based networking support.
|
Modifier and Type | Class and Description |
---|---|
class |
DistAlgReplyMessage
Reply message for the
DistributedAlgorithm . |
Modifier and Type | Method and Description |
---|---|
void |
DistributedAlgorithm.mergeStatisticsFromReplies(OperationStatistics targetStatistics,
java.util.Collection<? extends ReplyMessage> replyMessages)
Update supplied statistics with partial statistics from reply messages
|
void |
DistributedAlgorithm.mergeStatisticsFromReplies(OperationStatistics targetStatistics,
java.util.Collection<? extends ReplyMessage> replyMessages,
OperationStatistics localStats)
Update supplied statistics with partial statistics from reply messages
|
Modifier and Type | Class and Description |
---|---|
class |
BucketCreateReplyMessage
Message for returning results of a remote bucket creation.
|
class |
BucketExceptionReplyMessage
Message for returning exception thrown while manipulating objects on a remote bucket.
|
class |
BucketManipulationReplyMessage |
class |
BucketProcessQueryReplyMessage
Message for returning results of a query processed on a remote bucket.
|
class |
BucketRemoveReplyMessage
Message for returning results of a remote bucket removal.
|
class |
BucketReplyMessage
Generic message for returning results of an object manipulation on a remote bucket.
|
class |
BucketSplitReplyMessage
Message for returning results of a remote bucket split.
|
Modifier and Type | Class and Description |
---|---|
class |
MessageActivateResponse |
Modifier and Type | Class and Description |
---|---|
class |
ReplyReceiver<TReplyMessage extends ReplyMessage>
A
Receiver for receiving reply messages. |
Modifier and Type | Method and Description |
---|---|
static <E extends ReplyMessage> |
ReplyReceiver.cast(ReplyReceiver<?> receiver,
java.lang.Class<? extends E> replyMessageClass)
Cast a given
ReplyReceiver to a correct generic type. |
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
java.lang.Class<E> replyMessageClass,
boolean removeOnAccept,
java.util.Collection<NetworkNode> nodes)
Send the message to multiple network nodes and wait for the replies.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
java.lang.Class<E> replyMessageClass,
boolean removeOnAccept,
NetworkNode node)
Send the message to the specified network node and wait for the replies.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
java.lang.Class<E> replyMessageClass,
java.util.Collection<NetworkNode> nodes)
Send the message to multiple network nodes and wait for the replies.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
java.lang.Class<E> replyMessageClass,
NetworkNode node)
Send the message to the specified network node and wait for the replies.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitSingleReply(Message msg,
java.lang.Class<E> replyMessageClass,
NetworkNode node)
Send the message to a network node and wait for a single reply.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitSingleReply(Message msg,
java.lang.Class<E> replyMessageClass,
NetworkNode node,
long timeout)
Send the message to a network node and wait for a single reply.
|
Modifier and Type | Method and Description |
---|---|
ReplyReceiver<? extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
java.util.Collection<NetworkNode> nodes)
Send the message to multiple network nodes and wait for the replies.
|
ReplyReceiver<? extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
NetworkNode node)
Send the message to the specified network node and wait for the replies.
|
Modifier and Type | Method and Description |
---|---|
NetworkNode |
MessageDispatcher.replyMessage(ReplyMessage msg)
Send the reply message, i.e. send the message to its original sender node.
|