Uses of Class
org.objectweb.joram.shared.messages.Message
-
Packages that use Message Package Description com.scalagent.joram.mom.dest.ftp com.scalagent.joram.mom.dest.mail com.scalagent.joram.mom.dest.rest com.scalagent.joram.mom.dest.scheduler org.objectweb.joram.client.jms Theorg.objectweb.joram.client.jmspackage holds the classes implementing the interfaces defined by the JMS 2.0 specification.org.objectweb.joram.client.jms.admin Theorg.objectweb.joram.client.jms.adminpackage holds the interfaces and implementation classes for administering a JORAM platform and creating the JMS administered objects.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.dest.amqp org.objectweb.joram.mom.dest.jms Theorg.objectweb.joram.mom.dest.jmspackage provides implementation classes for JMS bridge facility.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 org.objectweb.joram.shared.admin Theorg.objectweb.joram.shared.adminpackage holds the request and reply objects used in the administrator - administration topic interactions.org.objectweb.joram.shared.client Theorg.objectweb.joram.shared.clientpackage holds the request and reply objects used in the client-provider interactions.org.objectweb.joram.shared.messages Theorg.objectweb.joram.shared.messagespackage provides the implementation classes of the messages routed by the MOM.org.objectweb.joram.shared.selectors Theorg.objectweb.joram.shared.selectorpackage holds the classes implementing the selector feature, used for filtering the messages according to their properties.org.ow2.joram.jakarta.jms Theorg.ow2.joram.jakarta.jmspackage holds the classes implementing the interfaces defined by the JMS 3.0 Jakarta specification.org.ow2.joram.jakarta.jms.admin Theorg.ow2.joram.jakarta.jms.adminpackage holds the interfaces and implementation classes for administering a JORAM platform and creating the JMS administered objects. -
-
Uses of Message in com.scalagent.joram.mom.dest.ftp
Fields in com.scalagent.joram.mom.dest.ftp declared as Message Modifier and Type Field Description private MessageFtpMessage. sharedMsgMethods in com.scalagent.joram.mom.dest.ftp that return Message Modifier and Type Method Description MessageFtpMessage. getSharedMessage()Methods in com.scalagent.joram.mom.dest.ftp with parameters of type Message Modifier and Type Method Description private voidFtpQueue. doProcessFtp(ClientMessages not, Message msg)protected booleanFtpQueue. isFtpMsg(Message message)Constructors in com.scalagent.joram.mom.dest.ftp with parameters of type Message Constructor Description FtpMessage(Message sharedMsg)Instantiates anFtpMessagewrapping a consumed shared simple message.FtpNot(int clientContext, int requestId, Message msg) -
Uses of Message in com.scalagent.joram.mom.dest.mail
Methods in com.scalagent.joram.mom.dest.mail with parameters of type Message Modifier and Type Method Description voidMailDistribution. distribute(Message fullMessage)private MimeBodyPartMailDistribution. getMultipartProp(Message msg)voidMailDistribution. sendJavaMail(Message fullMessage)Be careful, the message must be completely loaded (body). -
Uses of Message in com.scalagent.joram.mom.dest.rest
Methods in com.scalagent.joram.mom.dest.rest that return Message Modifier and Type Method Description private MessageRestAcquisitionAsync. createJSonMessage(HashMap<String,Object> map)private MessageRestAcquisitionAsync. createTextMessage(String text)private MessageRestAcquisitionAsync. recvNextMessage()Methods in com.scalagent.joram.mom.dest.rest with parameters of type Message Modifier and Type Method Description voidRESTDistribution. distribute(Message fullMessage)private Map<String,Object>RESTDistribution. getMapMessageToJsonBodyMap(Message fullMessage)private voidRESTDistribution. sendNextMessage(Message fullMessage)private voidRestAcquisitionAsync. setJMSMessageHeader(Message msg, Map header)private voidRestAcquisitionAsync. setJMSProperties(Message msg, Map props)private voidRESTAcquisition. setMessageHeader(Map jsonMessageHeader, Message message) -
Uses of Message in com.scalagent.joram.mom.dest.scheduler
Methods in com.scalagent.joram.mom.dest.scheduler with parameters of type Message Modifier and Type Method Description protected booleanSchedulerQueue. checkDelivery(Message msg)private static longSchedulerQueue. getScheduleDate(Message msg) -
Uses of Message in org.objectweb.joram.client.jms
Fields in org.objectweb.joram.client.jms declared as Message Modifier and Type Field Description protected MessageMessage. momMsgMethods in org.objectweb.joram.client.jms that return Message Modifier and Type Method Description MessageMessage. getMomMsg()Methods in org.objectweb.joram.client.jms with parameters of type Message Modifier and Type Method Description (package private) voidSession. onMessage(Message msg)Called by ConnectionConsumer in order to distribute a message through the method run().(package private) voidSession. onMessage(Message momMsg, MessageConsumerListener mcl)Called by onMessages()private voidSession. prepareSend(Destination dest, Message msg)Method called by message producers when producing a message for preparing the session to later commit it.static MessageMessage. wrapMomMessage(Session session, Message momMsg)Builds a Joram/JMS message from a Joram shared message.Constructors in org.objectweb.joram.client.jms with parameters of type Message Constructor Description BytesMessage(Session sess, Message momMsg)Instantiates aBytesMessagewrapping a consumed MOM message containing a bytes array.MapMessage(Session session, Message momMsg)Instantiates aMapMessagewrapping a consumed MOM message containing an hashtable.Message(Session session, Message momMsg)Instantiates aMessagewrapping a consumed MOM simple message.ObjectMessage(Session session, Message momMsg)Instantiates anObjectMessagewrapping a consumed MOM message containing an object.StreamMessage(Session session, Message momMsg)Instantiates aStreamMessagewrapping a consumed MOM message containing a stream of bytes.TextMessage(Session session, Message momMsg)Instantiates aTextMessagewrapping a consumed MOM message containing a text. -
Uses of Message in org.objectweb.joram.client.jms.admin
Constructors in org.objectweb.joram.client.jms.admin with parameters of type Message Constructor Description AdminMessage(Session session, Message momMsg)Instantiates anAdminMessagewrapping a consumed MOM message containing a Admin message. -
Uses of Message in org.objectweb.joram.mom.dest
Methods in org.objectweb.joram.mom.dest that return Message Modifier and Type Method Description private MessageElasticTopic. createReconnectionMessage(int tid)protected MessageDestination. processInterceptors(Message msg)Run all defined interceptors on the message.Methods in org.objectweb.joram.mom.dest with parameters of type Message Modifier and Type Method Description protected booleanQueue. checkDelivery(Message msg)Returns true if conditions are ok to deliver the message.voidDistributionHandler. distribute(Message message)Distributes the given message outside of the JORAM server.voidNotificationDistributionHandler. distribute(Message message)static voidMonitoringHelper. getJMXValues(Message message, Vector elements)private voidDistributionDaemon. incDeliveryCount(Message message)Increments the message delivery count.private booleanDistributionDaemon. isUndeliverable(Message message)private booleanDistributionDaemon. isValid(Message message)Returnstrueif the message is valid.protected MessageDestination. processInterceptors(Message msg)Run all defined interceptors on the message.voidDistributionModule. processMessage(Message fullMessage)Be careful, the message must be completely loaded (body).voidDistributionDaemon. push(Message fullMessage)Be careful, the message must be completely loaded (body).private static voidMonitoringHelper. setMessageProperty(Message message, String mbeanName, String attrName)voidAcquisitionModule. transmit(Message message, String messageId)Transmits a message to the MOM in a reliable way: if the message is persistent it has been persisted when the method returns and therefore can be safely acknowledged.voidReliableTransmitter. transmit(Message message, String messageId)Transmits a message to the MOM in a reliable way: if the message is persistent it has been persisted when the method returns and therefore can be safely acknowledged.Method parameters in org.objectweb.joram.mom.dest with type arguments of type Message Modifier and Type Method Description private voidAcquisitionModule. setMessagesInfo(List<Message> messages, long msgCount)voidAcquisitionModule. transmit(List<Message> messages, boolean persistent)Transmits a list of messages to the MOM in a reliable way: if persistent is set to true the messages have been persisted when the method returns and therefore can be safely acknowledged.voidReliableTransmitter. transmit(List<Message> messages, boolean persistent)Transmits a list of messages to the MOM in a reliable way: if persistent is set to true the messages have been persisted when the method returns and therefore can be safely acknowledged. -
Uses of Message in org.objectweb.joram.mom.dest.amqp
Methods in org.objectweb.joram.mom.dest.amqp with parameters of type Message Modifier and Type Method Description voidAmqpDistribution. distribute(Message fullMessage) -
Uses of Message in org.objectweb.joram.mom.dest.jms
Methods in org.objectweb.joram.mom.dest.jms with parameters of type Message Modifier and Type Method Description voidJMSDistribution. distribute(Message message) -
Uses of Message in org.objectweb.joram.mom.messages
Fields in org.objectweb.joram.mom.messages declared as Message Modifier and Type Field Description private MessageMessage. msgReference to the shared message.Methods in org.objectweb.joram.mom.messages that return Message Modifier and Type Method Description MessageMessage. getFullMessage()Returns the contained message with body.MessageMessage. getHeaderMessage()Returns the contained message eventually without the body.MessageMessage. getSharedMsg()Gets the message, loads it from disk if needed, then sets the msg attribute.Constructors in org.objectweb.joram.mom.messages with parameters of type Message Constructor Description Message(Message msg)Constructs aMessageinstance. -
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 MessageBrowseReply. messageThe message contained in the queue.private MessageClientMessages. messageMessage sent by the client.Fields in org.objectweb.joram.mom.notifications with type parameters of type Message Modifier and Type Field Description private Vector<Message>BrowseReply. messagesThe messages contained in the queue.private List<Message>ClientMessages. messagesMessages sent by the client.private Vector<Message>QueueMsgReply. messagesThe message sent by the queue.private List<Message>TopicMsgsReply. messagesVector of messages.private ArrayList<Message>ReconnectSubscribersNot. msgsMethods in org.objectweb.joram.mom.notifications that return types with arguments of type Message Modifier and Type Method Description Vector<Message>BrowseReply. getMessages()Returns the messages carried by this reply.List<Message>ClientMessages. getMessages()Returns the messages.Vector<Message>QueueMsgReply. getMessages()Returns the message wrapped by this reply.List<Message>TopicMsgsReply. getMessages()Returns the messages.ArrayList<Message>ReconnectSubscribersNot. getMsgs()Methods in org.objectweb.joram.mom.notifications with parameters of type Message Modifier and Type Method Description voidBrowseReply. addMessage(Message msg)Adds a message.voidClientMessages. addMessage(Message msg)Adds a message to deliver.voidQueueMsgReply. addMessage(Message msg)Constructors in org.objectweb.joram.mom.notifications with parameters of type Message Constructor Description ClientMessages(int clientContext, int requestId, Message message)Constructs aClientMessagesinstance.ReconnectSubscribersNot(String subName, Message msg)Constructor parameters in org.objectweb.joram.mom.notifications with type arguments of type Message Constructor Description ClientMessages(int clientContext, int requestId, List<Message> messages)Constructs aClientMessagesinstance.TopicMsgsReply(List<Message> messages)Constructs aTopicMsgsReply. -
Uses of Message in org.objectweb.joram.mom.proxies
Methods in org.objectweb.joram.mom.proxies with parameters of type Message Modifier and Type Method Description private voidUserAgent. sendToDMQ(Message msg, short messageError) -
Uses of Message in org.objectweb.joram.mom.util
Fields in org.objectweb.joram.mom.util with type parameters of type Message Modifier and Type Field Description private Map<String,Message>SynchronousAgent. requestsDeprecated.Methods in org.objectweb.joram.mom.util with parameters of type Message Modifier and Type Method Description voidDMQManager. addDeadMessage(Message mess, short reason)Stocks a dead message waiting to be sent to the DMQ.booleanMessageInterceptor. handle(Message msg, int key)Implement this method to intercept message on server side. -
Uses of Message in org.objectweb.joram.shared.admin
Fields in org.objectweb.joram.shared.admin declared as Message Modifier and Type Field Description private MessageGetQueueMessageRep. msgprivate MessageGetSubscriptionMessageRep. msgMethods in org.objectweb.joram.shared.admin that return Message Modifier and Type Method Description MessageGetQueueMessageRep. getMessage()MessageGetSubscriptionMessageRep. getMessage()Constructors in org.objectweb.joram.shared.admin with parameters of type Message Constructor Description GetQueueMessageRep(Message msg)GetSubscriptionMessageRep(Message msg) -
Uses of Message in org.objectweb.joram.shared.client
Fields in org.objectweb.joram.shared.client with type parameters of type Message Modifier and Type Field Description private Vector<Message>ConsumerMessages. messagesWrapped messages.private Vector<Message>ProducerMessages. messagesThe wrapped messages.Methods in org.objectweb.joram.shared.client that return types with arguments of type Message Modifier and Type Method Description Vector<Message>ConsumerMessages. getMessages()Returns the messages to deliver.Vector<Message>ProducerMessages. getMessages()Returns the produced messagesMethods in org.objectweb.joram.shared.client with parameters of type Message Modifier and Type Method Description voidConsumerMessages. addMessage(Message msg)voidProducerMessages. addMessage(Message msg)Adds a message to deliver.voidQBrowseReply. addMessage(Message msg)Method parameters in org.objectweb.joram.shared.client with type arguments of type Message Modifier and Type Method Description voidProducerMessages. addMessages(Vector<Message> msgs)Adds messages to deliver.voidConsumerMessages. setMessages(Vector<Message> newMsgs)Replace old messages vector by new newMsgs vectorvoidProducerMessages. setMessages(Vector<Message> newMsgs)Replace old messages vector by new newMsgs vectorConstructors in org.objectweb.joram.shared.client with parameters of type Message Constructor Description ConsumerMessages(int correlationId, Message message, String comingFrom, boolean queueMode)Constructs aConsumerMessagesinstance.ProducerMessages(String dest, Message msg)Constructs aProducerMessagesinstance carrying a single message.Constructor parameters in org.objectweb.joram.shared.client with type arguments of type Message Constructor Description ConsumerMessages(int correlationId, Vector<Message> messages, String comingFrom, boolean queueMode)Constructs aConsumerMessagesinstance. -
Uses of Message in org.objectweb.joram.shared.messages
Methods in org.objectweb.joram.shared.messages that return Message Modifier and Type Method Description static MessageMessageHelper. createMessage(String msgId, String correlationId, String destId, byte destType)Creates a well formedMessage.Methods in org.objectweb.joram.shared.messages that return types with arguments of type Message Modifier and Type Method Description static Vector<Message>Message. decodeMessageVector(Decoder decoder)static Vector<Message>Message. readVectorFrom(InputStream is)this method allows to read from the input stream a vector of messages.Method parameters in org.objectweb.joram.shared.messages with type arguments of type Message Modifier and Type Method Description static voidMessage. encodeMessageVector(Vector<Message> messages, Encoder encoder)static intMessage. getMessageVectorEncodedSize(Vector<Message> messages)static voidMessage. writeVectorTo(Vector<Message> messages, OutputStream os)this method allows to write to the output stream a vector of message. -
Uses of Message in org.objectweb.joram.shared.selectors
Fields in org.objectweb.joram.shared.selectors declared as Message Modifier and Type Field Description private MessageCUP$Filter$actions. messageprivate MessageFilter. messageMethods in org.objectweb.joram.shared.selectors with parameters of type Message Modifier and Type Method Description (package private) static ObjectInterpreter. interpret(String name, Message message, String syntaxType)Calls the appropriate method for interpreting a field name according to the syntax type.private static ObjectInterpreter. jmsInterpret(String name, Message message)Retrieves the value of a field following the JMS syntax rules.static booleanSelector. matches(Message message, String selector)Destinations call this method to filter a message according to a selector.Constructors in org.objectweb.joram.shared.selectors with parameters of type Message Constructor Description CUP$Filter$actions(Filter parser, Message message, String syntaxType)ConstructorFilter(java_cup.runtime.Scanner s, Message message, String syntaxType)Constructor which sets the default scanner. -
Uses of Message in org.ow2.joram.jakarta.jms
Fields in org.ow2.joram.jakarta.jms declared as Message Modifier and Type Field Description protected MessageMessage. momMsgMethods in org.ow2.joram.jakarta.jms that return Message Modifier and Type Method Description MessageMessage. getMomMsg()Methods in org.ow2.joram.jakarta.jms with parameters of type Message Modifier and Type Method Description (package private) voidSession. onMessage(Message msg)Called by ConnectionConsumer in order to distribute a message through the method run().(package private) voidSession. onMessage(Message momMsg, MessageConsumerListener mcl)Called by onMessages()private voidSession. prepareSend(Destination dest, Message msg)Method called by message producers when producing a message for preparing the session to later commit it.static MessageMessage. wrapMomMessage(Session session, Message momMsg)Builds a Joram/JMS message from a Joram shared message.Constructors in org.ow2.joram.jakarta.jms with parameters of type Message Constructor Description BytesMessage(Session sess, Message momMsg)Instantiates aBytesMessagewrapping a consumed MOM message containing a bytes array.MapMessage(Session session, Message momMsg)Instantiates aMapMessagewrapping a consumed MOM message containing an hashtable.Message(Session session, Message momMsg)Instantiates aMessagewrapping a consumed MOM simple message.ObjectMessage(Session session, Message momMsg)Instantiates anObjectMessagewrapping a consumed MOM message containing an object.StreamMessage(Session session, Message momMsg)Instantiates aStreamMessagewrapping a consumed MOM message containing a stream of bytes.TextMessage(Session session, Message momMsg)Instantiates aTextMessagewrapping a consumed MOM message containing a text. -
Uses of Message in org.ow2.joram.jakarta.jms.admin
Constructors in org.ow2.joram.jakarta.jms.admin with parameters of type Message Constructor Description AdminMessage(Session session, Message momMsg)Instantiates anAdminMessagewrapping a consumed MOM message containing a Admin message.
-