org.apache.qpid.client.message
Class MessageConverter
java.lang.Object
org.apache.qpid.client.message.MessageConverter
public class MessageConverter
- extends Object
Field Summary |
protected org.slf4j.Logger |
_logger
Log4J logger |
Method Summary |
AbstractJMSMessage |
getConvertedMessage()
|
protected void |
setJMSProperties(Message message)
Exposed JMS defined properties on converted message:
JMSDestination - we don't set here
JMSDeliveryMode - set
JMSExpiration - we don't set here
JMSPriority - we don't set here
JMSMessageID - we don't set here
JMSTimestamp - we don't set here
JMSCorrelationID - set
JMSReplyTo - set
JMSType - set
JMSRedlivered - we don't set here |
protected void |
setMessageProperties(Message message)
Sets all message properties |
protected void |
setNonJMSProperties(Message message)
Sets all non-JMS defined properties on converted message |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_logger
protected final org.slf4j.Logger _logger
- Log4J logger
MessageConverter
public MessageConverter(AbstractJMSMessage message)
throws JMSException
- Throws:
JMSException
MessageConverter
public MessageConverter(AMQSession session,
BytesMessage bytesMessage)
throws JMSException
- Throws:
JMSException
MessageConverter
public MessageConverter(AMQSession session,
MapMessage message)
throws JMSException
- Throws:
JMSException
MessageConverter
public MessageConverter(AMQSession session,
ObjectMessage origMessage)
throws JMSException
- Throws:
JMSException
MessageConverter
public MessageConverter(AMQSession session,
TextMessage message)
throws JMSException
- Throws:
JMSException
MessageConverter
public MessageConverter(AMQSession session,
StreamMessage message)
throws JMSException
- Throws:
JMSException
MessageConverter
public MessageConverter(AMQSession session,
Message message)
throws JMSException
- Throws:
JMSException
getConvertedMessage
public AbstractJMSMessage getConvertedMessage()
setMessageProperties
protected void setMessageProperties(Message message)
throws JMSException
- Sets all message properties
- Throws:
JMSException
setNonJMSProperties
protected void setNonJMSProperties(Message message)
throws JMSException
- Sets all non-JMS defined properties on converted message
- Throws:
JMSException
setJMSProperties
protected void setJMSProperties(Message message)
throws JMSException
- Exposed JMS defined properties on converted message:
JMSDestination - we don't set here
JMSDeliveryMode - set
JMSExpiration - we don't set here
JMSPriority - we don't set here
JMSMessageID - we don't set here
JMSTimestamp - we don't set here
JMSCorrelationID - set
JMSReplyTo - set
JMSType - set
JMSRedlivered - we don't set here
- Throws:
JMSException
Licensed to the Apache Software Foundation