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.JMSException
public 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.JMSException
public static void retrieveAndSetPayload(Message inMessage, javax.jms.Message message, String encoding) throws UnsupportedEncodingException
inMessage
- message
- the incoming messageencoding
- the message encodingUnsupportedEncodingException
public static void populateIncomingContext(javax.jms.Message message, Message inMessage, String messageType, JMSConfiguration jmsConfig) throws UnsupportedEncodingException
UnsupportedEncodingException
public 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.JMSException
public static void initResponseMessageProperties(JMSMessageHeadersType messageProperties, JMSMessageHeadersType inMessageProperties)
messageProperties
- inMessageProperties
- Apache CXF