Package | Description |
---|---|
desmoj.extensions.crossbar |
A higher-level construct to facilitate indirect process synchronization based on exchanging massages.
|
Modifier and Type | Method and Description |
---|---|
MessageChannel<T> |
MessageCrossbar.createMessageChannel(java.lang.String channelName)
Creates a new MessageChannel with is automatically associated with the
MessageCrossbar.
|
<ST extends T> |
MessageCrossbar.createMessageChannel(java.lang.String channelName,
java.lang.Class<ST> desiredGenericType,
boolean showInReport,
boolean showInTrace)
Creates a new MessageChannel with is automatically associated with the
MessageCrossbar.
|
MessageChannel<T> |
MessageCrossbar.getMessageChannel(java.lang.String channelName)
Returns the
MessageChannel identified by the given name. |
Modifier and Type | Method and Description |
---|---|
void |
MessageCrossbar.sendMessage(CrossbarMessage message,
java.util.List<MessageChannel<T>> channelsToSendTo)
Sends the given
CrossbarMessage to the specified message
channels, thereby activating all processes that are waiting on these
channel. |
CrossbarMessage |
MessageCrossbar.waitForMessage(java.util.List<MessageChannel<T>> channelsToWaitOn)
Wait for a
CrossbarMessage on the specified message channels,
thereby passivating the current process. |
CrossbarMessage |
MessageCrossbar.waitForMessage(java.util.List<MessageChannel<T>> channelsToWaitOn,
TimeInstant waitUntil)
Wait for a
CrossbarMessage on the specified message channels,
thereby passivating the current process. |
CrossbarMessage |
MessageCrossbar.waitForMessage(java.util.List<MessageChannel<T>> channelsToWaitOn,
TimeSpan maxWaitTime)
Wait for a
CrossbarMessage on the specified message channels,
thereby passivating the current process. |