org.mule.transport.amqp.internal.connector
Class AmqpConnector
java.lang.Object
org.mule.transport.AbstractConnector
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.
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)
|
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 |
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
AmqpConnector
public AmqpConnector(org.mule.api.MuleContext context)
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.