public final class JMSUtils extends Object
| Modifier and Type | Method and Description |
|---|---|
static void |
addContentTypeToProtocolHeader(Message message) |
static javax.jms.Message |
buildJMSMessageFromCXFMessage(JMSConfiguration jmsConfig,
Message outMessage,
Object payload,
String messageType,
javax.jms.Session session,
javax.jms.Destination replyTo,
String correlationId) |
static javax.jms.Message |
createAndSetPayload(Object payload,
javax.jms.Session session,
String messageType)
Create a JMS of the appropriate type populated with the given payload.
|
static String |
createCorrelationId(String prefix,
long i) |
static String |
getContentEncoding(Message message) |
static String |
getContentType(Message message) |
static long |
getTimeToLive(JMSMessageHeadersType headers) |
static void |
initResponseMessageProperties(JMSMessageHeadersType messageProperties,
JMSMessageHeadersType inMessageProperties) |
static void |
populateIncomingContext(javax.jms.Message message,
Message inMessage,
String messageType,
JMSConfiguration jmsConfig) |
static void |
retrieveAndSetPayload(Message inMessage,
javax.jms.Message message,
String encoding)
Extract the payload of an incoming message.
|
static void |
setMessageProperties(JMSMessageHeadersType headers,
javax.jms.Message message) |
public static long getTimeToLive(JMSMessageHeadersType headers)
public static void setMessageProperties(JMSMessageHeadersType headers, javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSExceptionpublic static javax.jms.Message createAndSetPayload(Object payload, javax.jms.Session session, String messageType) throws javax.jms.JMSException
payload - the message payload, expected to be either of type String or byte[] depending on payload
typesession - the JMS sessionreplyTo - the ReplyTo destination if anyjavax.jms.JMSExceptionpublic static void retrieveAndSetPayload(Message inMessage, javax.jms.Message message, String encoding) throws UnsupportedEncodingException
inMessage - message - the incoming messageencoding - the message encodingUnsupportedEncodingExceptionpublic static void populateIncomingContext(javax.jms.Message message,
Message inMessage,
String messageType,
JMSConfiguration jmsConfig)
throws UnsupportedEncodingException
UnsupportedEncodingExceptionpublic static void addContentTypeToProtocolHeader(Message message)
public static javax.jms.Message buildJMSMessageFromCXFMessage(JMSConfiguration jmsConfig, Message outMessage, Object payload, String messageType, javax.jms.Session session, javax.jms.Destination replyTo, String correlationId) throws javax.jms.JMSException
javax.jms.JMSExceptionpublic static void initResponseMessageProperties(JMSMessageHeadersType messageProperties, JMSMessageHeadersType inMessageProperties)
messageProperties - inMessageProperties - Apache CXF