| org.cougaar.core.blackboard.MessageManager
All known Subclasses: org.cougaar.core.blackboard.MessageManagerImpl,
acknowledgeMessages | void acknowledgeMessages(Iterator messagesToAck)(Code) | | Prepare to acknowledge a list of directive messages. The
acknowledgements are not actually sent until the end of the
epoch.
|
advanceEpoch | void advanceEpoch()(Code) | | Advance epoch. Bring the current epoch to an end in preparation
for a persistence delta.
true if the message manager actually requires the epoch to advance |
needAdvanceEpoch | boolean needAdvanceEpoch()(Code) | | |
receiveAck | int receiveAck(AckDirectiveMessage theAck)(Code) | | Incorporate a directive acknowledgement into the message
manager's state. The acknowledged messages are removed from the
retransmission queues.
|
receiveMessage | int receiveMessage(DirectiveMessage aMessage)(Code) | | Incorporate a directive message into the message manager's state.
Normally, the message is returned, but duplicate and fromthe future messages are ignored by returning null. |
sendMessages | void sendMessages(Iterator messages)(Code) | | Add a set of messages to the queue of messages waiting to be
transmitted. When persistence is enabled, the messages are held
until the end of the epoch.
|
start | void start(MessageSwitchService msgSwitch, boolean didRehydrate)(Code) | | Start the message manager running. The message manager should be
inactive until this method is called because it does know know
the identity of the agent it is in.
|
stop | void stop()(Code) | | Stop the message manager, halting any internal activity.
|
|
|