org.mule.transport.jms.activemq

Class ActiveMQJmsConnector

java.lang.Object

org.mule.transport.AbstractConnector

org.mule.transport.jms.JmsConnector

org.mule.transport.jms.activemq.ActiveMQJmsConnector

All Implemented Interfaces:

ExceptionListener, EventListener, javax.resource.spi.work.WorkListener, MuleContextAware, ConnectionNotificationListener, ServerNotificationListener, Disposable, Initialisable, Lifecycle, Startable, Stoppable, NamedObject, Connectable, Connector

Direct Known Subclasses:

ActiveMQXAJmsConnector

public class ActiveMQJmsConnector
extends JmsConnector

ActiveMQ 4.x-specific JMS connector.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTIVEMQ_CONNECTION_FACTORY_CLASS
static String	DEFAULT_BROKER_URL

Fields inherited from class org.mule.transport.jms.JmsConnector

JMS, password, username

Fields inherited from class org.mule.transport.AbstractConnector

connected, connectedSemaphore, connecting, connectionStrategy, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, muleContext, name, numberOfConcurrentTransactedReceivers, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, started, startOnConnect

Fields inherited from interface org.mule.api.transport.Connector

INT_VALUE_NOT_SET

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

PHASE_NAME

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

PHASE_NAME

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

PHASE_NAME

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

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
ActiveMQJmsConnector() Constructs a new ActiveMQJmsConnector.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	applyVendorSpecificConnectionFactoryProperties(javax.jms.ConnectionFactory connectionFactory)
protected void	doDisconnect() Will additionally try to cleanup the ActiveMq connection, otherwise there's a deadlock on shutdown.
String	getBrokerURL()
protected javax.jms.ConnectionFactory	getDefaultConnectionFactory() Override this method to provide a default ConnectionFactory for a vendor-specific JMS Connector.
void	setBrokerURL(String brokerURL)

Methods inherited from class org.mule.transport.jms.JmsConnector

close, close, close, close, close, closeQuietly, closeQuietly, closeQuietly, closeQuietly, closeQuietly, createConnection, doConnect, doDispose, doInitialise, doStart, doStop, getAcknowledgementMode, getClientId, getConnection, getConnectionFactory, getConnectionStrategy, getJmsSupport, getMaxRedelivery, getMessageAdapter, getPassword, getProtocol, getReceiverKey, getRedeliveryHandlerFactory, getReplyToHandler, getSession, getSession, getSessionFromTransaction, getSpecification, getTopicResolver, getUsername, isCacheJmsSessions, isDurable, isEagerConsumer, isHonorQosHeaders, isNoLocal, isPersistentDelivery, isRecoverJmsConnections, isRemoteSyncEnabled, onNotification, preProcessMessage, setAcknowledgementMode, setCacheJmsSessions, setClientId, setConnection, setConnectionFactory, setDurable, setEagerConsumer, setHonorQosHeaders, setJmsSupport, setMaxRedelivery, setNoLocal, setPassword, setPersistentDelivery, setRecoverJmsConnections, setRedeliveryHandlerFactory, setSpecification, setTopicResolver, setUsername, supportsProperty

Methods inherited from class org.mule.transport.AbstractConnector

checkDisposed, connect, createReceiver, destroyReceiver, disconnect, dispatch, dispose, disposeDispatchers, disposeReceivers, disposeRequesters, disposeWorkManagers, exceptionThrown, fireNotification, getConnectedSemaphore, getConnectEventId, getConnectionDescription, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getExceptionListener, getMaxDispatchersActive, getMaxRequestersActive, getMuleContext, getName, getNumberOfConcurrentTransactedReceivers, getOutputStream, getReceiver, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, handleException, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isStarted, isSyncEnabled, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, send, setConnectionStrategy, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherThreadingProfile, setDynamicNotification, setExceptionListener, setMaxDispatchersActive, setMaxRequestersActive, setMuleContext, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterThreadingProfile, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, start, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, workAccepted, workCompleted, workRejected, workStarted

Methods inherited from class java.lang.Object

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

Field Detail

ACTIVEMQ_CONNECTION_FACTORY_CLASS

public static final String ACTIVEMQ_CONNECTION_FACTORY_CLASS

See Also:

Constant Field Values

DEFAULT_BROKER_URL

public static final String DEFAULT_BROKER_URL

See Also:

Constant Field Values

Constructor Detail

ActiveMQJmsConnector

public ActiveMQJmsConnector()

Constructs a new ActiveMQJmsConnector.

Method Detail

getDefaultConnectionFactory

protected javax.jms.ConnectionFactory getDefaultConnectionFactory()

Description copied from class: JmsConnector

Override this method to provide a default ConnectionFactory for a vendor-specific JMS Connector.

Overrides:

getDefaultConnectionFactory in class JmsConnector

applyVendorSpecificConnectionFactoryProperties

protected void applyVendorSpecificConnectionFactoryProperties(javax.jms.ConnectionFactory connectionFactory)

doDisconnect

protected void doDisconnect()
                     throws ConnectException

Will additionally try to cleanup the ActiveMq connection, otherwise there's a deadlock on shutdown.

Overrides:

doDisconnect in class JmsConnector

Throws:

ConnectException

getBrokerURL

public String getBrokerURL()

setBrokerURL

public void setBrokerURL(String brokerURL)