void |
Queue.addClientMessages(ClientMessages clientMsgs,
boolean throwsExceptionOnFullDest) |
Adds the client messages in the queue.
|
(package private) void |
Queue.addDeliveryTimeMessage(Message msg,
boolean throwsExceptionOnFullDest,
boolean isHeader) |
Adds the specified message to the list of delayed message.
|
protected boolean |
Queue.addMessage(Message message,
boolean throwsExceptionOnFullDest) |
Adds a message in the list of messages to deliver.
|
protected void |
Queue.browseRequest(AgentId from,
BrowseRequest not) |
Method implementing the queue reaction to a BrowseRequest
instance, requesting an enumeration of the messages on the queue.
|
protected void |
Destination.clientMessages(AgentId from,
ClientMessages not) |
Method implementing the reaction to a ClientMessages
notification holding messages sent by a client.
|
protected abstract void |
Destination.doClientMessages(AgentId from,
ClientMessages not,
boolean throwsExceptionOnFullDest) |
|
protected void |
Queue.doClientMessages(AgentId from,
ClientMessages not,
boolean throwsExceptionOnFullDest) |
Method specifically processing a ClientMessages instance.
|
protected void |
Destination.getRights(AgentId from,
GetRightsRequestNot not) |
Method implementing the reaction to a GetRightsRequest
notification requesting the rights about this destination.
|
(package private) void |
Queue.processDeliveryTime(AgentId from,
QueueDeliveryTimeNot not) |
|
void |
ClusterQueue.receiveRequest(AgentId from,
ReceiveRequest not) |
|
protected void |
Queue.receiveRequest(AgentId from,
ReceiveRequest not) |
Method implementing the reaction to a ReceiveRequest
instance, requesting a message.
|
protected void |
Queue.storeMessage(Message msg,
boolean throwsExceptionOnFullDest) |
Actually stores a message in the deliverables list.
|
protected void |
Topic.subscribeRequest(AgentId from,
SubscribeRequest not) |
Method implementing the reaction to a SubscribeRequest
instance.
|