| Modifier and Type | Class and Description |
|---|---|
class |
LinkClosedEvent |
| Modifier and Type | Method and Description |
|---|---|
<M extends MessageEvent> |
MessageLink.sendMessage(MessageEvent sendMsg,
java.lang.Class<M> respType)
Send a message to the connected destination, and get a reply task.
|
| Modifier and Type | Method and Description |
|---|---|
static MessageEvent |
MessageType.getMessage(int inCode,
MessageFormat mInput)
Creates the Message corresponding to a given code.
|
| Modifier and Type | Method and Description |
|---|---|
EventHandler<? super MessageEvent> |
MessageLink.getEventHandler()
Deprecated.
|
EventProcessor<MessageEvent> |
MessageLink.getEventProcessor()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
ReplyStatus.isWaitingFor(MessageEvent inMessage) |
void |
ReplyStatus.markSentTo(MessageEvent inMessage,
NodeDetails inDetails) |
void |
MessageLink.sendMessage(MessageEvent sendMsg)
Send a message to the connected destination.
|
<M extends MessageEvent> |
MessageLink.sendMessage(MessageEvent sendMsg,
java.lang.Class<M> respType)
Send a message to the connected destination, and get a reply task.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MessageLink.setEventHandler(EventHandler<? super MessageEvent> inHandler)
Set the event handler that incoming events are passed to.
|
void |
MessageLink.setEventProcessor(EventProcessor<MessageEvent> inProcess)
Set the event handler that incoming events are passed to.
|
| Constructor and Description |
|---|
ReplyStatus(MessageEvent inMessage) |
| Modifier and Type | Class and Description |
|---|---|
class |
MsgLinkAssociate |
class |
MsgLinkAssocResp |
class |
MsgLinkConnect |
class |
MsgLinkMethodCall |
class |
MsgLinkMethodResp |
class |
MsgLinkTestping |
class |
MsgLinkTestpong |
| Modifier and Type | Class and Description |
|---|---|
class |
MessageBase
Message.java: Marshals and unmarshals messages.
|
| Modifier and Type | Method and Description |
|---|---|
<M extends MessageEvent> |
MessageProtocol.sendMessage(MessageEvent sendMsg,
java.lang.Class<M> respType) |
| Modifier and Type | Method and Description |
|---|---|
EventHandler<? super MessageEvent> |
MessageProtocol.getEventHandler()
Deprecated.
|
EventProcessor<MessageEvent> |
MessageProtocol.getEventProcessor()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MessageProtocol.sendMessage(MessageEvent inMessage) |
<M extends MessageEvent> |
MessageProtocol.sendMessage(MessageEvent sendMsg,
java.lang.Class<M> respType) |
| Modifier and Type | Method and Description |
|---|---|
void |
MessageProtocol.setEventHandler(EventHandler<? super MessageEvent> inHandler) |
void |
MessageProtocol.setEventProcessor(EventProcessor<MessageEvent> inProcess) |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
FunnelLogger.isMsgFiltered(MessageEvent inMsg) |
| Modifier and Type | Class and Description |
|---|---|
class |
DispatchReplyTask<M extends MessageEvent> |
| Constructor and Description |
|---|
DispatchReplyTask(int inFlags,
MessageEvent inSentMsg,
java.lang.Class<M> inType) |
| Modifier and Type | Method and Description |
|---|---|
<M extends MessageEvent> |
OverlayLinkImpl.sendMessage(MessageEvent inMessage,
java.lang.Class<M> respType) |
| Modifier and Type | Method and Description |
|---|---|
EventHandler<? super MessageEvent> |
OverlayLinkImpl.getEventHandler()
Deprecated.
|
EventProcessor<MessageEvent> |
OverlayLinkImpl.getEventProcessor()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
OverlayLinkImpl.sendMessage(MessageEvent inMessage) |
<M extends MessageEvent> |
OverlayLinkImpl.sendMessage(MessageEvent inMessage,
java.lang.Class<M> respType) |
| Modifier and Type | Method and Description |
|---|---|
void |
OverlayLinkImpl.setEventHandler(EventHandler<? super MessageEvent> inHandler) |
void |
OverlayLinkImpl.setEventProcessor(EventProcessor<MessageEvent> inProcess) |
| Modifier and Type | Method and Description |
|---|---|
MessageEvent |
ChunkPolicyImpl.mergeMessage(MessageEvent[] inEvents) |
MessageEvent |
ChunkPolicy.mergeMessage(MessageEvent[] inEvents)
Merge one or more message chunks into a single message.
|
MessageEvent[] |
ChunkPolicyImpl.splitMessage(MessageEvent inEvent,
MessageLink inLink) |
MessageEvent[] |
ChunkPolicy.splitMessage(MessageEvent inEvent,
MessageLink inLink)
Splits a message into one or more smaller message chunks.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<OverlayLink,java.util.List<OverlayPath>> |
RoutePolicyImpl.getRoutingLinks(MessageEvent inEvent) |
java.util.Map<OverlayLink,java.util.List<OverlayPath>> |
RoutePolicy.getRoutingLinks(MessageEvent inEvent)
Determine the links that should be used to route a message.
|
MessageEvent |
ChunkPolicyImpl.mergeMessage(MessageEvent[] inEvents) |
MessageEvent |
ChunkPolicy.mergeMessage(MessageEvent[] inEvents)
Merge one or more message chunks into a single message.
|
MessageEvent[] |
ChunkPolicyImpl.splitMessage(MessageEvent inEvent,
MessageLink inLink) |
MessageEvent[] |
ChunkPolicy.splitMessage(MessageEvent inEvent,
MessageLink inLink)
Splits a message into one or more smaller message chunks.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MessageBaseTE |
class |
MsgTopicAdvert |
class |
MsgTopicData |
class |
MsgTopicJoin |
class |
MsgTopicLookup |
class |
MsgTopicNeighbor |
class |
MsgTopicOverlay |
class |
MsgTopicRepair |
| Modifier and Type | Interface and Description |
|---|---|
interface |
TopicCtrlEvent |
interface |
TopicDataEvent |
interface |
TopicEvent |
interface |
TopicLinkEvent |
| Modifier and Type | Class and Description |
|---|---|
class |
MsgFileGet |
class |
MsgFilePut |
| Modifier and Type | Class and Description |
|---|---|
class |
MsgInsertPeer |
class |
MsgInsertResp |
class |
MsgLookupPeer |
class |
MsgPeerInfo |
class |
MsgPredecessorReq |
class |
MsgSuccessorPeers |