Package | Description |
---|---|
messif.algorithms |
Search algorithms base classes.
|
messif.network |
Message-based networking support.
|
Modifier and Type | Method and Description |
---|---|
protected ReplyReceiver<? extends DistAlgReplyMessage> |
DistributedAlgorithm.navigationBeforeProcessing(AbstractOperation operation,
DistAlgRequestMessage request,
java.util.Collection<NetworkNode> nodes)
Processes navigation before the local processing.
|
protected ReplyReceiver<? extends DistAlgReplyMessage> |
DistributedAlgorithm.navigationBeforeProcessing(AbstractOperation operation,
DistAlgRequestMessage request,
NetworkNode node)
Processes navigation before the local processing.
|
Modifier and Type | Method and Description |
---|---|
protected int |
DistributedAlgorithm.navigationAfterProcessing(AbstractOperation operation,
DistAlgRequestMessage request,
ReplyReceiver<? extends DistAlgReplyMessage> receiver)
Processes navigation after the local processing.
|
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.
|
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 |
---|---|
static <E extends ReplyMessage> |
ReplyReceiver.cast(ReplyReceiver<?> receiver,
java.lang.Class<? extends E> replyMessageClass)
Cast a given
ReplyReceiver to a correct generic type. |