| java.lang.Object
 org.cougaar.core.blackboard.MessageManagerImpl
| MessageManagerImpl | | class MessageManagerImpl implements MessageManager,Serializable(Code) | | A message acknowledgement manager used by the
Distributor 's
non-lazy persistence mode to ensure that unacknowledged messages
are persisted.
|
| serialVersionUID | | final public static long serialVersionUID(Code) | | |
| MessageManagerImpl | | public MessageManagerImpl(boolean enable)(Code) | | |
| acknowledgeMessages | | public void acknowledgeMessages(Iterator messages)(Code) | | |
| advanceEpoch | | public void advanceEpoch()(Code) | | Wrap up the current epoch and get into the correct state to be
persisted. Every message that has been queued for transmission is
sent. Acknowledgement numbers are advanced so we begin
acknowledging messages we have received and processed. This
method must be called while this MessageManager is
synchronized. We purposely omit the "synchronized" here because
proper operation is precluded unless the synchronization is
performed externally.
|
| needAdvanceEpoch | | public boolean needAdvanceEpoch()(Code) | | Determine if anything has happened during this epoch.
true if anything has changed. |
| receiveAck | | public int receiveAck(AckDirectiveMessage theAck)(Code) | | Process a directive acknowledgement. The acknowledged messages
are removed from the retransmission queues. If the ack is marked
as having been sent during a agent restart, we speed up the
retransmission process to hasten the recovery process.
|
| receiveMessage | | public int receiveMessage(DirectiveMessage directiveMessage)(Code) | | Check a received DirectiveMessage for being a duplicate.
Parameters:
aMessage - The received DirectiveMessage DUPLICATE, FUTURE, RESTART, IGNORE, or OK |
| sendMessages | | public void sendMessages(Iterator messages)(Code) | | Submit a DirectiveMessage for transmission from this agent. The
message is added to the set of message to be transmitted at the
end of the current epoch.
|
|
|