org.mule.transport.jms

Class JmsMessageUtils

java.lang.Object

org.mule.transport.jms.JmsMessageUtils

public class JmsMessageUtils
extends Object

JmsMessageUtils contains helper method for dealing with JMS messages in Mule.

Field Summary

Fields

Modifier and Type	Field and Description
static char	REPLACEMENT_CHAR

Constructor Summary

Constructors

Constructor and Description
JmsMessageUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static javax.jms.Message	copyJMSProperties(javax.jms.Message from, javax.jms.Message to, JmsConnector connector)
static String	encodeHeader(String name) Encode a String so that is is a valid JMS header name
static String	getNameForDestination(javax.jms.Destination dest)
static byte[]	toByteArray(javax.jms.Message message, String jmsSpec)
static javax.jms.Message	toMessage(Object object, javax.jms.Session session)
static Object	toObject(javax.jms.Message source, String jmsSpec)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

REPLACEMENT_CHAR

public static final char REPLACEMENT_CHAR

See Also:

Constant Field Values

Constructor Detail

JmsMessageUtils

public JmsMessageUtils()

Method Detail

encodeHeader

public static String encodeHeader(String name)

Encode a String so that is is a valid JMS header name

Parameters:

name - the String to encode

Returns:

a valid JMS header name

toMessage

public static javax.jms.Message toMessage(Object object,
                          javax.jms.Session session)
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

toObject

public static Object toObject(javax.jms.Message source,
              String jmsSpec)
                       throws javax.jms.JMSException,
                              IOException

Throws:

javax.jms.JMSException

IOException

toByteArray

public static byte[] toByteArray(javax.jms.Message message,
                 String jmsSpec)
                          throws javax.jms.JMSException,
                                 IOException

Parameters:

message - the message to receive the bytes from. Note this only works for TextMessge, ObjectMessage, StreamMessage and BytesMessage.

jmsSpec - indicates the JMS API version, either JmsConstants.JMS_SPECIFICATION_102B or JmsConstants.JMS_SPECIFICATION_11. Any other value including null is treated as fallback to JmsConstants.JMS_SPECIFICATION_102B.

Returns:

a byte array corresponding with the message payload

Throws:

javax.jms.JMSException - if the message can't be read or if the message passed is a MapMessage

IOException - if a failure occurs while reading the stream and converting the message data

getNameForDestination

public static String getNameForDestination(javax.jms.Destination dest)
                                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

copyJMSProperties

public static javax.jms.Message copyJMSProperties(javax.jms.Message from,
                                  javax.jms.Message to,
                                  JmsConnector connector)
                                           throws javax.jms.JMSException

Throws:

javax.jms.JMSException