Package | Description |
---|---|
org.objectweb.joram.mom.dest |
The
org.objectweb.joram.mom.dest package holds the classes implementing the queue, topic and specialized destinations provided by JORAM's MOM. |
org.objectweb.joram.mom.dest.jmsbridge |
The
org.objectweb.joram.mom.dest.jmsbridge package provides utility classes used by the MOM destinations and proxies. |
org.objectweb.joram.mom.proxies |
The
org.objectweb.joram.mom.proxies package holds the classes implementing the MOM proxy, basically linking external client applications to destination agents. |
Modifier and Type | Method and Description |
---|---|
void |
Queue.addClientMessages(ClientMessages clientMsgs,
boolean throwsExceptionOnFullDest)
Adds the client messages in the queue.
|
(package private) void |
Queue.addDeliveryTimeMessage(Message msg,
int clientCtx,
boolean throwsExceptionOnFullDest,
boolean isHeader) |
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 void |
Queue.doClientMessages(AgentId from,
ClientMessages not,
boolean throwsExceptionOnFullDest)
Method specifically processing a
ClientMessages instance. |
protected abstract void |
Destination.doClientMessages(AgentId from,
ClientMessages not,
boolean throwsExceptionOnFullDest) |
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) |
protected void |
Queue.receiveRequest(AgentId from,
ReceiveRequest not)
Method implementing the reaction to a
ReceiveRequest
instance, requesting a message. |
void |
ClusterQueue.receiveRequest(AgentId from,
ReceiveRequest not) |
protected void |
Queue.storeMessage(Message msg,
boolean throwsExceptionOnFullDest)
Actually stores a message in the deliverables list.
|
protected void |
Queue.storeMessageHeader(Message message,
boolean throwsExceptionOnFullDest)
Actually stores a message header in the deliverables list.
|
protected void |
Topic.subscribeRequest(AgentId from,
SubscribeRequest not)
Method implementing the reaction to a
SubscribeRequest
instance. |
Modifier and Type | Method and Description |
---|---|
void |
JMSBridgeQueue.receiveRequest(AgentId from,
ReceiveRequest not)
Deprecated.
Method specializing the reaction to a
ReceiveRequest
instance, requesting a message. |
Modifier and Type | Method and Description |
---|---|
private void |
UserAgent.doReact(int key,
GetAdminTopicRequest req)
Method implementing the reaction to a
GetAdminTopicRequest
requesting the identifier of the local admin topic. |
Copyright © 2022 ScalAgent D.T.. All rights reserved.