public class MessageConverter extends Object
Constructor and Description |
---|
MessageConverter(AbstractJMSMessage message) |
MessageConverter(AMQSession session,
javax.jms.BytesMessage bytesMessage) |
MessageConverter(AMQSession session,
javax.jms.MapMessage message) |
MessageConverter(AMQSession session,
javax.jms.Message message) |
MessageConverter(AMQSession session,
javax.jms.ObjectMessage origMessage) |
MessageConverter(AMQSession session,
javax.jms.StreamMessage message) |
MessageConverter(AMQSession session,
javax.jms.TextMessage message) |
Modifier and Type | Method and Description |
---|---|
AbstractJMSMessage |
getConvertedMessage() |
protected void |
setJMSProperties(javax.jms.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(javax.jms.Message message)
Sets all message properties
|
protected void |
setNonJMSProperties(javax.jms.Message message)
Sets all non-JMS defined properties on converted message
|
public MessageConverter(AbstractJMSMessage message) throws javax.jms.JMSException
javax.jms.JMSException
public MessageConverter(AMQSession session, javax.jms.BytesMessage bytesMessage) throws javax.jms.JMSException
javax.jms.JMSException
public MessageConverter(AMQSession session, javax.jms.MapMessage message) throws javax.jms.JMSException
javax.jms.JMSException
public MessageConverter(AMQSession session, javax.jms.ObjectMessage origMessage) throws javax.jms.JMSException
javax.jms.JMSException
public MessageConverter(AMQSession session, javax.jms.TextMessage message) throws javax.jms.JMSException
javax.jms.JMSException
public MessageConverter(AMQSession session, javax.jms.StreamMessage message) throws javax.jms.JMSException
javax.jms.JMSException
public MessageConverter(AMQSession session, javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
public AbstractJMSMessage getConvertedMessage()
protected void setMessageProperties(javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
protected void setNonJMSProperties(javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
protected void setJMSProperties(javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.