org.apache.cxf.transport.jms
Class JMSUtils
java.lang.Object
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 |
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
typesession
- the JMS sessionreplyTo
- 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 messageencoding
- 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