org.mule.transport.jms

Class CustomCachingConnectionFactory

java.lang.Object

org.springframework.jms.connection.SingleConnectionFactory

org.springframework.jms.connection.CachingConnectionFactory

org.mule.transport.jms.CustomCachingConnectionFactory

All Implemented Interfaces:

ConnectionFactory, ExceptionListener, QueueConnectionFactory, TopicConnectionFactory, Closeable, Disposable, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class CustomCachingConnectionFactory
extends org.springframework.jms.connection.CachingConnectionFactory
implements Closeable, Disposable

Field Summary

Fields inherited from class org.springframework.jms.connection.SingleConnectionFactory

logger

Fields inherited from interface org.mule.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
CustomCachingConnectionFactory(ConnectionFactory targetConnectionFactory, String username, String password)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the resource.
Connection	createConnection(String username, String password)
void	dispose() A lifecycle method where implementor should free up any resources.
protected Connection	doCreateConnection()
String	getPassword()
String	getUsername()

Methods inherited from class org.springframework.jms.connection.CachingConnectionFactory

getCachedSessionProxy, getSession, getSessionCacheSize, isCacheConsumers, isCacheProducers, resetConnection, setCacheConsumers, setCacheProducers, setSessionCacheSize

Methods inherited from class org.springframework.jms.connection.SingleConnectionFactory

afterPropertiesSet, closeConnection, createConnection, createQueueConnection, createQueueConnection, createSession, createTopicConnection, createTopicConnection, destroy, getClientId, getConnection, getExceptionListener, getSharedConnectionProxy, getTargetConnectionFactory, initConnection, isReconnectOnException, onException, prepareConnection, setClientId, setExceptionListener, setReconnectOnException, setTargetConnectionFactory

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomCachingConnectionFactory

public CustomCachingConnectionFactory(ConnectionFactory targetConnectionFactory,
                              String username,
                              String password)

Method Detail

createConnection

public Connection createConnection(String username,
                          String password)
                            throws JMSException

Specified by:

createConnection in interface ConnectionFactory

Overrides:

createConnection in class org.springframework.jms.connection.SingleConnectionFactory

Throws:

JMSException

doCreateConnection

protected Connection doCreateConnection()
                                 throws JMSException

Overrides:

doCreateConnection in class org.springframework.jms.connection.SingleConnectionFactory

Throws:

JMSException

getUsername

public String getUsername()

getPassword

public String getPassword()

close

public void close()
           throws MuleException

Description copied from interface: Closeable

Closes the resource. Calling this method is mandatory for any component using this instance once it finishes using it. This method should not throw exception is invoked on an instance that has already been closed

Specified by:

close in interface Closeable

Throws:

MuleException - if an exception occurs closing the resource

dispose

public void dispose()

Description copied from interface: Disposable

A lifecycle method where implementor should free up any resources. If an exception is thrown it should just be logged and processing should continue. This method should not throw Runtime exceptions.

Specified by:

dispose in interface Disposable