Package | Description |
---|---|
com.scalagent.joram.mom.dest.ftp | |
com.scalagent.joram.mom.dest.mail | |
com.scalagent.joram.mom.dest.scheduler | |
org.objectweb.joram.client.jms |
The
org.objectweb.joram.client.jms package holds the classes implementing the interfaces defined by the JMS 1.1 specification. |
org.objectweb.joram.client.jms.admin |
The
org.objectweb.joram.client.jms.admin package holds the interfaces and implementation classes for administering a JORAM platform and creating the JMS administered objects. |
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.amqp | |
org.objectweb.joram.mom.dest.jms | |
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.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 | |
org.objectweb.joram.shared.admin |
The
org.objectweb.joram.shared.admin package holds the request and reply objects used in the administrator - administration topic interactions. |
org.objectweb.joram.shared.client |
The
org.objectweb.joram.shared.client package holds the request and reply objects used in the client-provider interactions. |
org.objectweb.joram.shared.messages |
The
org.objectweb.joram.shared.messages package provides the implementation classes of the messages routed by the MOM. |
org.objectweb.joram.shared.selectors |
The
org.objectweb.joram.shared.selector package holds the classes implementing the selector feature, used for filtering the messages according to their properties. |
Modifier and Type | Field and Description |
---|---|
private Message |
FtpMessage.sharedMsg |
Modifier and Type | Method and Description |
---|---|
Message |
FtpMessage.getSharedMessage() |
Modifier and Type | Method and Description |
---|---|
private void |
FtpQueue.doProcessFtp(ClientMessages not,
Message msg) |
protected boolean |
FtpQueue.isFtpMsg(Message message) |
Constructor and Description |
---|
FtpMessage(Message sharedMsg)
Instantiates an
FtpMessage wrapping a consumed
shared simple message. |
FtpNot(int clientContext,
int requestId,
Message msg) |
Modifier and Type | Method and Description |
---|---|
void |
MailDistribution.distribute(Message message) |
private MimeBodyPart |
MailDistribution.getMultipartProp(Message msg) |
void |
MailDistribution.sendJavaMail(Message message) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
SchedulerQueue.checkDelivery(Message msg) |
private static long |
SchedulerQueue.getScheduleDate(Message msg) |
Modifier and Type | Field and Description |
---|---|
protected Message |
Message.momMsg |
Modifier and Type | Method and Description |
---|---|
Message |
Message.getMomMsg() |
Modifier and Type | Method and Description |
---|---|
(package private) void |
Session.onMessage(Message msg)
Called by ConnectionConsumer in order to distribute a message through the
method run().
|
(package private) void |
Session.onMessage(Message momMsg,
MessageConsumerListener mcl)
Called by onMessages()
|
private void |
Session.prepareSend(Destination dest,
Message msg)
Method called by message producers when producing a message for
preparing the session to later commit it.
|
static Message |
Message.wrapMomMessage(Session session,
Message momMsg) |
Constructor and Description |
---|
BytesMessage(Session sess,
Message momMsg)
Instantiates a
BytesMessage wrapping a consumed
MOM message containing a bytes array. |
MapMessage(Session session,
Message momMsg)
Instantiates a
MapMessage wrapping a consumed MOM
message containing an hashtable. |
Message(Session session,
Message momMsg)
Instantiates a
Message wrapping a consumed MOM simple message. |
ObjectMessage(Session session,
Message momMsg)
Instantiates an
ObjectMessage wrapping a
consumed MOM message containing an object. |
StreamMessage(Session session,
Message momMsg)
Instantiates a
StreamMessage wrapping a consumed
MOM message containing a stream of bytes. |
TextMessage(Session session,
Message momMsg)
Instantiates a
TextMessage wrapping a consumed
MOM message containing a text. |
Constructor and Description |
---|
AdminMessage(Session session,
Message momMsg)
Instantiates an
AdminMessage wrapping a
consumed MOM message containing a Admin message. |
Modifier and Type | Method and Description |
---|---|
private Message |
ElasticTopic.createReconnectionMessage(int tid) |
protected Message |
Destination.processInterceptors(Message msg)
Interceptors process
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
Queue.checkDelivery(Message msg)
Returns true if conditions are ok to deliver the message.
|
void |
NotificationDistributionHandler.distribute(Message message) |
void |
DistributionHandler.distribute(Message message)
Distributes the given message outside of the JORAM server.
|
static void |
MonitoringHelper.getJMXValues(Message message,
Vector elements) |
private void |
DistributionDaemon.incDeliveryCount(Message message)
Increments the message delivery count.
|
private boolean |
DistributionDaemon.isUndeliverable(Message message) |
private boolean |
DistributionDaemon.isValid(Message message)
Returns
true if the message is valid. |
protected Message |
Destination.processInterceptors(Message msg)
Interceptors process
|
void |
DistributionModule.processMessage(Message fullMessage) |
void |
DistributionDaemon.push(Message msg) |
private static void |
MonitoringHelper.setMessageProperty(Message message,
String mbeanName,
String attrName) |
void |
ReliableTransmitter.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.
|
void |
AcquisitionModule.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.
|
Modifier and Type | Method and Description |
---|---|
void |
AmqpDistribution.distribute(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
JMSDistribution.distribute(Message message) |
Modifier and Type | Field and Description |
---|---|
private Message |
JMSBridgeDeliveryNot.message
Deprecated.
Message obtained from the foreign JMS server.
|
Modifier and Type | Method and Description |
---|---|
Message |
JMSBridgeDeliveryNot.getMessage()
Deprecated.
Returns the message obtained from the foreign JMS server.
|
Message |
JMSBridgeModule.receiveNoWait()
Deprecated.
Synchronous method requesting an immediate delivery from the foreign
JMS destination.
|
Modifier and Type | Method and Description |
---|---|
protected void |
JMSBridgeModule.acknowledge(Message message)
Deprecated.
Acknowledges a message successfully delivered to the foreign JMS server.
|
void |
JMSBridgeModule.send(Message message)
Deprecated.
Sends a message to the foreign JMS destination.
|
Constructor and Description |
---|
JMSBridgeDeliveryNot(Message message)
Deprecated.
Constructs a
BridgeDeliveryNot wrapping a given message
obtained from a foreign JMS server. |
Modifier and Type | Field and Description |
---|---|
private Message |
Message.msg
Reference to the MOM message.
|
Modifier and Type | Method and Description |
---|---|
Message |
Message.getFullMessage()
Returns the contained message with body.
|
Message |
Message.getHeaderMessage()
Returns the contained message eventually without the body.
|
Message |
Message.getMsg() |
Constructor and Description |
---|
Message(Message msg)
Constructs a
Message instance. |
Modifier and Type | Field and Description |
---|---|
private Message |
ClientMessages.message
Message sent by the client.
|
private Message |
BrowseReply.message
The message contained in the queue.
|
Modifier and Type | Field and Description |
---|---|
private List<Message> |
ClientMessages.messages
Messages sent by the client.
|
private ArrayList<Message> |
ReconnectSubscribersNot.msgs |
Modifier and Type | Method and Description |
---|---|
ArrayList<Message> |
ReconnectSubscribersNot.getMsgs() |
Modifier and Type | Method and Description |
---|---|
void |
QueueMsgReply.addMessage(Message msg) |
void |
ClientMessages.addMessage(Message msg)
Adds a message to deliver.
|
void |
BrowseReply.addMessage(Message msg)
Adds a message.
|
Constructor and Description |
---|
ClientMessages(int clientContext,
int requestId,
Message message)
Constructs a
ClientMessages instance. |
ReconnectSubscribersNot(String subName,
Message msg) |
Constructor and Description |
---|
ReconnectSubscribersNot(ArrayList<Integer> subs,
ArrayList<Message> msgs,
FwdAdminRequestNot not) |
Modifier and Type | Method and Description |
---|---|
private void |
UserAgent.sendToDMQ(Message msg,
short messageError) |
Modifier and Type | Field and Description |
---|---|
private Map<String,Message> |
SynchronousAgent.requests |
Modifier and Type | Method and Description |
---|---|
void |
DMQManager.addDeadMessage(Message mess,
short reason)
Stocks a dead message waiting to be sent to the DMQ.
|
boolean |
MessageInterceptor.handle(Message msg,
int key)
Implement this method to intercept message on server side.
|
Modifier and Type | Field and Description |
---|---|
private Message |
GetSubscriptionMessageRep.msg |
private Message |
GetQueueMessageRep.msg |
Modifier and Type | Method and Description |
---|---|
Message |
GetSubscriptionMessageRep.getMessage() |
Message |
GetQueueMessageRep.getMessage() |
Constructor and Description |
---|
GetQueueMessageRep(Message msg) |
GetSubscriptionMessageRep(Message msg) |
Modifier and Type | Method and Description |
---|---|
void |
QBrowseReply.addMessage(Message msg) |
void |
ProducerMessages.addMessage(Message msg)
Adds a message to deliver.
|
void |
ConsumerMessages.addMessage(Message msg) |
Constructor and Description |
---|
ConsumerMessages(int correlationId,
Message message,
String comingFrom,
boolean queueMode)
Constructs a
ConsumerMessages instance. |
ProducerMessages(String dest,
Message msg)
Constructs a
ProducerMessages instance carrying a single
message. |
Modifier and Type | Method and Description |
---|---|
static Message |
MessageHelper.createMessage(String msgId,
String correlationId,
String destId,
byte destType)
Creates a well formed
Message . |
Modifier and Type | Method and Description |
---|---|
static Vector<Message> |
Message.decodeMessageVector(Decoder decoder) |
Modifier and Type | Method and Description |
---|---|
static void |
Message.encodeMessageVector(Vector<Message> messages,
Encoder encoder) |
static int |
Message.getMessageVectorEncodedSize(Vector<Message> messages) |
Modifier and Type | Field and Description |
---|---|
private Message |
Filter.message |
private Message |
CUP$Filter$actions.message |
Modifier and Type | Method and Description |
---|---|
(package private) static Object |
Interpreter.interpret(String name,
Message message,
String syntaxType)
Calls the appropriate method for interpreting a field name according to
the syntax type.
|
private static Object |
Interpreter.jmsInterpret(String name,
Message message)
Retrieves the value of a field following the JMS syntax rules.
|
static boolean |
Selector.matches(Message message,
String selector)
Destinations call this method to filter a message according to a selector.
|
Constructor and Description |
---|
CUP$Filter$actions(Filter parser,
Message message,
String syntaxType)
Constructor
|
Filter(java_cup.runtime.Scanner s,
Message message,
String syntaxType)
Constructor which sets the default scanner.
|
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.