|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Message in org.jboss.jms.message |
Classes in org.jboss.jms.message that implement Message | |
class |
JBossBytesMessage
This class implements javax.jms.BytesMessage. |
class |
JBossMapMessage
This class implements javax.jms.MapMessage |
class |
JBossMessage
Implementation of a JMS Message Note that the only reason this class is Serializable is so that messages can be returned from JMX operations. |
class |
JBossObjectMessage
This class implements javax.jms.ObjectMessage |
class |
JBossStreamMessage
This class implements javax.jms.StreamMessage. |
class |
JBossTextMessage
This class implements javax.jms.TextMessage ported from SpyTextMessage in JBossMQ. |
Uses of Message in org.jboss.jms.server.endpoint |
Methods in org.jboss.jms.server.endpoint with parameters of type Message | |
boolean |
ServerConsumerEndpoint.accept(Message msg)
|
Uses of Message in org.jboss.jms.server.selector |
Methods in org.jboss.jms.server.selector with parameters of type Message | |
boolean |
Selector.accept(Message message)
|
Uses of Message in org.jboss.jms.wireformat |
Methods in org.jboss.jms.wireformat that return Message | |
Message |
ClientDelivery.getMessage()
|
Constructors in org.jboss.jms.wireformat with parameters of type Message | |
ClientDelivery(Message msg,
int consumerId,
long deliveryId,
int deliveryCount)
|
Uses of Message in org.jboss.messaging.core |
Methods in org.jboss.messaging.core with parameters of type Message | |
boolean |
Filter.accept(Message message)
Tests whether the message should be accepted. |
Uses of Message in org.jboss.messaging.core.message |
Classes in org.jboss.messaging.core.message that implement Message | |
class |
CoreMessage
|
class |
MessageSupport
A message base. |
Methods in org.jboss.messaging.core.message that return Message | |
Message |
MessageReference.getMessage()
|
Message |
SimpleMessageReference.getMessage()
|
static Message |
MessageFactory.createMessage(byte type)
|
static Message |
MessageFactory.createMessage(long messageID,
boolean reliable,
long expiration,
long timestamp,
byte priority,
java.util.Map headers,
byte[] payload,
byte type)
|
Methods in org.jboss.messaging.core.message with parameters of type Message | |
MessageReference |
SimpleMessageStore.reference(Message m)
|
protected org.jboss.messaging.core.message.MessageHolder |
SimpleMessageStore.addMessage(Message m)
|
Uses of Message in org.jboss.messaging.core.plugin |
Methods in org.jboss.messaging.core.plugin with parameters of type Message | |
protected void |
JDBCPersistenceManager.incrementChannelCount(Message m,
java.sql.PreparedStatement ps)
|
protected void |
JDBCPersistenceManager.decrementChannelCount(Message m,
java.sql.PreparedStatement ps)
|
protected void |
JDBCPersistenceManager.storeMessage(Message m,
java.sql.PreparedStatement ps)
Stores the message in the MESSAGE table. |
protected void |
JDBCPersistenceManager.removeMessage(Message message,
java.sql.PreparedStatement ps)
Removes the message from the MESSAGE table. |
Uses of Message in org.jboss.messaging.core.plugin.contract |
Methods in org.jboss.messaging.core.plugin.contract that return Message | |
Message |
PersistenceManager.MessageChannelPair.getMessage()
|
Methods in org.jboss.messaging.core.plugin.contract with parameters of type Message | |
MessageReference |
MessageStore.reference(Message m)
Message m is stored in the store if it is not already known to the store, then a new MessageReference is returned for the Message |
Constructors in org.jboss.messaging.core.plugin.contract with parameters of type Message | |
PersistenceManager.MessageChannelPair(Message message,
long channelId)
|
Uses of Message in org.jboss.messaging.core.plugin.postoffice.cluster |
Methods in org.jboss.messaging.core.plugin.postoffice.cluster with parameters of type Message | |
void |
DefaultClusteredPostOffice.routeFromCluster(Message message,
java.lang.String routingKeyText,
java.util.Map queueNameNodeIdMap)
|
void |
DefaultClusteredPostOffice.handleMessagePullResult(int remoteNodeId,
long holdingTxId,
java.lang.String queueName,
Message message)
|
void |
LocalClusteredQueue.handlePullMessagesResult(RemoteQueueStub remoteQueue,
Message message,
long holdingTxId,
boolean failBeforeCommit,
boolean failAfterCommit)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |