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_PASSWORD, DEFAULT_PRODUCER_WINDOW_SIZE, DEFAULT_USER, dispatchAsync, password, userName, xaAckMode

Constructor Summary

Constructors

Constructor and Description
ActiveMQTestReconnectionConnectionFactoryWrapper()
ActiveMQTestReconnectionConnectionFactoryWrapper(String brokerURL)
ActiveMQTestReconnectionConnectionFactoryWrapper(String userName, String password, String brokerURL)
ActiveMQTestReconnectionConnectionFactoryWrapper(String userName, String password, URI brokerURL)
ActiveMQTestReconnectionConnectionFactoryWrapper(URI brokerURL)

Method Summary

Methods

Modifier and Type	Method and Description
void	closeConnection()
QueueConnection	createQueueConnection()
QueueConnection	createQueueConnection(String user, String passwd)
TopicConnection	createTopicConnection()
TopicConnection	createTopicConnection(String user, String passwd)
List<Object>	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, getConnectionIdGenerator, getConsumerFailoverRedeliveryWaitPeriod, getExceptionListener, getMaxThreadPoolSize, getOptimizeAcknowledgeTimeOut, getOptimizedAckScheduledAckInterval, getPassword, getPrefetchPolicy, getProducerWindowSize, getRedeliveryPolicy, getRedeliveryPolicyMap, getRejectedTaskHandler, getSendTimeout, getSessionTaskRunner, getStats, getTransformer, getTransportListener, getUserName, getWarnAboutUnstartedConnectionTimeout, isAlwaysSessionAsync, isAlwaysSyncSend, isCheckForDuplicates, isConsumerExpiryCheckEnabled, isCopyMessageOnSend, isDisableTimeStampsByDefault, isDispatchAsync, isExclusiveConsumer, isMessagePrioritySupported, isNestedMapAndListEnabled, isNonBlockingRedelivery, isObjectMessageSerializationDefered, isOptimizeAcknowledge, isOptimizedMessageDispatch, isRmIdFromConnectionId, isSendAcksAsync, isStatsEnabled, isTransactedIndividualAck, isUseAsyncSend, isUseCompression, isUseDedicatedTaskRunner, isUseRetroactiveConsumer, isWatchTopicAdvisories, populateProperties, setAlwaysSessionAsync, setAlwaysSyncSend, setAuditDepth, setAuditMaximumProducerNumber, setBlobTransferPolicy, setBrokerURL, setCheckForDuplicates, setClientID, setClientIdGenerator, setClientIDPrefix, setClientInternalExceptionListener, setCloseTimeout, setConnectionIdGenerator, setConnectionIDPrefix, setConsumerExpiryCheckEnabled, setConsumerFailoverRedeliveryWaitPeriod, setCopyMessageOnSend, setDisableTimeStampsByDefault, setDispatchAsync, setExceptionListener, setExclusiveConsumer, setMaxThreadPoolSize, setMessagePrioritySupported, setNestedMapAndListEnabled, setNonBlockingRedelivery, setObjectMessageSerializationDefered, setOptimizeAcknowledge, setOptimizeAcknowledgeTimeOut, setOptimizedAckScheduledAckInterval, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setProducerWindowSize, setRedeliveryPolicy, setRedeliveryPolicyMap, setRejectedTaskHandler, setRmIdFromConnectionId, setSendAcksAsync, setSendTimeout, setSessionTaskRunner, setStatsEnabled, setTransactedIndividualAck, 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 user,
                                    String passwd)
                                      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 user,
                                    String passwd)
                                      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<Object> 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