org.apache.cxf.transport.jms
Class JMSUtils

java.lang.Object
  extended by org.apache.cxf.transport.jms.JMSUtils

public final class JMSUtils
extends java.lang.Object


Method Summary
static void addContentTypeToProtocolHeader(Message message)
           
protected static void addProtocolHeaders(javax.jms.Message message, java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers)
           
static javax.jms.Message buildJMSMessageFromCXFMessage(Message outMessage, java.lang.Object payload, java.lang.String messageType, javax.jms.Session session, javax.jms.Destination replyTo, java.lang.String correlationId)
           
static javax.jms.Message createAndSetPayload(java.lang.Object payload, javax.jms.Session session, java.lang.String messageType)
          Create a JMS of the appropriate type populated with the given payload.
static java.lang.String createCorrelationId(java.lang.String prefix, long i)
           
static long getTimeToLive(org.apache.cxf.transport.jms.JMSMessageHeadersType headers)
           
static void populateIncomingContext(javax.jms.Message message, Message inMessage, java.lang.String headerType)
           
static byte[] retrievePayload(javax.jms.Message message, java.lang.String encoding)
          Extract the payload of an incoming message.
static void setMessageProperties(org.apache.cxf.transport.jms.JMSMessageHeadersType headers, javax.jms.Message message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getTimeToLive

public static long getTimeToLive(org.apache.cxf.transport.jms.JMSMessageHeadersType headers)

setMessageProperties

public static void setMessageProperties(org.apache.cxf.transport.jms.JMSMessageHeadersType headers,
                                        javax.jms.Message message)
                                 throws javax.jms.JMSException
Throws:
javax.jms.JMSException

createAndSetPayload

public static javax.jms.Message createAndSetPayload(java.lang.Object payload,
                                                    javax.jms.Session session,
                                                    java.lang.String messageType)
                                             throws javax.jms.JMSException
Create a JMS of the appropriate type populated with the given payload.

Parameters:
payload - the message payload, expected to be either of type String or byte[] depending on payload type
session - the JMS session
replyTo - the ReplyTo destination if any
Returns:
a JMS of the appropriate type populated with the given payload
Throws:
javax.jms.JMSException

retrievePayload

public static byte[] retrievePayload(javax.jms.Message message,
                                     java.lang.String encoding)
                              throws java.io.UnsupportedEncodingException
Extract the payload of an incoming message.

Parameters:
message - the incoming message
encoding - the message encoding
Returns:
the message payload as byte[]
Throws:
java.io.UnsupportedEncodingException

populateIncomingContext

public static void populateIncomingContext(javax.jms.Message message,
                                           Message inMessage,
                                           java.lang.String headerType)
                                    throws java.io.UnsupportedEncodingException
Throws:
java.io.UnsupportedEncodingException

addProtocolHeaders

protected static void addProtocolHeaders(javax.jms.Message message,
                                         java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers)
                                  throws javax.jms.JMSException
Throws:
javax.jms.JMSException

addContentTypeToProtocolHeader

public static void addContentTypeToProtocolHeader(Message message)

buildJMSMessageFromCXFMessage

public static javax.jms.Message buildJMSMessageFromCXFMessage(Message outMessage,
                                                              java.lang.Object payload,
                                                              java.lang.String messageType,
                                                              javax.jms.Session session,
                                                              javax.jms.Destination replyTo,
                                                              java.lang.String correlationId)
                                                       throws javax.jms.JMSException
Throws:
javax.jms.JMSException

createCorrelationId

public static java.lang.String createCorrelationId(java.lang.String prefix,
                                                   long i)


Apache CXF