| org.cougaar.mts.base.BoundComponent
 org.cougaar.mts.base.MessageQueue
org.cougaar.mts.base.SendQueueImpl
| SendQueueImpl | | final public class SendQueueImpl extends MessageQueue implements SendQueue(Code) | | The default, and for now only, implementation of
SendQueue .
The implementation of sendMessage simply adds the
message to the queue. This kind of queue includes its own thread,
which invokes dispatch as each message is popped
off the queue. This, in turn, requests the
Router to route
the message to the appropriate
DestinationQueue .
|
| Method Summary | |
| boolean | dispatch(AttributedMessage message)
This is the callback from the internal thread. | | public void | load()
| | public boolean | matches(String name)
In a system with more than one SendQueue, each would have a
unique name. | | public void | sendMessage(AttributedMessage message)
The implementation of this SendQueue method simply adds the
message to the internal queue (a CircularQueue). |
| matches | | public boolean matches(String name)(Code) | | In a system with more than one SendQueue, each would have a
unique name. If the SendQueueFactory is ever asked to make a
queue with a name that's alreayd in use, it will instead find
the existing queue by means of this method.
|
| sendMessage | | public void sendMessage(AttributedMessage message)(Code) | | The implementation of this SendQueue method simply adds the
message to the internal queue (a CircularQueue).
|
|
|