org.mule.transport.jms.activemq
Class ActiveMQJmsConnector

java.lang.Object
  extended by org.mule.transport.AbstractConnector
      extended by org.mule.transport.jms.JmsConnector
          extended by 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
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, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatchers, disposed, 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
ActiveMQJmsConnector()
          Constructs a new ActiveMQJmsConnector.
 
Method Summary
protected  void applyVendorSpecificConnectionFactoryProperties(ConnectionFactory connectionFactory)
           
protected  void doDisconnect()
          Will additionally try to cleanup the ActiveMq connection, otherwise there's a deadlock on shutdown.
 String getBrokerURL()
           
protected  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, createConnectionFactory, createJmsSupport, doConnect, doDispose, doInitialise, doStart, doStop, getAcknowledgementMode, getClientId, getConnection, getConnectionFactory, getConnectionFactoryJndiName, getConnectionFactoryProperties, getJmsSupport, getJndiContext, getJndiInitialFactory, getJndiProviderProperties, getJndiProviderUrl, getMaxRedelivery, getMessageAdapter, getNumberOfConsumers, getPassword, getProtocol, getReceiverKey, getRedeliveryHandlerFactory, getReplyToHandler, getSession, getSession, getSessionFromTransaction, getSpecification, getTopicResolver, getUsername, initJndiContext, isCacheJmsSessions, isDisableTemporaryReplyToDestinations, isDurable, isEagerConsumer, isForceJndiDestinations, isHonorQosHeaders, isJndiDestinations, isNoLocal, isPersistentDelivery, isResponseEnabled, lookupFromJndi, onException, onNotification, preProcessMessage, setAcknowledgementMode, setCacheJmsSessions, setClientId, setConnection, setConnectionFactory, setConnectionFactoryJndiName, setConnectionFactoryProperties, setDisableTemporaryReplyToDestinations, setDurable, setEagerConsumer, setForceJndiDestinations, setHonorQosHeaders, setJmsSupport, setJndiContext, setJndiDestinations, setJndiInitialFactory, setJndiProviderProperties, setJndiProviderUrl, setMaxRedelivery, setNoLocal, setNumberOfConsumers, setPassword, setPersistentDelivery, 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, getConnectEventId, getConnectionDescription, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getExceptionListener, getMaxDispatchersActive, getMaxRequestersActive, getMuleContext, getName, getNumberOfConcurrentTransactedReceivers, getOutputStream, getReceiver, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, handleException, handleException, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isStarted, isSyncEnabled, isValidateConnections, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, send, setConnected, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherThreadingProfile, setDynamicNotification, setExceptionListener, setMaxDispatchersActive, setMaxRequestersActive, setMuleContext, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, start, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, 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 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(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)


Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.