| Package | Description |
|---|---|
| ds.funnel.data.msglink | |
| ds.funnel.data.msglink.protocol3 | |
| ds.funnel.node | |
| ds.funnel.overlay | |
| ds.funnel.peer | |
| ds.funnel.samples | |
| ds.synapse.peer |
| Modifier and Type | Method and Description |
|---|---|
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.
|
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.
|
| Modifier and Type | Method and Description |
|---|---|
MessageLink |
MessageLinkFactory.openLink(NodeDetails inDetails)
Open a new connection to the given node.
|
MessageProtocol |
MessageProtocol.openVirtual() |
MessageLink |
MessageLinkFactory.openVirtualLink(NodeDetails inDetails)
Open a new virtual connection using the stored group protocol.
|
void |
MessageProtocol.sendMessage(MessageEvent inMessage) |
<M extends MessageEvent> |
MessageProtocol.sendMessage(MessageEvent sendMsg,
java.lang.Class<M> respType) |
void |
MessageProtocol.setEventHandler(EventHandler<? super MessageEvent> inHandler) |
void |
MessageProtocol.setEventProcessor(EventProcessor<MessageEvent> inProcess) |
| Modifier and Type | Method and Description |
|---|---|
void |
NodeDetailsBase.onOpenComponentLink(MsgLinkAssociate evtMsg) |
MessageLink |
NodeDetailsBase.openLink() |
MessageLink |
NodeDetails.openLink() |
MessageLink |
NodeDetailsBase.openVirtualLink() |
MessageLink |
NodeDetails.openVirtualLink() |
| Modifier and Type | Class and Description |
|---|---|
class |
OverlayException |
| Modifier and Type | Method and Description |
|---|---|
MessageLink |
OverlayManagerImpl.openBackingLink(NodeDetails inNode) |
void |
OverlayLinkImpl.sendMessage(MessageEvent inMessage) |
<M extends MessageEvent> |
OverlayLinkImpl.sendMessage(MessageEvent inMessage,
java.lang.Class<M> respType) |
void |
OverlayLinkImpl.sendMessage(TopicEvent inMessage,
java.util.List<OverlayPath> inDests) |
void |
OverlayLink.sendMessage(TopicEvent inMessage,
java.util.List<OverlayPath> inDests)
Send a message to the connected destination.
|
void |
OverlayLinkImpl.setEventHandler(EventHandler<? super MessageEvent> inHandler) |
void |
OverlayLinkImpl.setEventProcessor(EventProcessor<MessageEvent> inProcess) |
| Modifier and Type | Method and Description |
|---|---|
void |
PeerGroup.forwardEvent(TopicEvent inEvent)
Send a topic event to other nodes connected to this overlay.
|
void |
PeerGroupImpl.forwardEvent(TopicEvent inEvent) |
ReplyStatus |
PeerGroupImpl.forwardEventTracked(TopicEvent inEvent) |
void |
PeerGroupAdvert.onNeighborAdvert(MsgTopicNeighbor inEvent) |
void |
RouterNode.onPing(MsgLinkTestping inMsg) |
void |
PeerGroupAdvert.onTopicAdvert(MsgTopicAdvert inEvent) |
| Modifier and Type | Method and Description |
|---|---|
void |
TimerTestNode.onPing(MsgLinkTestping inMsg) |
void |
UDPTestNode.onPing(MsgLinkTestping inMsg) |
| Constructor and Description |
|---|
DHTConnection(SynapseDHTDetails inDetails)
Deprecated.
|
DHTLookup(DHTConnection inPeerConnect) |