org.wso2.carbon.deployment.notifier.internal

Class JMSUtils

java.lang.Object

org.wso2.carbon.deployment.notifier.internal.JMSUtils

public class JMSUtils
extends Object

Miscallaneous methods used for the JMS transport. Borrowed generously from Apache Axi2 JMS implementation.

Constructor Summary

Constructors

Constructor and Description
JMSUtils()

Method Summary

Modifier and Type	Method and Description
static javax.jms.Connection	createConnection(javax.jms.ConnectionFactory conFac, String user, String pass, boolean jmsSpec11, Boolean isQueue, boolean isDurable, String clientID) This is a JMS spec independent method to create a Connection.
static javax.jms.MessageProducer	createProducer(javax.jms.Session session, javax.jms.Destination destination, Boolean isQueue, boolean jmsSpec11) This is a JMS spec independent method to create a MessageProducer.
static javax.jms.Session	createSession(javax.jms.Connection connection, boolean transacted, int ackMode, boolean jmsSpec11, Boolean isQueue) This is a JMS spec independent method to create a Session.
static <T> T	lookup(Context context, Class<T> clazz, String name)
static javax.jms.Destination	lookupDestination(Context context, String destinationName, String destinationType) Return the JMS destination with the given destination name looked up from the context.

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSUtils

public JMSUtils()

Method Detail

lookup

public static <T> T lookup(Context context,
                           Class<T> clazz,
                           String name)
                    throws NamingException

Throws:

NamingException

lookupDestination

public static javax.jms.Destination lookupDestination(Context context,
                                                      String destinationName,
                                                      String destinationType)
                                               throws NamingException

Return the JMS destination with the given destination name looked up from the context. Borrowed generiously from axis2 jms transport implementation

Parameters:

context - the Context to lookup

destinationName - name of the destination to be looked up

destinationType - type of the destination to be looked up

Returns:

the JMS destination, or null if it does not exist

Throws:

NamingException

createSession

public static javax.jms.Session createSession(javax.jms.Connection connection,
                                              boolean transacted,
                                              int ackMode,
                                              boolean jmsSpec11,
                                              Boolean isQueue)
                                       throws javax.jms.JMSException

This is a JMS spec independent method to create a Session. Please be cautious when making any changes

Parameters:

connection - the JMS Connection

transacted - should the session be transacted?

ackMode - the ACK mode for the session

jmsSpec11 - should we use the JMS 1.1 API?

isQueue - is this Session to deal with a Queue?

Returns:

a Session created for the given information

Throws:

javax.jms.JMSException - on errors, to be handled and logged by the caller

createConnection

public static javax.jms.Connection createConnection(javax.jms.ConnectionFactory conFac,
                                                    String user,
                                                    String pass,
                                                    boolean jmsSpec11,
                                                    Boolean isQueue,
                                                    boolean isDurable,
                                                    String clientID)
                                             throws javax.jms.JMSException

This is a JMS spec independent method to create a Connection. Please be cautious when making any changes

Parameters:

conFac - the ConnectionFactory to use

user - optional user name

pass - optional password

jmsSpec11 - should we use JMS 1.1 API ?

isQueue - is this to deal with a Queue?

Returns:

a JMS Connection as requested

Throws:

javax.jms.JMSException - on errors, to be handled and logged by the caller

createProducer

public static javax.jms.MessageProducer createProducer(javax.jms.Session session,
                                                       javax.jms.Destination destination,
                                                       Boolean isQueue,
                                                       boolean jmsSpec11)
                                                throws javax.jms.JMSException

This is a JMS spec independent method to create a MessageProducer. Please be cautious when making any changes

Parameters:

session - JMS session

destination - the Destination

isQueue - is the Destination a queue?

jmsSpec11 - should we use JMS 1.1 API ?

Returns:

a MessageProducer to send messages to the given Destination

Throws:

javax.jms.JMSException - on errors, to be handled and logged by the caller