Package | Description |
---|---|
dcps | |
ethernet | |
test |
Modifier and Type | Method and Description |
---|---|
boolean |
Topic.callListeners(Message m) |
void |
TopicsScope.onMessage(Message m) |
void |
TopicListener.onMessage(Topic t,
Message m) |
Modifier and Type | Class and Description |
---|---|
class |
MessagePlain
This Message extension handles messages with any pre-defined structure.
|
class |
MessageProxyWrapper
This Message extension handles messages wrapping other messages.
|
class |
MessageSyncTime
This Message extension handles messages for time synchronization.
|
class |
MessageTopicData
This Message extension handles messages for data managed
inside the DCPS service ("TopiscScope" MultiPeerListener).
|
class |
MessageTopicLinks
This Message extension handles messages for commands to
configure the DCPS service ("TopiscScope" MultiPeerListener).
|
Modifier and Type | Field and Description |
---|---|
(package private) Message |
MessageProxyWrapper.originalMessage |
Modifier and Type | Field and Description |
---|---|
private java.util.ArrayList<Message> |
QueueMessage.queue |
Modifier and Type | Method and Description |
---|---|
static Message |
Message.fromInputStream(java.io.InputStream is)
Static method to create a new specific "MessageXXX" according the message
type contained in the prologue.
|
Message |
MessageProxyWrapper.getOriginalMessage()
OriginalMessage getter.
|
Message |
QueueMessage.pull()
Gets a message from the head of the queue following the FIFO policy.
|
private Message |
Destination.receive()
Private reading routine.
|
Modifier and Type | Method and Description |
---|---|
void |
SyncClock.onMessage(Message m)
MultiPeerListener callback.
|
void |
ProxyManager.onMessage(Message m) |
void |
MultiPeerListener.onMessage(Message m) |
void |
MultiPeer.OnMessage(Message m)
Callback generated by "Destinations" when a message arrives.
|
private void |
MultiPeer.propagateNewMessage(Message m)
Propagate the new message to listeners (callback)
|
void |
QueueMessage.push(Message m)
Adds a message to the queue
|
Destination[] |
MultiPeer.send(Destination[] destArray,
Message m)
Send a Message to a subset of peers in the party.
|
void |
MultiPeer.send(Message m)
Send a Message to ALL peers in the party.
|
boolean |
Destination.send(Message m)
Send a message to the peer (header and payload buffers of the Message passed)
The information about message length and type is encoded in a prologue handled
at this level (Destination.send() and Destination.receive()).
|
private Destination[] |
MultiPeer.sendByProxyPeersSet(Message m,
PeersSet pSet)
Auxiliary method to send a message to an arbitrary "PeersSet"
using the "ProxyManager" service.
|
private Destination[] |
MultiPeer.sendDirectPeersSet(Message m,
PeersSet pSet)
Auxiliary method to send a message to an arbitrary "PeersSet" directly.
|
Constructor and Description |
---|
MessageProxyWrapper(IPPort srcIPP,
Message msg,
int[] destPortsLst)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
MultiPeerTest.onMessage(Message m) |
void |
TopicTest3.onMessage(Topic t,
Message m) |
void |
TopicTest2.onMessage(Topic t,
Message m) |
void |
TopicTest.onMessage(Topic t,
Message m) |