org.wso2.carbon.deployment.notifier.internal

Class JMSConnectionFactory

java.lang.Object

org.wso2.carbon.deployment.notifier.internal.JMSConnectionFactory

public class JMSConnectionFactory
extends Object

Encapsulate a JMS Connection factory.

JMS Connection Factory definitions, allows JNDI properties as well as other service level parameters to be defined, and re-used by each service that binds to it

When used for sending messages out, the JMSConnectionFactory'ies are able to cache a Connection, Session or Producer

Borrowed generously from Apache Axi2 JMS implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JMSConnectionFactory.JMSPooledConnectionHolder Holder class for connections and its session/producer.

Constructor Summary

Constructors

Constructor and Description
JMSConnectionFactory(Hashtable<String,String> parameters, String name, String destination) Digest a JMS CF definition and construct.
JMSConnectionFactory(Hashtable<String,String> parameters, String name, String destination, int maxConcurrentConnections) Digest a JMS CF definition 'Parameter' and construct.

Method Summary

Modifier and Type	Method and Description
void	close()
javax.jms.Connection	createConnection()
JMSConnectionFactory.JMSPooledConnectionHolder	getConnectionFromPool()
Context	getContext() Get cached InitialContext.
javax.jms.Destination	getDestination() Lookup a Destination using this JMS CF definitions and JNDI name.
boolean	isJmsSpec11() Should the JMS 1.1 API be used? - defaults to yes
Boolean	isQueue() Return the type of the JMS CF Destination.
void	returnPooledConnection(JMSConnectionFactory.JMSPooledConnectionHolder pooledConnection)

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSConnectionFactory

public JMSConnectionFactory(Hashtable<String,String> parameters,
                            String name,
                            String destination)

Digest a JMS CF definition and construct. Set max concurrent connections to be 5 if unspecified.

JMSConnectionFactory

public JMSConnectionFactory(Hashtable<String,String> parameters,
                            String name,
                            String destination,
                            int maxConcurrentConnections)

Digest a JMS CF definition 'Parameter' and construct.

Method Detail

returnPooledConnection

public void returnPooledConnection(JMSConnectionFactory.JMSPooledConnectionHolder pooledConnection)

getContext

public Context getContext()

Get cached InitialContext.

Returns:

cache InitialContext

getDestination

public javax.jms.Destination getDestination()

Lookup a Destination using this JMS CF definitions and JNDI name.

Returns:

JMS Destination for the given JNDI name or null

isJmsSpec11

public boolean isJmsSpec11()

Should the JMS 1.1 API be used? - defaults to yes

Returns:

true, if JMS 1.1 api should be used

isQueue

public Boolean isQueue()

Return the type of the JMS CF Destination.

Returns:

TRUE if a Queue, FALSE for a Topic and NULL for a JMS 1.1 Generic Destination

createConnection

public javax.jms.Connection createConnection()

getConnectionFromPool

public JMSConnectionFactory.JMSPooledConnectionHolder getConnectionFromPool()

close

public void close()