Main Page | Class Hierarchy | Alphabetical List | Class List | Directories | File List | Class Members | File Members | Related Pages

NetworkMessage Class Reference

Inheritance diagram for NetworkMessage:

NetworkQueue IConsumer NetworkTask List of all members.

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

static this ()

Private Attributes

IChannel reply
IConsumer consumer

Member Function Documentation

this ICluster  cluster,
char[]  channel,
IEventListener  listener = null
[inline]
 

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 130 of file NetworkQueue.d.

References consumer, and reply.

void cancel  )  [inline]
 

Cancel the listener. No more events will be dispatched to the reply IEventListener.

Reimplemented from IConsumer.

Definition at line 148 of file NetworkQueue.d.

References IConsumer::cancel(), and consumer.

void put IMessage  message  )  [inline]
 

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 162 of file NetworkQueue.d.

References IChannel::getName(), reply, and IMessage::setReply().

Referenced by testClusterMessage().

this ICluster  cluster,
char[]  channel
[inline, inherited]
 

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 62 of file NetworkQueue.d.

static this  )  [inline, static, inherited]
 

Definition at line 66 of file Client.d.

References Client::EmptyMessage.

IConsumer createConsumer IEventListener  listener  )  [inline, inherited]
 

Create a listener for this channel. Listeners are invoked when new content is placed into a corresponding queue.

Definition at line 74 of file NetworkQueue.d.

References ICluster::createConsumer().

Referenced by testClusterMessage(), and testClusterQueue().

void put IPayload  payload  )  [inline, inherited]
 

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 87 of file NetworkQueue.d.

References ICluster::putQueue().

Referenced by testClusterQueue().

IPayload get  )  [inline, inherited]
 

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 102 of file NetworkQueue.d.

References ICluster::getQueue().


Member Data Documentation

IChannel reply [private]
 

Definition at line 115 of file NetworkQueue.d.

Referenced by put(), and this().

IConsumer consumer [private]
 

Definition at line 116 of file NetworkQueue.d.

Referenced by cancel(), and this().


The documentation for this class was generated from the following file:
Generated on Mon Nov 14 10:59:58 2005 for Mango by  doxygen 1.4.0