Uses of Class
org.objectweb.joram.mom.messages.Message
-
Packages that use Message Package Description org.objectweb.joram.mom.dest Theorg.objectweb.joram.mom.destpackage holds the classes implementing the queue, topic and specialized destinations provided by JORAM's MOM.org.objectweb.joram.mom.messages Theorg.objectweb.joram.shared.messagespackage provides the implementation classes of the messages routed by the MOM.org.objectweb.joram.mom.notifications Theorg.objectweb.joram.mom.notificationspackage holds the notifications used for interacting with the MOM destination agents.org.objectweb.joram.mom.proxies Theorg.objectweb.joram.mom.proxiespackage holds the classes implementing the MOM proxy, basically linking external client applications to destination agents.org.objectweb.joram.mom.util -
-
Uses of Message in org.objectweb.joram.mom.dest
Fields in org.objectweb.joram.mom.dest declared as Message Modifier and Type Field Description private MessageQueueDelivery. messageFields in org.objectweb.joram.mom.dest with type parameters of type Message Modifier and Type Field Description protected List<Message>Queue. delayedList of delayed messagesprotected List<Message>Queue. messagesList holding the messages before delivery.Methods in org.objectweb.joram.mom.dest that return Message Modifier and Type Method Description MessageQueueDelivery. getMessage()private MessageQueue. getMomMessage(String msgId)protected MessageClusterQueue. getQueueMessage(String msgId, boolean remove)get mom message, delete if remove = true.protected MessageQueue. getQueueMessage(String msgId, boolean remove)Get mom message, delete if remove = true.Methods in org.objectweb.joram.mom.dest that return types with arguments of type Message Modifier and Type Method Description private List<Message>Queue. getMessages(int nb, String selector, boolean remove)get messages, if it's possible.Methods in org.objectweb.joram.mom.dest with parameters of type Message Modifier and Type Method Description (package private) voidQueue. addDeliveryTimeMessage(Message msg, boolean throwsExceptionOnFullDest, boolean isHeader)Adds the specified message to the list of delayed message.protected booleanQueue. addMessage(Message message, boolean throwsExceptionOnFullDest)Adds a message in the list of messages to deliver.private static StringQueue. getIdString(Message msg)protected booleanQueue. isUndeliverable(Message message)Returnstrueif 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).voidQueueDelivery. setMessage(Message message)protected voidQueue. setMsgTxName(Message msg)protected voidQueue. storeMessage(Message msg, boolean throwsExceptionOnFullDest)Actually stores a message in the deliverables list.Constructors in org.objectweb.joram.mom.dest with parameters of type Message Constructor Description QueueDelivery(AgentId consumerId, int contextId, Message message) -
Uses of Message in org.objectweb.joram.mom.messages
Methods in org.objectweb.joram.mom.messages that return Message Modifier and Type Method Description static MessageMessage. load(String txname)static MessageMessage. loadMessage(Transaction transaction, String txname)Loads a message from transactional persistence.Methods in org.objectweb.joram.mom.messages that return types with arguments of type Message Modifier and Type Method Description static Vector<Message>Message. loadAll(String msgTxname, int max)Loads all persisted messages.Methods in org.objectweb.joram.mom.messages with parameters of type Message Modifier and Type Method Description intMessage. compareTo(Message msg)static CompositeDataMessageJMXWrapper. createCompositeDataSupport(Message msg)Returns the description of a message. -
Uses of Message in org.objectweb.joram.mom.notifications
Fields in org.objectweb.joram.mom.notifications declared as Message Modifier and Type Field Description private MessageQueueDeliveryTimeNot. msgprivate MessageTopicDeliveryTimeNot. msgMethods in org.objectweb.joram.mom.notifications that return Message Modifier and Type Method Description MessageQueueDeliveryTimeNot. getMsg()MessageTopicDeliveryTimeNot. getMsg()Constructors in org.objectweb.joram.mom.notifications with parameters of type Message Constructor Description QueueDeliveryTimeNot(Message msg, boolean throwsExceptionOnFullDest)TopicDeliveryTimeNot(Message msg, AgentId topic, String subName) -
Uses of Message in org.objectweb.joram.mom.proxies
Methods in org.objectweb.joram.mom.proxies that return Message Modifier and Type Method Description (package private) MessageClientSubscription. getSubMessage(String msgId)(package private) MessageClientSubscription. getSubscriptionMessage(String msgId)(package private) MessageClientSubscription. removeMessage(String msgId)Removes a particular pending message in the subscription.Methods in org.objectweb.joram.mom.proxies with parameters of type Message Modifier and Type Method Description private voidClientSubscription. decrAckCounters(String msgId, Message message)private voidUserAgent. persistDeliveryTimeMessage(Message msg)(package private) voidClientSubscription. scheduleDeliveryTimeMessage(Message message)schedule the delivery time message.protected voidUserAgent. setMsgTxName(Message msg)Method parameters in org.objectweb.joram.mom.proxies with type arguments of type Message Modifier and Type Method Description (package private) voidClientSubscription. browseNewMessages(List<Message> newMessages)Browses messages and keeps those which will have to be delivered to the subscriber.(package private) voidClientSubscription. reinitialize(MessageTable messagesTable, List<Message> persistedMessages, boolean denyDeliveredMessages)Re-initializes the client subscription. -
Uses of Message in org.objectweb.joram.mom.util
Fields in org.objectweb.joram.mom.util declared as Message Modifier and Type Field Description private MessageQueueDeliveryTimeTask. msgprivate MessageTopicDeliveryTimeTask. msgFields in org.objectweb.joram.mom.util with type parameters of type Message Modifier and Type Field Description private HashMap<String,Message>InMemoryMessageTable. mapMethods in org.objectweb.joram.mom.util that return Message Modifier and Type Method Description MessageInMemoryMessageTable. get(String msgId)MessageMessageTable. get(String msgId)Returns the specified message.Methods in org.objectweb.joram.mom.util that return types with arguments of type Message Modifier and Type Method Description HashMap<String,Message>InMemoryMessageTable. getMap()Map<String,Message>MessageTable. getMap()Returns a map of messages from this table indexed by their message identifiers.Methods in org.objectweb.joram.mom.util with parameters of type Message Modifier and Type Method Description voidInMemoryMessageTable. put(Message msg)voidMessageTable. put(Message msg)Adds a message in this table.Constructors in org.objectweb.joram.mom.util with parameters of type Message Constructor Description QueueDeliveryTimeTask(AgentId destId, Message msg, boolean throwsExceptionOnFullDest)TopicDeliveryTimeTask(AgentId destId, AgentId topic, String subName, Message msg)
-