org.mule.transport.amqp.internal.connector
Class AmqpConnector

java.lang.Object
  extended by org.mule.transport.AbstractConnector
      extended by org.mule.transport.amqp.internal.connector.AmqpConnector
All Implemented Interfaces:
EventListener, javax.resource.spi.work.WorkListener, org.mule.api.lifecycle.Disposable, org.mule.api.lifecycle.Initialisable, org.mule.api.lifecycle.Lifecycle, org.mule.api.lifecycle.LifecycleStateEnabled, org.mule.api.lifecycle.Startable, org.mule.api.lifecycle.Stoppable, org.mule.api.NameableObject, org.mule.api.NamedObject, org.mule.api.transport.Connectable, org.mule.api.transport.Connector
Direct Known Subclasses:
AmqpsConnector

public class AmqpConnector
extends org.mule.transport.AbstractConnector

Connects to a particular virtual host on a particular AMQP broker.


Field Summary
static String ALL_USER_HEADERS
           
static String AMQP
           
static String AMQP_DELIVERY_TAG
           
static int DEFAULT_NUMBER_OF_CHANNELS
          Default number of channels
static String ENDPOINT_DEFAULT_EXCHANGE_ALIAS
           
static String ENDPOINT_EXCHANGE_PREFIX
           
static String ENDPOINT_PROPERTY_EXCHANGE_AUTO_DELETE
           
static String ENDPOINT_PROPERTY_EXCHANGE_DURABLE
           
static String ENDPOINT_PROPERTY_EXCHANGE_TYPE
           
static String ENDPOINT_PROPERTY_QUEUE_AUTO_DELETE
           
static String ENDPOINT_PROPERTY_QUEUE_DURABLE
           
static String ENDPOINT_PROPERTY_QUEUE_EXCLUSIVE
           
static String ENDPOINT_PROPERTY_ROUTING_KEY
           
static String ENDPOINT_QUEUE_PREFIX
           
static String EXCHANGE
           
static String MESSAGE_PROPERTY_APP_ID
           
static String MESSAGE_PROPERTY_CHANNEL
           
static String MESSAGE_PROPERTY_CLUSTER_ID
           
static String MESSAGE_PROPERTY_CONSUMER_TAG
           
static String MESSAGE_PROPERTY_CONTENT_ENCODING
           
static String MESSAGE_PROPERTY_CONTENT_TYPE
           
static String MESSAGE_PROPERTY_CORRELATION_ID
           
static String MESSAGE_PROPERTY_DELIVERY_MODE
           
static String MESSAGE_PROPERTY_DELIVERY_TAG
           
static String MESSAGE_PROPERTY_EXPIRATION
           
static String MESSAGE_PROPERTY_MESSAGE_ID
           
static String MESSAGE_PROPERTY_NEXT_PUBLISH_SEQ_NO
           
static String MESSAGE_PROPERTY_PRIORITY
           
static String MESSAGE_PROPERTY_REDELIVER
           
static String MESSAGE_PROPERTY_REPLY_TO
           
static String MESSAGE_PROPERTY_ROUTING_KEY
           
static String MESSAGE_PROPERTY_TIMESTAMP
           
static String MESSAGE_PROPERTY_TYPE
           
static String MESSAGE_PROPERTY_USER_ID
           
static String NUMBER_OF_CHANNELS
           
static String RETURN_CONTEXT_PREFIX
           
static String RETURN_EXCHANGE
           
static String RETURN_LISTENER
           
static String RETURN_REPLY_CODE
           
static String RETURN_REPLY_TEXT
           
static String RETURN_ROUTING_KEY
           
 
Fields inherited from class org.mule.transport.AbstractConnector
createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatcherPoolFactory, dispatchers, initialStateStopped, lifecycleManager, logger, muleContext, muleMessageFactory, name, numberOfConcurrentTransactedReceivers, PROPERTY_POLLING_FREQUENCY, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, startOnConnect
 
Fields inherited from interface org.mule.api.transport.Connector
INT_VALUE_NOT_SET
 
Fields inherited from interface org.mule.api.lifecycle.Disposable
PHASE_NAME
 
Constructor Summary
AmqpConnector(org.mule.api.MuleContext context)
           
 
Method Summary
protected  void addFallbackAddresses(List<com.rabbitmq.client.Address> brokerAddresses)
           
protected  void configureDefaultReturnListener()
           
protected  void connectToFirstResponsiveBroker(List<com.rabbitmq.client.Address> brokerAddresses)
           
protected  com.rabbitmq.client.Channel createOperationResource(org.mule.api.endpoint.ImmutableEndpoint endpoint)
           
 void doConnect()
           
 void doDisconnect()
           
 void doDispose()
           
 void doInitialise()
           
 void doStart()
           
 void doStop()
           
 AckMode getAckMode()
           
 ChannelHandler getChannelHandler()
           
 com.rabbitmq.client.Connection getConnection()
           
 com.rabbitmq.client.ConnectionFactory getConnectionFactory()
           
 com.rabbitmq.client.ReturnListener getDefaultReturnListener()
           
 DeliveryMode getDeliveryMode()
           
 String getHost()
           
 int getNumberOfChannels()
           
protected  Object getOperationResourceFactory()
           
 int getPort()
           
 int getPrefetchCount()
           
 int getPrefetchSize()
           
 Byte getPriority()
           
 String getProtocol()
           
 org.mule.api.transformer.Transformer getReceiveTransformer()
           
 org.mule.api.transport.ReplyToHandler getReplyToHandler(org.mule.api.endpoint.ImmutableEndpoint endpoint)
           
 int getRequestedHeartbeat()
           
 boolean isExclusiveConsumers()
           
 boolean isImmediate()
           
 boolean isMandatory()
           
 boolean isNoLocal()
           
 boolean isRequestBrokerConfirms()
           
 void setAckMode(AckMode ackMode)
           
 void setActiveDeclarationsOnly(boolean activeDeclarationsOnly)
           
 void setChannelHandler(ChannelHandler channelHandler)
           
 void setConnectionFactory(com.rabbitmq.client.ConnectionFactory connectionFactory)
           
 void setDefaultReturnEndpoint(org.mule.api.endpoint.EndpointBuilder defaultReturnEndpointBuilder)
           
 void setDeliveryMode(DeliveryMode deliveryMode)
           
 void setExclusiveConsumers(boolean exclusiveConsumers)
           
 void setFallbackAddresses(String[] fallbackAddresses)
           
 void setHost(String host)
           
 void setImmediate(boolean immediate)
           
 void setMandatory(boolean mandatory)
           
 void setNoLocal(boolean noLocal)
           
 void setNumberOfChannels(int numberOfChannels)
           
 void setPassword(String password)
           
 void setPort(int port)
           
 void setPrefetchCount(int prefetchCount)
           
 void setPrefetchSize(int prefetchSize)
           
 void setPriority(Byte priority)
           
 void setRequestBrokerConfirms(boolean requestBrokerConfirms)
           
 void setRequestedHeartbeat(int requestedHeartbeat)
           
 void setUsername(String username)
           
 void setVirtualHost(String virtualHost)
           
 
Methods inherited from class org.mule.transport.AbstractConnector
clearDispatchers, clearRequesters, configureDispatcherPool, connect, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createReceiver, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, getConnectEventId, getConnectionDescription, getDefaultExchangePattern, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherPoolFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getInboundExchangePatterns, getLifecycleState, getMaxDispatchersActive, getMaxRequestersActive, getMaxTotalDispatchers, getMuleContext, getMuleMessageFactory, getName, getNumberOfConcurrentTransactedReceivers, getOutboundExchangePatterns, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, getTransactionalResource, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isConnecting, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isInitialised, isInitialStateStopped, isResponseEnabled, isStarted, isStarting, isStopped, isStopping, isValidateConnections, lookupReceiver, registerListener, registerSupportedMetaProtocol, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, setConnected, setConnecting, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherPoolFactory, setDispatcherPoolMaxWait, setDispatcherPoolWhenExhaustedAction, setDispatcherThreadingProfile, setDynamicNotification, setInitialStateStopped, setMaxDispatchersActive, setMaxRequestersActive, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterPoolMaxWait, setRequesterPoolWhenExhaustedAction, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, shutdownScheduler, start, startAfterConnect, 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

DEFAULT_NUMBER_OF_CHANNELS

public static final int DEFAULT_NUMBER_OF_CHANNELS
Default number of channels

See Also:
Constant Field Values

NUMBER_OF_CHANNELS

public static final String NUMBER_OF_CHANNELS
See Also:
Constant Field Values

AMQP

public static final String AMQP
See Also:
Constant Field Values

AMQP_DELIVERY_TAG

public static final String AMQP_DELIVERY_TAG
See Also:
Constant Field Values

ALL_USER_HEADERS

public static final String ALL_USER_HEADERS
See Also:
Constant Field Values

MESSAGE_PROPERTY_APP_ID

public static final String MESSAGE_PROPERTY_APP_ID
See Also:
Constant Field Values

MESSAGE_PROPERTY_CHANNEL

public static final String MESSAGE_PROPERTY_CHANNEL
See Also:
Constant Field Values

MESSAGE_PROPERTY_CONTENT_ENCODING

public static final String MESSAGE_PROPERTY_CONTENT_ENCODING
See Also:
Constant Field Values

MESSAGE_PROPERTY_CONTENT_TYPE

public static final String MESSAGE_PROPERTY_CONTENT_TYPE
See Also:
Constant Field Values

MESSAGE_PROPERTY_CORRELATION_ID

public static final String MESSAGE_PROPERTY_CORRELATION_ID
See Also:
Constant Field Values

MESSAGE_PROPERTY_DELIVERY_MODE

public static final String MESSAGE_PROPERTY_DELIVERY_MODE
See Also:
Constant Field Values

MESSAGE_PROPERTY_DELIVERY_TAG

public static final String MESSAGE_PROPERTY_DELIVERY_TAG
See Also:
Constant Field Values

EXCHANGE

public static final String EXCHANGE
See Also:
Constant Field Values

MESSAGE_PROPERTY_EXPIRATION

public static final String MESSAGE_PROPERTY_EXPIRATION
See Also:
Constant Field Values

MESSAGE_PROPERTY_MESSAGE_ID

public static final String MESSAGE_PROPERTY_MESSAGE_ID
See Also:
Constant Field Values

MESSAGE_PROPERTY_CLUSTER_ID

public static final String MESSAGE_PROPERTY_CLUSTER_ID
See Also:
Constant Field Values

MESSAGE_PROPERTY_PRIORITY

public static final String MESSAGE_PROPERTY_PRIORITY
See Also:
Constant Field Values

MESSAGE_PROPERTY_REDELIVER

public static final String MESSAGE_PROPERTY_REDELIVER
See Also:
Constant Field Values

MESSAGE_PROPERTY_REPLY_TO

public static final String MESSAGE_PROPERTY_REPLY_TO
See Also:
Constant Field Values

MESSAGE_PROPERTY_ROUTING_KEY

public static final String MESSAGE_PROPERTY_ROUTING_KEY
See Also:
Constant Field Values

MESSAGE_PROPERTY_TIMESTAMP

public static final String MESSAGE_PROPERTY_TIMESTAMP
See Also:
Constant Field Values

MESSAGE_PROPERTY_TYPE

public static final String MESSAGE_PROPERTY_TYPE
See Also:
Constant Field Values

MESSAGE_PROPERTY_USER_ID

public static final String MESSAGE_PROPERTY_USER_ID
See Also:
Constant Field Values

MESSAGE_PROPERTY_NEXT_PUBLISH_SEQ_NO

public static final String MESSAGE_PROPERTY_NEXT_PUBLISH_SEQ_NO
See Also:
Constant Field Values

MESSAGE_PROPERTY_CONSUMER_TAG

public static final String MESSAGE_PROPERTY_CONSUMER_TAG
See Also:
Constant Field Values

ENDPOINT_DEFAULT_EXCHANGE_ALIAS

public static final String ENDPOINT_DEFAULT_EXCHANGE_ALIAS
See Also:
Constant Field Values

ENDPOINT_EXCHANGE_PREFIX

public static final String ENDPOINT_EXCHANGE_PREFIX
See Also:
Constant Field Values

ENDPOINT_PROPERTY_ROUTING_KEY

public static final String ENDPOINT_PROPERTY_ROUTING_KEY
See Also:
Constant Field Values

ENDPOINT_PROPERTY_QUEUE_EXCLUSIVE

public static final String ENDPOINT_PROPERTY_QUEUE_EXCLUSIVE
See Also:
Constant Field Values

ENDPOINT_PROPERTY_QUEUE_AUTO_DELETE

public static final String ENDPOINT_PROPERTY_QUEUE_AUTO_DELETE
See Also:
Constant Field Values

ENDPOINT_PROPERTY_QUEUE_DURABLE

public static final String ENDPOINT_PROPERTY_QUEUE_DURABLE
See Also:
Constant Field Values

ENDPOINT_PROPERTY_EXCHANGE_AUTO_DELETE

public static final String ENDPOINT_PROPERTY_EXCHANGE_AUTO_DELETE
See Also:
Constant Field Values

ENDPOINT_PROPERTY_EXCHANGE_DURABLE

public static final String ENDPOINT_PROPERTY_EXCHANGE_DURABLE
See Also:
Constant Field Values

ENDPOINT_PROPERTY_EXCHANGE_TYPE

public static final String ENDPOINT_PROPERTY_EXCHANGE_TYPE
See Also:
Constant Field Values

ENDPOINT_QUEUE_PREFIX

public static final String ENDPOINT_QUEUE_PREFIX
See Also:
Constant Field Values

RETURN_CONTEXT_PREFIX

public static final String RETURN_CONTEXT_PREFIX
See Also:
Constant Field Values

RETURN_ROUTING_KEY

public static final String RETURN_ROUTING_KEY
See Also:
Constant Field Values

RETURN_EXCHANGE

public static final String RETURN_EXCHANGE
See Also:
Constant Field Values

RETURN_REPLY_TEXT

public static final String RETURN_REPLY_TEXT
See Also:
Constant Field Values

RETURN_REPLY_CODE

public static final String RETURN_REPLY_CODE
See Also:
Constant Field Values

RETURN_LISTENER

public static final String RETURN_LISTENER
See Also:
Constant Field Values
Constructor Detail

AmqpConnector

public AmqpConnector(org.mule.api.MuleContext context)
Method Detail

doInitialise

public void doInitialise()
                  throws org.mule.api.lifecycle.InitialisationException
Specified by:
doInitialise in class org.mule.transport.AbstractConnector
Throws:
org.mule.api.lifecycle.InitialisationException

doConnect

public void doConnect()
               throws Exception
Specified by:
doConnect in class org.mule.transport.AbstractConnector
Throws:
Exception

doStart

public void doStart()
             throws org.mule.api.MuleException
Specified by:
doStart in class org.mule.transport.AbstractConnector
Throws:
org.mule.api.MuleException

doStop

public void doStop()
            throws org.mule.api.MuleException
Specified by:
doStop in class org.mule.transport.AbstractConnector
Throws:
org.mule.api.MuleException

doDisconnect

public void doDisconnect()
                  throws Exception
Specified by:
doDisconnect in class org.mule.transport.AbstractConnector
Throws:
Exception

doDispose

public void doDispose()
Specified by:
doDispose in class org.mule.transport.AbstractConnector

addFallbackAddresses

protected void addFallbackAddresses(List<com.rabbitmq.client.Address> brokerAddresses)

connectToFirstResponsiveBroker

protected void connectToFirstResponsiveBroker(List<com.rabbitmq.client.Address> brokerAddresses)
                                       throws Exception
Throws:
Exception

configureDefaultReturnListener

protected void configureDefaultReturnListener()
                                       throws org.mule.api.lifecycle.InitialisationException
Throws:
org.mule.api.lifecycle.InitialisationException

setDefaultReturnEndpoint

public void setDefaultReturnEndpoint(org.mule.api.endpoint.EndpointBuilder defaultReturnEndpointBuilder)

getReplyToHandler

public org.mule.api.transport.ReplyToHandler getReplyToHandler(org.mule.api.endpoint.ImmutableEndpoint endpoint)
Overrides:
getReplyToHandler in class org.mule.transport.AbstractConnector

createOperationResource

protected com.rabbitmq.client.Channel createOperationResource(org.mule.api.endpoint.ImmutableEndpoint endpoint)
                                                       throws org.mule.api.MuleException
Overrides:
createOperationResource in class org.mule.transport.AbstractConnector
Throws:
org.mule.api.MuleException

getOperationResourceFactory

protected Object getOperationResourceFactory()
Overrides:
getOperationResourceFactory in class org.mule.transport.AbstractConnector

getConnection

public com.rabbitmq.client.Connection getConnection()

getReceiveTransformer

public org.mule.api.transformer.Transformer getReceiveTransformer()

getProtocol

public String getProtocol()

getPriority

public Byte getPriority()

setPriority

public void setPriority(Byte priority)

getAckMode

public AckMode getAckMode()

setAckMode

public void setAckMode(AckMode ackMode)

setActiveDeclarationsOnly

public void setActiveDeclarationsOnly(boolean activeDeclarationsOnly)

getDeliveryMode

public DeliveryMode getDeliveryMode()

setDeliveryMode

public void setDeliveryMode(DeliveryMode deliveryMode)

getHost

public String getHost()

setHost

public void setHost(String host)

getPort

public int getPort()

setPort

public void setPort(int port)

setFallbackAddresses

public void setFallbackAddresses(String[] fallbackAddresses)

setVirtualHost

public void setVirtualHost(String virtualHost)

setUsername

public void setUsername(String username)

setPassword

public void setPassword(String password)

isImmediate

public boolean isImmediate()

setImmediate

public void setImmediate(boolean immediate)

isMandatory

public boolean isMandatory()

setMandatory

public void setMandatory(boolean mandatory)

getPrefetchSize

public int getPrefetchSize()

setPrefetchSize

public void setPrefetchSize(int prefetchSize)

getPrefetchCount

public int getPrefetchCount()

setPrefetchCount

public void setPrefetchCount(int prefetchCount)

isNoLocal

public boolean isNoLocal()

setNoLocal

public void setNoLocal(boolean noLocal)

isExclusiveConsumers

public boolean isExclusiveConsumers()

setExclusiveConsumers

public void setExclusiveConsumers(boolean exclusiveConsumers)

setConnectionFactory

public void setConnectionFactory(com.rabbitmq.client.ConnectionFactory connectionFactory)

getConnectionFactory

public com.rabbitmq.client.ConnectionFactory getConnectionFactory()

setRequestBrokerConfirms

public void setRequestBrokerConfirms(boolean requestBrokerConfirms)

isRequestBrokerConfirms

public boolean isRequestBrokerConfirms()

getRequestedHeartbeat

public int getRequestedHeartbeat()

setRequestedHeartbeat

public void setRequestedHeartbeat(int requestedHeartbeat)

getDefaultReturnListener

public com.rabbitmq.client.ReturnListener getDefaultReturnListener()

getNumberOfChannels

public int getNumberOfChannels()

setNumberOfChannels

public void setNumberOfChannels(int numberOfChannels)

getChannelHandler

public ChannelHandler getChannelHandler()

setChannelHandler

public void setChannelHandler(ChannelHandler channelHandler)


Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.