org.apache.qpid.client.message
Class AbstractJMSMessageFactory
java.lang.Object
org.apache.qpid.client.message.AbstractJMSMessageFactory
- All Implemented Interfaces:
- MessageFactory
- Direct Known Subclasses:
- AMQPEncodedMapMessageFactory, JMSBytesMessageFactory, JMSMapMessageFactory, JMSObjectMessageFactory, JMSStreamMessageFactory, JMSTextMessageFactory
public abstract class AbstractJMSMessageFactory
- extends Object
- implements MessageFactory
Method Summary |
protected AbstractJMSMessage |
create010MessageWithBody(long messageNbr,
org.apache.qpid.transport.MessageProperties msgProps,
org.apache.qpid.transport.DeliveryProperties deliveryProps,
ByteBuffer body)
|
protected AbstractJMSMessage |
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 |
createMessage(AMQMessageDelegate delegate,
org.apache.mina.common.ByteBuffer data)
|
AbstractJMSMessage |
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 |
createMessage(long messageNbr,
boolean redelivered,
org.apache.qpid.transport.MessageProperties msgProps,
org.apache.qpid.transport.DeliveryProperties deliveryProps,
ByteBuffer body)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AbstractJMSMessageFactory
public AbstractJMSMessageFactory()
create08MessageWithBody
protected AbstractJMSMessage create08MessageWithBody(long messageNbr,
org.apache.qpid.framing.ContentHeaderBody contentHeader,
org.apache.qpid.framing.AMQShortString exchange,
org.apache.qpid.framing.AMQShortString routingKey,
List bodies)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
createMessage
protected abstract AbstractJMSMessage createMessage(AMQMessageDelegate delegate,
org.apache.mina.common.ByteBuffer data)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
create010MessageWithBody
protected AbstractJMSMessage create010MessageWithBody(long messageNbr,
org.apache.qpid.transport.MessageProperties msgProps,
org.apache.qpid.transport.DeliveryProperties deliveryProps,
ByteBuffer body)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
createMessage
public AbstractJMSMessage 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)
throws JMSException,
org.apache.qpid.AMQException
- Specified by:
createMessage
in interface MessageFactory
- Throws:
JMSException
org.apache.qpid.AMQException
createMessage
public AbstractJMSMessage createMessage(long messageNbr,
boolean redelivered,
org.apache.qpid.transport.MessageProperties msgProps,
org.apache.qpid.transport.DeliveryProperties deliveryProps,
ByteBuffer body)
throws JMSException,
org.apache.qpid.AMQException
- Specified by:
createMessage
in interface MessageFactory
- Throws:
JMSException
org.apache.qpid.AMQException
Licensed to the Apache Software Foundation