Inheritance diagram for NetworkMessage:
Public Member Functions | |
this (ICluster cluster, char[] channel, IEventListener listener=null) | |
void | cancel () |
void | put (IMessage message) |
Private Member Functions | |
this (ICluster cluster, char[] channel) | |
IConsumer | createConsumer (IEventListener listener) |
void | put (IPayload payload) |
IPayload | get () |
Static Private Member Functions | |
this () | |
Private Attributes | |
IChannel | reply |
IConsumer | consumer |
|
Construct a NetworkMessage gateway on the provided QOS cluster for the specified channel. Each subsequent queue operation will take place over the given channel. You can listen for cluster replies by providing an optional IEventListener. Outgoing messages will be tagged appropriately such that a consumer can respond using IEvent.reply(). Reimplemented in NetworkTask. Definition at line 127 of file NetworkQueue.d. |
|
Cancel the listener. No more events will be dispatched to the reply IEventListener. Reimplemented from IConsumer. Definition at line 145 of file NetworkQueue.d. References IConsumer::cancel(). |
|
Add an IMessage entry to the corresponding queue. This will throw a ClusterFullException if there is no space left in the clustered queue. Definition at line 159 of file NetworkQueue.d. References IChannel::getName(), and IMessage::setReply(). Referenced by testClusterMessage(). |
|
Construct a NetworkQueue gateway on the provided QOS cluster for the specified channel. Each subsequent queue operation will take place over the given channel. Reimplemented from Client. Definition at line 59 of file NetworkQueue.d. |
|
Definition at line 63 of file Client.d. References Client::EmptyMessage. |
|
Create a listener for this channel. Listeners are invoked when new content is placed into a corresponding queue. Definition at line 71 of file NetworkQueue.d. References ICluster::createConsumer(). Referenced by testClusterMessage(), and testClusterQueue(). |
|
Add an IPayload entry to the corresponding queue. This will throw a ClusterFullException if there is no space left in the clustered queue. Definition at line 84 of file NetworkQueue.d. References ICluster::putQueue(). Referenced by testClusterQueue(). |
|
Query the cluster for queued entries on our corresponding channel. Returns, and removes, a matching entry from the cluster. This is the synchronous (polling) approach; you should use createConsumer() instead for asynchronous style notification instead. Definition at line 99 of file NetworkQueue.d. References ICluster::getQueue(). |
|
Definition at line 112 of file NetworkQueue.d. |
|
Definition at line 113 of file NetworkQueue.d. |