Methods in org.apache.qpid.client with parameters of type AbstractJMSMessage |
void |
BasicMessageConsumer.notifyMessage(AbstractJMSMessage jmsMessage)
|
void |
BasicMessageConsumer_0_10.notifyMessage(AbstractJMSMessage jmsMessage)
This is invoked by the session thread when emptying the session message queue. |
(package private) void |
BasicMessageConsumer.postDeliver(AbstractJMSMessage msg)
|
(package private) void |
BasicMessageConsumer_0_10.postDeliver(AbstractJMSMessage msg)
|
protected void |
BasicMessageConsumer.preApplicationProcessing(AbstractJMSMessage jmsMsg)
|
protected void |
BasicMessageConsumer_0_10.preApplicationProcessing(AbstractJMSMessage jmsMsg)
|
(package private) void |
BasicMessageConsumer.preDeliver(AbstractJMSMessage msg)
|
void |
AMQSession.rejectMessage(AbstractJMSMessage message,
boolean requeue)
|
(package private) abstract void |
BasicMessageProducer.sendMessage(AMQDestination destination,
Message origMessage,
AbstractJMSMessage message,
UUID messageId,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
boolean wait)
|
(package private) void |
BasicMessageProducer_0_10.sendMessage(AMQDestination destination,
Message origMessage,
AbstractJMSMessage message,
UUID messageId,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
boolean wait)
Sends a message to a given destination |
(package private) void |
BasicMessageProducer_0_8.sendMessage(AMQDestination destination,
Message origMessage,
AbstractJMSMessage message,
UUID messageId,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
boolean wait)
|
Methods in org.apache.qpid.client.message that return AbstractJMSMessage |
protected AbstractJMSMessage |
AbstractJMSMessageFactory.create010MessageWithBody(long messageNbr,
org.apache.qpid.transport.MessageProperties msgProps,
org.apache.qpid.transport.DeliveryProperties deliveryProps,
ByteBuffer body)
|
protected AbstractJMSMessage |
AbstractJMSMessageFactory.create08MessageWithBody(long messageNbr,
org.apache.qpid.framing.ContentHeaderBody contentHeader,
org.apache.qpid.framing.AMQShortString exchange,
org.apache.qpid.framing.AMQShortString routingKey,
List bodies)
|
protected abstract AbstractJMSMessage |
AbstractJMSMessageFactory.createMessage(AMQMessageDelegate delegate,
org.apache.mina.common.ByteBuffer data)
|
protected AbstractJMSMessage |
JMSBytesMessageFactory.createMessage(AMQMessageDelegate delegate,
org.apache.mina.common.ByteBuffer data)
|
protected AbstractJMSMessage |
JMSMapMessageFactory.createMessage(AMQMessageDelegate delegate,
org.apache.mina.common.ByteBuffer data)
|
protected AbstractJMSMessage |
JMSObjectMessageFactory.createMessage(AMQMessageDelegate delegate,
org.apache.mina.common.ByteBuffer data)
|
protected AbstractJMSMessage |
JMSStreamMessageFactory.createMessage(AMQMessageDelegate delegate,
org.apache.mina.common.ByteBuffer data)
|
protected AbstractJMSMessage |
JMSTextMessageFactory.createMessage(AMQMessageDelegate delegate,
org.apache.mina.common.ByteBuffer data)
|
protected AbstractJMSMessage |
AMQPEncodedMapMessageFactory.createMessage(AMQMessageDelegate delegate,
org.apache.mina.common.ByteBuffer data)
|
AbstractJMSMessage |
MessageFactory.createMessage(AMQMessageDelegateFactory delegateFactory)
|
AbstractJMSMessage |
JMSBytesMessageFactory.createMessage(AMQMessageDelegateFactory delegateFactory)
|
AbstractJMSMessage |
JMSMapMessageFactory.createMessage(AMQMessageDelegateFactory delegateFactory)
|
AbstractJMSMessage |
JMSObjectMessageFactory.createMessage(AMQMessageDelegateFactory delegateFactory)
|
AbstractJMSMessage |
JMSStreamMessageFactory.createMessage(AMQMessageDelegateFactory delegateFactory)
|
AbstractJMSMessage |
JMSTextMessageFactory.createMessage(AMQMessageDelegateFactory delegateFactory)
|
AbstractJMSMessage |
AMQPEncodedMapMessageFactory.createMessage(AMQMessageDelegateFactory delegateFactory)
|
AbstractJMSMessage |
MessageFactoryRegistry.createMessage(AMQMessageDelegateFactory delegateFactory,
String mimeType)
|
AbstractJMSMessage |
MessageFactoryRegistry.createMessage(long deliveryTag,
boolean redelivered,
org.apache.qpid.framing.AMQShortString exchange,
org.apache.qpid.framing.AMQShortString routingKey,
org.apache.qpid.framing.ContentHeaderBody contentHeader,
List bodies)
Create a message. |
AbstractJMSMessage |
MessageFactory.createMessage(long deliveryTag,
boolean redelivered,
org.apache.qpid.framing.ContentHeaderBody contentHeader,
org.apache.qpid.framing.AMQShortString exchange,
org.apache.qpid.framing.AMQShortString routingKey,
List bodies)
|
AbstractJMSMessage |
AbstractJMSMessageFactory.createMessage(long messageNbr,
boolean redelivered,
org.apache.qpid.framing.ContentHeaderBody contentHeader,
org.apache.qpid.framing.AMQShortString exchange,
org.apache.qpid.framing.AMQShortString routingKey,
List bodies)
|
AbstractJMSMessage |
MessageFactory.createMessage(long deliveryTag,
boolean redelivered,
org.apache.qpid.transport.MessageProperties msgProps,
org.apache.qpid.transport.DeliveryProperties deliveryProps,
ByteBuffer body)
|
AbstractJMSMessage |
AbstractJMSMessageFactory.createMessage(long messageNbr,
boolean redelivered,
org.apache.qpid.transport.MessageProperties msgProps,
org.apache.qpid.transport.DeliveryProperties deliveryProps,
ByteBuffer body)
|
AbstractJMSMessage |
MessageFactoryRegistry.createMessage(org.apache.qpid.transport.MessageTransfer transfer)
|
AbstractJMSMessage |
MessageConverter.getConvertedMessage()
|