com.cognifide.aet.queues

Class JmsUtils

java.lang.Object

com.cognifide.aet.queues.JmsUtils

public final class JmsUtils
extends Object

General JMS manipulation utilities

Author:

lukasz.wieczorek

Method Summary

Modifier and Type	Method and Description
static void	closeQuietly(javax.jms.Connection connection) Closes a Connection ignoring nulls and exceptions
static void	closeQuietly(javax.jms.MessageConsumer messageConsumer) Closes a MessageConsumer ignoring nulls and exceptions
static void	closeQuietly(javax.jms.MessageProducer messageProducer) Closes a MessageProducer ignoring nulls and exceptions
static void	closeQuietly(javax.jms.Session session) Closes a Session ignoring nulls and exceptions
static <T> T	getFromMessage(javax.jms.Message message, Class<T> tClass)
static String	getJMSCorrelationID(javax.jms.Message message)
static String	getJMSMessageID(javax.jms.Message message)

Methods inherited from class java.lang.Object

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

Method Detail

closeQuietly

public static void closeQuietly(javax.jms.MessageProducer messageProducer)

Closes a MessageProducer ignoring nulls and exceptions

Parameters:

messageProducer - - a MessageProducer to close.

closeQuietly

public static void closeQuietly(javax.jms.MessageConsumer messageConsumer)

Closes a MessageConsumer ignoring nulls and exceptions

Parameters:

messageConsumer - - a MessageConsumer to close.

closeQuietly

public static void closeQuietly(javax.jms.Session session)

Closes a Session ignoring nulls and exceptions

Parameters:

session - - a Session to close.

closeQuietly

public static void closeQuietly(javax.jms.Connection connection)

Closes a Connection ignoring nulls and exceptions

Parameters:

connection - - a Connection to close.

getFromMessage

public static <T> T getFromMessage(javax.jms.Message message,
                                   Class<T> tClass)
                            throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getJMSCorrelationID

public static String getJMSCorrelationID(javax.jms.Message message)

getJMSMessageID

public static String getJMSMessageID(javax.jms.Message message)