org.mule.transport.jms.integration.activemq
Class ActiveMQTestReconnectionConnectionFactoryWrapper

java.lang.Object
  org.apache.activemq.jndi.JNDIBaseStorable
      org.apache.activemq.ActiveMQConnectionFactory
          org.mule.transport.jms.integration.activemq.ActiveMQTestReconnectionConnectionFactoryWrapper

All Implemented Interfaces:

Externalizable, Serializable, Cloneable, InvocationHandler, ConnectionFactory, QueueConnectionFactory, TopicConnectionFactory, Referenceable, org.apache.activemq.jndi.JNDIStorableInterface, org.apache.activemq.management.StatsCapable, TestReconnectionConnectionFactoryWrapper, TargetInvocationHandler

public class ActiveMQTestReconnectionConnectionFactoryWrapper
extends org.apache.activemq.ActiveMQConnectionFactory
implements TargetInvocationHandler, TestReconnectionConnectionFactoryWrapper

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.activemq.ActiveMQConnectionFactory

alwaysSessionAsync, brokerURL, clientID, DEFAULT_BROKER_BIND_URL, DEFAULT_BROKER_URL, DEFAULT_CONNECTION_EXECUTOR, DEFAULT_PASSWORD, DEFAULT_PRODUCER_WINDOW_SIZE, DEFAULT_USER, dispatchAsync, password, userName

Constructor Summary

ActiveMQTestReconnectionConnectionFactoryWrapper()

ActiveMQTestReconnectionConnectionFactoryWrapper(String brokerURL)

ActiveMQTestReconnectionConnectionFactoryWrapper(String userName, String password, String brokerURL)

ActiveMQTestReconnectionConnectionFactoryWrapper(String userName, String password, URI brokerURL)

ActiveMQTestReconnectionConnectionFactoryWrapper(URI brokerURL)

Method Summary

void	closeConnection()
QueueConnection	createQueueConnection()
QueueConnection	createQueueConnection(String userName, String password)
TopicConnection	createTopicConnection()
TopicConnection	createTopicConnection(String userName, String password)
List	getCalledMethods()
Object	getTargetObject()
void	init()
Object	invoke(Object proxy, Method method, Object[] args)
boolean	isEnabled()
void	setEnabled(boolean enabled)

Methods inherited from class org.apache.activemq.ActiveMQConnectionFactory

buildFromMap, buildFromProperties, configureConnection, copy, createActiveMQConnection, createActiveMQConnection, createActiveMQConnection, createConnection, createConnection, createTransport, getAuditDepth, getAuditMaximumProducerNumber, getBlobTransferPolicy, getBrokerURL, getClientID, getClientIdGenerator, getClientIDPrefix, getClientInternalExceptionListener, getCloseTimeout, getConsumerFailoverRedeliveryWaitPeriod, getExceptionListener, getPassword, getPrefetchPolicy, getProducerWindowSize, getRedeliveryPolicy, getSendTimeout, getStats, getTransformer, getTransportListener, getUserName, getWarnAboutUnstartedConnectionTimeout, isAlwaysSessionAsync, isAlwaysSyncSend, isCheckForDuplicates, isCopyMessageOnSend, isDisableTimeStampsByDefault, isDispatchAsync, isExclusiveConsumer, isMessagePrioritySupported, isNestedMapAndListEnabled, isObjectMessageSerializationDefered, isOptimizeAcknowledge, isOptimizedMessageDispatch, isSendAcksAsync, isStatsEnabled, isUseAsyncSend, isUseCompression, isUseDedicatedTaskRunner, isUseRetroactiveConsumer, isWatchTopicAdvisories, populateProperties, setAlwaysSessionAsync, setAlwaysSyncSend, setAuditDepth, setAuditMaximumProducerNumber, setBlobTransferPolicy, setBrokerURL, setCheckForDuplicates, setClientID, setClientIdGenerator, setClientIDPrefix, setClientInternalExceptionListener, setCloseTimeout, setConsumerFailoverRedeliveryWaitPeriod, setCopyMessageOnSend, setDisableTimeStampsByDefault, setDispatchAsync, setExceptionListener, setExclusiveConsumer, setMessagePrioritySupported, setNestedMapAndListEnabled, setObjectMessageSerializationDefered, setOptimizeAcknowledge, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setProducerWindowSize, setRedeliveryPolicy, setSendAcksAsync, setSendTimeout, setStatsEnabled, setTransformer, setTransportListener, setUseAsyncSend, setUseCompression, setUseDedicatedTaskRunner, setUseRetroactiveConsumer, setUserName, setWarnAboutUnstartedConnectionTimeout, setWatchTopicAdvisories

Methods inherited from class org.apache.activemq.jndi.JNDIBaseStorable

getProperties, getReference, readExternal, setProperties, writeExternal

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.ConnectionFactory

createConnection, createConnection

Constructor Detail

ActiveMQTestReconnectionConnectionFactoryWrapper

public ActiveMQTestReconnectionConnectionFactoryWrapper()

ActiveMQTestReconnectionConnectionFactoryWrapper

public ActiveMQTestReconnectionConnectionFactoryWrapper(String brokerURL)

ActiveMQTestReconnectionConnectionFactoryWrapper

public ActiveMQTestReconnectionConnectionFactoryWrapper(URI brokerURL)

ActiveMQTestReconnectionConnectionFactoryWrapper

public ActiveMQTestReconnectionConnectionFactoryWrapper(String userName,
                                                        String password,
                                                        URI brokerURL)

ActiveMQTestReconnectionConnectionFactoryWrapper

public ActiveMQTestReconnectionConnectionFactoryWrapper(String userName,
                                                        String password,
                                                        String brokerURL)

Method Detail

init

public void init()

Specified by:

init in interface TestReconnectionConnectionFactoryWrapper

createQueueConnection

public QueueConnection createQueueConnection()
                                      throws JMSException

Specified by:

createQueueConnection in interface QueueConnectionFactory

Overrides:

createQueueConnection in class org.apache.activemq.ActiveMQConnectionFactory

Throws:

JMSException

createQueueConnection

public QueueConnection createQueueConnection(String userName,
                                             String password)
                                      throws JMSException

Specified by:

createQueueConnection in interface QueueConnectionFactory

Overrides:

createQueueConnection in class org.apache.activemq.ActiveMQConnectionFactory

Throws:

JMSException

createTopicConnection

public TopicConnection createTopicConnection()
                                      throws JMSException

Specified by:

createTopicConnection in interface TopicConnectionFactory

Overrides:

createTopicConnection in class org.apache.activemq.ActiveMQConnectionFactory

Throws:

JMSException

createTopicConnection

public TopicConnection createTopicConnection(String userName,
                                             String password)
                                      throws JMSException

Specified by:

createTopicConnection in interface TopicConnectionFactory

Overrides:

createTopicConnection in class org.apache.activemq.ActiveMQConnectionFactory

Throws:

JMSException

invoke

public Object invoke(Object proxy,
                     Method method,
                     Object[] args)
              throws Throwable

Specified by:

invoke in interface InvocationHandler

Specified by:

invoke in interface TestReconnectionConnectionFactoryWrapper

Throws:

Throwable

getTargetObject

public Object getTargetObject()

Specified by:

getTargetObject in interface TestReconnectionConnectionFactoryWrapper

Specified by:

getTargetObject in interface TargetInvocationHandler

getCalledMethods

public List getCalledMethods()

Specified by:

getCalledMethods in interface TestReconnectionConnectionFactoryWrapper

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface TestReconnectionConnectionFactoryWrapper

setEnabled

public void setEnabled(boolean enabled)

Specified by:

setEnabled in interface TestReconnectionConnectionFactoryWrapper

closeConnection

public void closeConnection()

Specified by:

closeConnection in interface TestReconnectionConnectionFactoryWrapper