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.messages |
The
org.objectweb.joram.shared.messages package provides the implementation classes of the messages routed by the MOM. |
org.objectweb.joram.mom.notifications |
The
org.objectweb.joram.mom.notifications package holds the notifications used for interacting with the MOM destination agents. |
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. |
org.objectweb.joram.mom.util |
Modifier and Type | Field and Description |
---|---|
private Message |
QueueDelivery.message |
Modifier and Type | Field and Description |
---|---|
protected List<Message> |
Queue.messages
List holding the messages before delivery.
|
Modifier and Type | Method and Description |
---|---|
Message |
QueueDelivery.getMessage() |
private Message |
Queue.getMomMessage(String msgId) |
protected Message |
Queue.getQueueMessage(String msgId,
boolean remove)
Get mom message, delete if remove = true.
|
protected Message |
ClusterQueue.getQueueMessage(String msgId,
boolean remove)
get mom message, delete if remove = true.
|
Modifier and Type | Method and Description |
---|---|
private List<Message> |
Queue.getMessages(int nb,
String selector,
boolean remove)
get messages, if it's possible.
|
Modifier and Type | Method and Description |
---|---|
(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.
|
private static String |
Queue.getIdString(Message msg) |
protected boolean |
Queue.isUndeliverable(Message message)
Returns
true if a given message is considered as undeliverable,
because its delivery count matches the queue's threshold, if any, or the
server's default threshold value (if any). |
void |
QueueDelivery.setMessage(Message message) |
protected void |
Queue.setMsgTxName(Message msg) |
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.
|
Constructor and Description |
---|
QueueDelivery(AgentId consumerId,
int contextId,
Message message) |
Modifier and Type | Method and Description |
---|---|
static Message |
Message.load(String txname) |
Modifier and Type | Method and Description |
---|---|
static Vector<Message> |
Message.loadAll(String msgTxname,
int max)
Loads all persisted messages.
|
Modifier and Type | Method and Description |
---|---|
int |
Message.compareTo(Message msg) |
static CompositeData |
MessageJMXWrapper.createCompositeDataSupport(Message msg)
Returns the description of a message.
|
Modifier and Type | Field and Description |
---|---|
Message |
TopicDeliveryTimeNot.msg |
Message |
QueueDeliveryTimeNot.msg |
Constructor and Description |
---|
QueueDeliveryTimeNot(Message msg,
boolean throwsExceptionOnFullDest) |
TopicDeliveryTimeNot(Message msg,
AgentId topic,
String subName) |
Modifier and Type | Method and Description |
---|---|
(package private) Message |
ClientSubscription.getSubMessage(String msgId) |
(package private) Message |
ClientSubscription.getSubscriptionMessage(String msgId) |
(package private) Message |
ClientSubscription.removeMessage(String msgId)
Removes a particular pending message in the subscription.
|
Modifier and Type | Method and Description |
---|---|
private void |
ClientSubscription.decrAckCounters(String msgId,
Message message) |
(package private) void |
UserAgent.persistDeliveryTimeMessage(Message msg) |
(package private) void |
ClientSubscription.scheduleDeliveryTimeMessage(Message message)
schedule the delivery time message.
|
protected void |
UserAgent.setMsgTxName(Message msg) |
Modifier and Type | Field and Description |
---|---|
private Message |
TopicDeliveryTimeTask.msg |
private Message |
QueueDeliveryTimeTask.msg |
Modifier and Type | Field and Description |
---|---|
private HashMap<String,Message> |
InMemoryMessageTable.map |
Modifier and Type | Method and Description |
---|---|
Message |
MessageTable.get(String msgId)
Returns the specified message.
|
Message |
InMemoryMessageTable.get(String msgId) |
Modifier and Type | Method and Description |
---|---|
Map<String,Message> |
MessageTable.getMap()
Returns a map of messages from this table indexed
by their message identifiers.
|
HashMap<String,Message> |
InMemoryMessageTable.getMap() |
Modifier and Type | Method and Description |
---|---|
void |
MessageTable.put(Message msg)
Adds a message in this table.
|
void |
InMemoryMessageTable.put(Message msg) |
Constructor and Description |
---|
QueueDeliveryTimeTask(AgentId destId,
Message msg,
boolean throwsExceptionOnFullDest) |
TopicDeliveryTimeTask(AgentId destId,
AgentId topic,
String subName,
Message msg) |
Copyright © 2023 ScalAgent D.T.. All rights reserved.