org.apache.qpid.client.message
Class MessageConverter

java.lang.Object
  extended by org.apache.qpid.client.message.MessageConverter

public class MessageConverter
extends Object


Field Summary
protected  org.slf4j.Logger _logger
          Log4J logger
 
Constructor Summary
MessageConverter(AbstractJMSMessage message)
           
MessageConverter(AMQSession session, BytesMessage bytesMessage)
           
MessageConverter(AMQSession session, MapMessage message)
           
MessageConverter(AMQSession session, Message message)
           
MessageConverter(AMQSession session, ObjectMessage origMessage)
           
MessageConverter(AMQSession session, StreamMessage message)
           
MessageConverter(AMQSession session, TextMessage message)
           
 
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
 

Field Detail

_logger

protected final org.slf4j.Logger _logger
Log4J logger

Constructor Detail

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
Method Detail

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