| Package | Description |
|---|---|
| ds.funnel.overlay | |
| ds.funnel.peer | |
| ds.funnel.peer.event | |
| ds.funnel.topic |
| Modifier and Type | Method and Description |
|---|---|
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.
|
| 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 |
PeerGroupUtilizer.onEvent(TopicEvent inEvent)
Called by the group to pass incoming events to the utilizer.
|
void |
PeerGroup.processEvent(TopicEvent inEvent)
Process a topic event.
|
void |
PeerGroupImpl.processEvent(TopicEvent inEvent) |
void |
PeerGroupImpl.processQueued(TopicEvent inEvent) |
| 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 |
| Modifier and Type | Method and Description |
|---|---|
void |
TopicPublisherImpl.onEvent(TopicEvent inEvent) |
void |
TopicSubscriptionImpl.onEvent(TopicEvent inEvent) |