A B C D E F G H I L M N O P Q R S T U V

A

AbstractAmqpMessageToObject - Class in org.mule.transport.amqp.internal.transformer
 
AbstractAmqpMessageToObject() - Constructor for class org.mule.transport.amqp.internal.transformer.AbstractAmqpMessageToObject
 
AbstractAmqpReturnHandlerListener - Class in org.mule.transport.amqp.internal.client
 
AbstractAmqpReturnHandlerListener() - Constructor for class org.mule.transport.amqp.internal.client.AbstractAmqpReturnHandlerListener
 
AbstractChannelMessageProcessor - Class in org.mule.transport.amqp.internal.processor
Provides common logic to all channel aware message processors.
AbstractChannelMessageProcessor() - Constructor for class org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
 
ack(MuleEvent, boolean) - Method in class org.mule.transport.amqp.internal.processor.Acknowledger
 
ack(MuleMessage, boolean) - Method in class org.mule.transport.amqp.internal.processor.Acknowledger
 
ackMessageIfNecessary(Channel, AmqpMessage, ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.client.MessagePropertiesHandler
 
AckMode - Enum in org.mule.transport.amqp.internal.domain
 
Acknowledger - Class in org.mule.transport.amqp.internal.processor
Used to manually perform a basic ack of the message in flow, allowing fine control of message throttling.
Acknowledger() - Constructor for class org.mule.transport.amqp.internal.processor.Acknowledger
 
addFallbackAddresses(List<Address>) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
addInvocationProperties(Channel, AmqpMessage, MuleMessage, AmqpConnector) - Method in class org.mule.transport.amqp.internal.client.MessagePropertiesHandler
 
addProperties(DefaultMuleMessage, Object) - Method in class org.mule.transport.amqp.internal.domain.AmqpMuleMessageFactory
 
addReturnListenerIfNeeded(MuleEvent, Channel) - Method in class org.mule.transport.amqp.internal.endpoint.dispatcher.Dispatcher
Try to associate a return listener to the channel in order to allow flow-level exception strategy to handle return messages.
ALL_USER_HEADERS - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
AMQP - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
AMQP_ALL_PROPERTY_NAMES - Static variable in class org.mule.transport.amqp.internal.transformer.ObjectToAmqpMessage
 
AMQP_DELIVERY_TAG - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
AMQP_MESSAGE_DATA_TYPE - Static variable in class org.mule.transport.amqp.internal.transformer.AbstractAmqpMessageToObject
 
amqpConnector - Variable in class org.mule.transport.amqp.internal.client.DispatchingReturnListener
 
AmqpConnector - Class in org.mule.transport.amqp.internal.connector
Connects to a particular virtual host on a particular AMQP broker.
AmqpConnector(MuleContext) - Constructor for class org.mule.transport.amqp.internal.connector.AmqpConnector
 
amqpConnector - Variable in class org.mule.transport.amqp.internal.endpoint.dispatcher.Dispatcher
 
amqpConnector - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageReceiver
 
amqpConnector - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
amqpConnector - Variable in class org.mule.transport.amqp.internal.endpoint.requester.MessageRequester
 
AmqpConnectorFlowConstruct - Class in org.mule.transport.amqp.internal.connector
A fake FlowConstruct that is used when the events need to be dispatched on behalf of the connector and out of any actual Flow context.
AmqpDeclarer - Class in org.mule.transport.amqp.internal.client
 
AmqpDeclarer() - Constructor for class org.mule.transport.amqp.internal.client.AmqpDeclarer
 
AmqpEndpointUtil - Class in org.mule.transport.amqp.internal.endpoint
 
AmqpEndpointUtil() - Constructor for class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
AmqpMessage - Class in org.mule.transport.amqp.internal.domain
 
AmqpMessage(String, Envelope, AMQP.BasicProperties, byte[]) - Constructor for class org.mule.transport.amqp.internal.domain.AmqpMessage
 
AmqpMessageToObject - Class in org.mule.transport.amqp.internal.transformer
 
AmqpMessageToObject() - Constructor for class org.mule.transport.amqp.internal.transformer.AmqpMessageToObject
 
AmqpMuleMessageFactory - Class in org.mule.transport.amqp.internal.domain
 
AmqpMuleMessageFactory(MuleContext) - Constructor for class org.mule.transport.amqp.internal.domain.AmqpMuleMessageFactory
 
AmqpNamespaceHandler - Class in org.mule.transport.amqp.config
Registers a Bean Definition Parser for handling elements and supporting endpoint elements.
AmqpNamespaceHandler() - Constructor for class org.mule.transport.amqp.config.AmqpNamespaceHandler
 
AMQPS - Static variable in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
AmqpsConnector - Class in org.mule.transport.amqp.internal.connector
Connects to a particular virtual host on a particular AMQP broker.
AmqpsConnector(MuleContext) - Constructor for class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
AmqpsNamespaceHandler - Class in org.mule.transport.amqp.config
Registers a Bean Definition Parser for handling elements and supporting endpoint elements.
AmqpsNamespaceHandler() - Constructor for class org.mule.transport.amqp.config.AmqpsNamespaceHandler
 
AmqpTransaction - Class in org.mule.transport.amqp.internal.transaction
AmqpTransaction is a wrapper for an AMQP local transaction.
AmqpTransaction(MuleContext, AmqpTransaction.RecoverStrategy) - Constructor for class org.mule.transport.amqp.internal.transaction.AmqpTransaction
 
AmqpTransaction.RecoverStrategy - Enum in org.mule.transport.amqp.internal.transaction
 
AmqpTransactionFactory - Class in org.mule.transport.amqp.internal.transaction
AmqpTransactionFactory creates an AMQP local transaction.
AmqpTransactionFactory() - Constructor for class org.mule.transport.amqp.internal.transaction.AmqpTransactionFactory
 
AmqpTransactionFactoryRegistor - Class in org.mule.transport.amqp.internal.transaction
 
AmqpTransactionFactoryRegistor() - Constructor for class org.mule.transport.amqp.internal.transaction.AmqpTransactionFactoryRegistor
 
applyRecoverStrategy(Channel) - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransaction
 
awaitConfirm(Channel, MuleEvent, long, TimeUnit) - Method in interface org.mule.transport.amqp.internal.confirm.ConfirmsManager
 
awaitConfirm(Channel, MuleEvent, long, TimeUnit) - Method in class org.mule.transport.amqp.internal.confirm.DefaultConfirmsManager
 

B

beginTransaction(MuleContext) - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransactionFactory
 
bindResource(Object, Object) - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransaction
 

C

channel - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
ChannelHandler - Class in org.mule.transport.amqp.internal.client
 
ChannelHandler() - Constructor for class org.mule.transport.amqp.internal.client.ChannelHandler
 
channelHandler - Variable in class org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
 
close() - Method in class org.mule.transport.amqp.internal.transaction.CloseableChannelWrapper
 
CloseableChannelWrapper - Class in org.mule.transport.amqp.internal.transaction
 
CloseableChannelWrapper(Channel) - Constructor for class org.mule.transport.amqp.internal.transaction.CloseableChannelWrapper
 
closeChannel(Channel) - Method in class org.mule.transport.amqp.internal.client.ChannelHandler
 
closeChannelIfNeeded(Channel) - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransaction
 
closeChannelIfNotTransacted(Channel) - Method in class org.mule.transport.amqp.internal.client.ChannelHandler
 
configureDefaultReturnListener() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ConfirmsManager - Interface in org.mule.transport.amqp.internal.confirm
 
connectToFirstResponsiveBroker(List<Address>) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
consumeMessage(Channel, String, boolean, long) - Method in class org.mule.transport.amqp.internal.client.MessageConsumer
 
CONSUMER_TAG - Static variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
consumerTag - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
create(OutboundEndpoint) - Method in class org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherFactory
 
create(InboundEndpoint) - Method in class org.mule.transport.amqp.internal.endpoint.requester.MessageRequesterFactory
 
createChannel(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.client.ChannelHandler
 
createOperationResource(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
createUnboundTransaction(MuleContext) - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransactionFactory
 

D

declarator - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageReceiver
 
declareBinding(Channel, ImmutableEndpoint, String, String, String) - Method in class org.mule.transport.amqp.internal.client.AmqpDeclarer
 
declareEndpoint(Channel, ImmutableEndpoint, boolean) - Method in class org.mule.transport.amqp.internal.client.AmqpDeclarer
 
declareEndpoint(Channel, ImmutableEndpoint, boolean, String) - Method in class org.mule.transport.amqp.internal.client.AmqpDeclarer
 
declareEndpoint(Channel, ImmutableEndpoint, boolean, String, String) - Method in class org.mule.transport.amqp.internal.client.AmqpDeclarer
 
declareEndpoint(Channel) - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageReceiver
 
declareExchange(Channel, ImmutableEndpoint, boolean) - Method in class org.mule.transport.amqp.internal.client.AmqpDeclarer
 
declareInputOutputClasses() - Method in class org.mule.transport.amqp.internal.transformer.AbstractAmqpMessageToObject
 
declareInputOutputClasses() - Method in class org.mule.transport.amqp.internal.transformer.AmqpMessageToObject
 
declareInputOutputClasses() - Method in class org.mule.transport.amqp.internal.transformer.ObjectToAmqpMessage
 
declareQueuePassively(Channel, String) - Method in class org.mule.transport.amqp.internal.client.AmqpDeclarer
 
declareTemporaryQueue(Channel) - Method in class org.mule.transport.amqp.internal.client.AmqpDeclarer
 
DEFAULT_NUMBER_OF_CHANNELS - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
Default number of channels
DEFAULT_RECOVER_STRATEGY - Static variable in class org.mule.transport.amqp.internal.transaction.AmqpTransactionFactory
 
DEFAULT_RETURN_LISTENER - Static variable in class org.mule.transport.amqp.internal.processor.ReturnHandler
 
DefaultConfirmsManager - Class in org.mule.transport.amqp.internal.confirm
 
DefaultConfirmsManager(AmqpConnector) - Constructor for class org.mule.transport.amqp.internal.confirm.DefaultConfirmsManager
 
deliverAmqpMessage(AmqpMessage) - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MessageReceiverConsumer
 
DeliveryMode - Enum in org.mule.transport.amqp.internal.domain
 
Dispatcher - Class in org.mule.transport.amqp.internal.endpoint.dispatcher
The Dispatcher takes care of sending messages from Mule to an AMQP broker.
Dispatcher(OutboundEndpoint) - Constructor for class org.mule.transport.amqp.internal.endpoint.dispatcher.Dispatcher
 
DispatcherAction - Class in org.mule.transport.amqp.internal.endpoint.dispatcher
 
DispatcherAction() - Constructor for class org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherAction
 
DispatcherActionDispatch - Class in org.mule.transport.amqp.internal.endpoint.dispatcher
 
DispatcherActionDispatch() - Constructor for class org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherActionDispatch
 
DispatcherActionSend - Class in org.mule.transport.amqp.internal.endpoint.dispatcher
 
DispatcherActionSend() - Constructor for class org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherActionSend
 
DispatcherFactory - Class in org.mule.transport.amqp.internal.endpoint.dispatcher
Creates instances of DispatcherFactory.
DispatcherFactory() - Constructor for class org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherFactory
 
DispatchingReturnListener - Class in org.mule.transport.amqp.internal.client
 
DispatchingReturnListener(List<MessageProcessor>, MuleEvent) - Constructor for class org.mule.transport.amqp.internal.client.DispatchingReturnListener
 
DispatchingReturnListener(List<MessageProcessor>, AmqpConnectorFlowConstruct) - Constructor for class org.mule.transport.amqp.internal.client.DispatchingReturnListener
 
doBegin() - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransaction
 
doCommit() - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransaction
 
doConnect() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
doConnect() - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageReceiver
 
doConnect() - Method in class org.mule.transport.amqp.internal.endpoint.requester.MessageRequester
 
doDisconnect() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
doDisconnect() - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageReceiver
 
doDisconnect() - Method in class org.mule.transport.amqp.internal.endpoint.requester.MessageRequester
 
doDispatch(MuleEvent) - Method in class org.mule.transport.amqp.internal.endpoint.dispatcher.Dispatcher
 
doDispose() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
doDispose() - Method in class org.mule.transport.amqp.internal.endpoint.dispatcher.Dispatcher
 
doHandleReturn(String, Map<String, Object>, AmqpMessage) - Method in class org.mule.transport.amqp.internal.client.AbstractAmqpReturnHandlerListener
 
doHandleReturn(String, Map<String, Object>, AmqpMessage) - Method in class org.mule.transport.amqp.internal.client.DispatchingReturnListener
 
doHandleReturn(String, Map<String, Object>, AmqpMessage) - Method in class org.mule.transport.amqp.internal.client.LoggingReturnListener
 
doInitialise() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
doInitialise() - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
doInitialise() - Method in class org.mule.transport.amqp.internal.endpoint.dispatcher.Dispatcher
 
doOutboundAction(MuleEvent, DispatcherAction) - Method in class org.mule.transport.amqp.internal.endpoint.dispatcher.Dispatcher
 
doRequest(long) - Method in class org.mule.transport.amqp.internal.endpoint.requester.MessageRequester
 
doRollback() - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransaction
 
doSend(MuleEvent) - Method in class org.mule.transport.amqp.internal.endpoint.dispatcher.Dispatcher
 
doStart() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
doStart() - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
doStop() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
doStop() - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 

E

endpoint - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
ENDPOINT_DEFAULT_EXCHANGE_ALIAS - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ENDPOINT_EXCHANGE_PREFIX - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ENDPOINT_PROPERTY_EXCHANGE_AUTO_DELETE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ENDPOINT_PROPERTY_EXCHANGE_DURABLE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ENDPOINT_PROPERTY_EXCHANGE_TYPE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ENDPOINT_PROPERTY_QUEUE_AUTO_DELETE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ENDPOINT_PROPERTY_QUEUE_DURABLE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ENDPOINT_PROPERTY_QUEUE_EXCLUSIVE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ENDPOINT_PROPERTY_ROUTING_KEY - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ENDPOINT_QUEUE_PREFIX - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
endpointUtil - Variable in class org.mule.transport.amqp.internal.client.AmqpDeclarer
 
endpointUtil - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
equals(Object) - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
eventFlowConstruct - Variable in class org.mule.transport.amqp.internal.client.DispatchingReturnListener
 
EXCHANGE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
extractPayload(Object, String) - Method in class org.mule.transport.amqp.internal.domain.AmqpMuleMessageFactory
 

F

forget(MuleEvent) - Method in interface org.mule.transport.amqp.internal.confirm.ConfirmsManager
 
forget(MuleEvent) - Method in class org.mule.transport.amqp.internal.confirm.DefaultConfirmsManager
 

G

getAckMode() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getArguments(ImmutableEndpoint, String) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
getBody() - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
getChannel(ImmutableEndpoint, MuleMessage) - Method in class org.mule.transport.amqp.internal.client.ChannelHandler
 
getChannel() - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
getChannel() - Method in class org.mule.transport.amqp.internal.transaction.CloseableChannelWrapper
 
getChannelHandler() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getChannelOrFail(MuleMessage, String) - Method in class org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
 
getClientConsumerTag() - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
getCode() - Method in enum org.mule.transport.amqp.internal.domain.DeliveryMode
 
getConnection() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getConnectionFactory() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getConnector() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnectorFlowConstruct
 
getConnectorClass() - Method in class org.mule.transport.amqp.config.AmqpNamespaceHandler
 
getConnectorClass() - Method in class org.mule.transport.amqp.config.AmqpsNamespaceHandler
 
getConnectorProtocol() - Method in class org.mule.transport.amqp.config.AmqpNamespaceHandler
 
getConnectorProtocol() - Method in class org.mule.transport.amqp.config.AmqpsNamespaceHandler
 
getConstructType() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnectorFlowConstruct
 
getConsumerTag() - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
getDefaultReturnListener() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getDeliveryMode() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getDeliveryTagFromMessage(MuleMessage) - Method in class org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
 
getDeliveryTagOrFail(MuleMessage, String) - Method in class org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
 
getEndpointType(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
getEnvelope() - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
getExchangeName(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
getExchangeName(ImmutableEndpoint, MuleEvent) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
getExchangeName(String, String) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
getFlowVariableChannel(MuleMessage) - Method in class org.mule.transport.amqp.internal.client.ChannelHandler
 
getHitCount() - Method in class org.mule.transport.amqp.internal.client.LoggingReturnListener
 
getHost() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getNumberOfChannels() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getNumberOfChannels(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
getOperationResourceFactory() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getOrCreateChannel(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.client.ChannelHandler
 
getOrDefaultChannel(ImmutableEndpoint, Channel) - Method in class org.mule.transport.amqp.internal.client.ChannelHandler
 
getOrDefaultChannel(ImmutableEndpoint, MuleMessage, Channel) - Method in class org.mule.transport.amqp.internal.client.ChannelHandler
 
getPort() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getPrefetchCount() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getPrefetchSize() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getPriority() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getPriorityWeighting() - Method in class org.mule.transport.amqp.internal.transformer.AbstractAmqpMessageToObject
 
getProperties() - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
getProtocol() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getProtocol() - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
getQueueName(String) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
getQueueName() - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
getQueueName() - Method in class org.mule.transport.amqp.internal.endpoint.requester.MessageRequester
 
getQueueOrCreateTemporaryQueue(Channel) - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageReceiver
 
getReceiveTransformer() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getRecoverStrategy() - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransactionFactory
 
getReplyTo() - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
getReplyToHandler(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getRequestedHeartbeat() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
getRoutingKey(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
getRoutingKey(ImmutableEndpoint, MuleEvent) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
getSslProtocol() - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
getSslTrustManager() - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
getSupportedTransportMessageTypes() - Method in class org.mule.transport.amqp.internal.domain.AmqpMuleMessageFactory
 
getTransactedChannel() - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransaction
 
getTransactedResourceChannel(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.client.ChannelHandler
 

H

handleCancel(String) - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MessageReceiverConsumer
 
handleDelivery(String, Envelope, AMQP.BasicProperties, byte[]) - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MessageReceiverConsumer
 
handleReturn(int, String, String, String, AMQP.BasicProperties, byte[]) - Method in class org.mule.transport.amqp.internal.client.AbstractAmqpReturnHandlerListener
 
handleShutdownSignal(String, ShutdownSignalException) - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MessageReceiverConsumer
 
hashCode() - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
hitCount - Variable in class org.mule.transport.amqp.internal.client.LoggingReturnListener
 

I

init() - Method in class org.mule.transport.amqp.config.AmqpNamespaceHandler
 
init() - Method in class org.mule.transport.amqp.config.AmqpsNamespaceHandler
 
initialise() - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransactionFactoryRegistor
 
isAutoAck() - Method in enum org.mule.transport.amqp.internal.domain.AckMode
 
isDefaultExchange(String) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
isExchangeAutoDelete(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
isExchangeDurable(ImmutableEndpoint) - Method in class org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
 
isExclusiveConsumers() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
isImmediate() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
isMandatory() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
isNoLocal() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
isRequestBrokerConfirms() - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
isTransacted() - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransactionFactory
 

L

LoggingReturnListener - Class in org.mule.transport.amqp.internal.client
 
LoggingReturnListener() - Constructor for class org.mule.transport.amqp.internal.client.LoggingReturnListener
 
LONG_STRING_CHARSET - Static variable in class org.mule.transport.amqp.internal.domain.AmqpMuleMessageFactory
 

M

MESSAGE_PROPERTY_APP_ID - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_CHANNEL - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_CLUSTER_ID - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_CONSUMER_TAG - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_CONTENT_ENCODING - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_CONTENT_TYPE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_CORRELATION_ID - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_DELIVERY_MODE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_DELIVERY_TAG - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_EXPIRATION - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_MESSAGE_ID - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_NEXT_PUBLISH_SEQ_NO - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_PRIORITY - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_REDELIVER - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_REPLY_TO - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_ROUTING_KEY - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_TIMESTAMP - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_TYPE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MESSAGE_PROPERTY_USER_ID - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
MessageConsumer - Class in org.mule.transport.amqp.internal.client
 
MessageConsumer() - Constructor for class org.mule.transport.amqp.internal.client.MessageConsumer
 
messageConsumer - Variable in class org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherActionSend
 
messageConsumer - Variable in class org.mule.transport.amqp.internal.endpoint.requester.MessageRequester
 
MessagePropertiesHandler - Class in org.mule.transport.amqp.internal.client
 
MessagePropertiesHandler() - Constructor for class org.mule.transport.amqp.internal.client.MessagePropertiesHandler
 
messagePropertiesHandler - Variable in class org.mule.transport.amqp.internal.endpoint.requester.MessageRequester
 
MessageReceiverConsumer - Class in org.mule.transport.amqp.internal.endpoint.receiver
 
MessageReceiverConsumer(MultiChannelMessageSubReceiver, Channel) - Constructor for class org.mule.transport.amqp.internal.endpoint.receiver.MessageReceiverConsumer
 
MessageRequester - Class in org.mule.transport.amqp.internal.endpoint.requester
The MessageRequester is used to consume individual messages from an AMQP broker.
MessageRequester(InboundEndpoint) - Constructor for class org.mule.transport.amqp.internal.endpoint.requester.MessageRequester
 
MessageRequesterFactory - Class in org.mule.transport.amqp.internal.endpoint.requester
Creates instances of MessageRequester.
MessageRequesterFactory() - Constructor for class org.mule.transport.amqp.internal.endpoint.requester.MessageRequesterFactory
 
MultiChannelMessageReceiver - Class in org.mule.transport.amqp.internal.endpoint.receiver
In Mule an endpoint corresponds to a single receiver.
MultiChannelMessageReceiver(Connector, FlowConstruct, InboundEndpoint) - Constructor for class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageReceiver
 
MultiChannelMessageSubReceiver - Class in org.mule.transport.amqp.internal.endpoint.receiver
In Mule an endpoint corresponds to a single receiver.
MultiChannelMessageSubReceiver(MultiChannelMessageReceiver) - Constructor for class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
multiple - Variable in class org.mule.transport.amqp.internal.processor.Acknowledger
 

N

NonExclusiveAddressedEndpointDefinitionParser - Class in org.mule.transport.amqp.internal.config
The following specific parser exists because the default AddressedEndpointDefinitionParser.AddressParser enforces exclusivity of address attributes which is not OK for AMQP endpoints.
NonExclusiveAddressedEndpointDefinitionParser(String, boolean, MuleDefinitionParser, String[], String[], String[][], String[][]) - Constructor for class org.mule.transport.amqp.internal.config.NonExclusiveAddressedEndpointDefinitionParser
 
NUMBER_OF_CHANNELS - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
numberOfChannels - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageReceiver
 

O

ObjectToAmqpMessage - Class in org.mule.transport.amqp.internal.transformer
 
ObjectToAmqpMessage() - Constructor for class org.mule.transport.amqp.internal.transformer.ObjectToAmqpMessage
 
org.mule.transport.amqp.config - package org.mule.transport.amqp.config
 
org.mule.transport.amqp.internal.client - package org.mule.transport.amqp.internal.client
 
org.mule.transport.amqp.internal.config - package org.mule.transport.amqp.internal.config
 
org.mule.transport.amqp.internal.confirm - package org.mule.transport.amqp.internal.confirm
 
org.mule.transport.amqp.internal.connector - package org.mule.transport.amqp.internal.connector
 
org.mule.transport.amqp.internal.domain - package org.mule.transport.amqp.internal.domain
 
org.mule.transport.amqp.internal.endpoint - package org.mule.transport.amqp.internal.endpoint
 
org.mule.transport.amqp.internal.endpoint.dispatcher - package org.mule.transport.amqp.internal.endpoint.dispatcher
 
org.mule.transport.amqp.internal.endpoint.receiver - package org.mule.transport.amqp.internal.endpoint.receiver
 
org.mule.transport.amqp.internal.endpoint.requester - package org.mule.transport.amqp.internal.endpoint.requester
 
org.mule.transport.amqp.internal.processor - package org.mule.transport.amqp.internal.processor
 
org.mule.transport.amqp.internal.transaction - package org.mule.transport.amqp.internal.transaction
 
org.mule.transport.amqp.internal.transformer - package org.mule.transport.amqp.internal.transformer
 

P

parentReceiver - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
process(MuleEvent) - Method in class org.mule.transport.amqp.internal.processor.Acknowledger
 
process(MuleEvent) - Method in class org.mule.transport.amqp.internal.processor.Recover
 
process(MuleEvent) - Method in class org.mule.transport.amqp.internal.processor.Rejecter
 
process(MuleEvent) - Method in class org.mule.transport.amqp.internal.processor.ReturnHandler
 
processReplyTo(MuleEvent, MuleMessage, Object) - Method in class org.mule.transport.amqp.internal.connector.ReplyToHandler
 
PROPERTIES - Static variable in class org.mule.transport.amqp.internal.config.NonExclusiveAddressedEndpointDefinitionParser
 

Q

queueName - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageReceiver
 
queueName - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 

R

Recover - Class in org.mule.transport.amqp.internal.processor
Used to manually perform a basic recover of the current channel.
Recover() - Constructor for class org.mule.transport.amqp.internal.processor.Recover
 
recover(MuleEvent, boolean) - Method in class org.mule.transport.amqp.internal.processor.Recover
 
recover(MuleMessage, boolean) - Method in class org.mule.transport.amqp.internal.processor.Recover
 
registerAmqpEndpointDefinitionParser(String, MuleDefinitionParser) - Method in class org.mule.transport.amqp.config.AmqpNamespaceHandler
 
registerAmqpTransportEndpoints() - Method in class org.mule.transport.amqp.config.AmqpNamespaceHandler
 
reject(MuleEvent, boolean) - Method in class org.mule.transport.amqp.internal.processor.Rejecter
 
reject(MuleMessage, boolean) - Method in class org.mule.transport.amqp.internal.processor.Rejecter
 
Rejecter - Class in org.mule.transport.amqp.internal.processor
Used to manually perform a basic reject of the message in flow, allowing fine control of message throttling.
Rejecter() - Constructor for class org.mule.transport.amqp.internal.processor.Rejecter
 
ReplyToHandler - Class in org.mule.transport.amqp.internal.connector
 
ReplyToHandler(AmqpConnector, ImmutableEndpoint) - Constructor for class org.mule.transport.amqp.internal.connector.ReplyToHandler
 
requestConfirm(Channel, MuleEvent) - Method in interface org.mule.transport.amqp.internal.confirm.ConfirmsManager
 
requestConfirm(Channel, MuleEvent) - Method in class org.mule.transport.amqp.internal.confirm.DefaultConfirmsManager
 
requeue - Variable in class org.mule.transport.amqp.internal.processor.Recover
 
requeue - Variable in class org.mule.transport.amqp.internal.processor.Rejecter
 
restart(boolean) - Method in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageSubReceiver
 
RETURN_CONTEXT_PREFIX - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
RETURN_EXCHANGE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
RETURN_LISTENER - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
RETURN_REPLY_CODE - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
RETURN_REPLY_TEXT - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
RETURN_ROUTING_KEY - Static variable in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
ReturnHandler - Class in org.mule.transport.amqp.internal.processor
Message processor that sets the return listener for the flow, leaving it up to the endpoint to set it on the channel.
This class is also the holder of all the different return listeners of the transport.
ReturnHandler() - Constructor for class org.mule.transport.amqp.internal.processor.ReturnHandler
 
returnMessageProcessors - Variable in class org.mule.transport.amqp.internal.client.DispatchingReturnListener
 
run(AmqpConnector, Channel, String, String, AmqpMessage, long) - Method in class org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherAction
 
run(AmqpConnector, Channel, String, String, AmqpMessage, long) - Method in class org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherActionDispatch
 
run(AmqpConnector, Channel, String, String, AmqpMessage, long) - Method in class org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherActionSend
 

S

setAckMode(AckMode) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setActiveDeclarationsOnly(boolean) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setAmqpConnector(AmqpConnector) - Method in class org.mule.transport.amqp.internal.client.DispatchingReturnListener
 
setChannelHandler(ChannelHandler) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setConnectionFactory(ConnectionFactory) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setDefaultReturnEndpoint(EndpointBuilder) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setDeliveryMode(DeliveryMode) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setDeliveryMode(DeliveryMode) - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
setEndpoint(URI, Properties) - Method in class org.mule.transport.amqp.internal.client.UrlEndpointURIBuilder
 
setExclusiveConsumers(boolean) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setExplicitTrustStoreOnly(boolean) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setFallbackAddresses(String[]) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setHost(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setImmediate(boolean) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setKeyManagerAlgorithm(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setKeyPassword(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setKeyStore(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setKeyStorePassword(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setKeyStoreType(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setMandatory(boolean) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setMessageProcessors(List<MessageProcessor>) - Method in class org.mule.transport.amqp.internal.processor.ReturnHandler
 
setMuleContext(MuleContext) - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransactionFactoryRegistor
 
setMultiple(boolean) - Method in class org.mule.transport.amqp.internal.processor.Acknowledger
 
setNoLocal(boolean) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setNumberOfChannels(int) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setPassword(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setPort(int) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setPrefetchCount(int) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setPrefetchSize(int) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setPriority(Byte) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setPriority(int) - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
setPriorityWeighting(int) - Method in class org.mule.transport.amqp.internal.transformer.AbstractAmqpMessageToObject
 
setRecoverStrategy(AmqpTransaction.RecoverStrategy) - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransactionFactory
 
setReplyTo(String) - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
setRequestBrokerConfirms(boolean) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setRequestedHeartbeat(int) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setRequeue(boolean) - Method in class org.mule.transport.amqp.internal.processor.Recover
 
setRequeue(boolean) - Method in class org.mule.transport.amqp.internal.processor.Rejecter
 
setSslProtocol(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setSslTrustManager(TrustManager) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setTrustManagerAlgorithm(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setTrustManagerFactory(TrustManagerFactory) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setTrustStore(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setTrustStorePassword(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setTrustStoreType(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpsConnector
 
setUsername(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
setVirtualHost(String) - Method in class org.mule.transport.amqp.internal.connector.AmqpConnector
 
shouldCloseChannel() - Method in class org.mule.transport.amqp.internal.transaction.AmqpTransaction
 
subReceivers - Variable in class org.mule.transport.amqp.internal.endpoint.receiver.MultiChannelMessageReceiver
 

T

toString() - Method in class org.mule.transport.amqp.internal.client.AbstractAmqpReturnHandlerListener
 
toString() - Method in class org.mule.transport.amqp.internal.domain.AmqpMessage
 
transformMessage(MuleMessage, String) - Method in class org.mule.transport.amqp.internal.transformer.AmqpMessageToObject
 
transformMessage(MuleMessage, String) - Method in class org.mule.transport.amqp.internal.transformer.ObjectToAmqpMessage
 

U

urlEncode(MuleEvent, String) - Method in class org.mule.transport.amqp.internal.connector.ReplyToHandler
 
UrlEndpointURIBuilder - Class in org.mule.transport.amqp.internal.client
This builder takes care of the cases where the URI has an empty host component but has the authority component filled.
UrlEndpointURIBuilder() - Constructor for class org.mule.transport.amqp.internal.client.UrlEndpointURIBuilder
 

V

valueOf(String) - Static method in enum org.mule.transport.amqp.internal.domain.AckMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.mule.transport.amqp.internal.domain.DeliveryMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.mule.transport.amqp.internal.transaction.AmqpTransaction.RecoverStrategy
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.mule.transport.amqp.internal.domain.AckMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.mule.transport.amqp.internal.domain.DeliveryMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.mule.transport.amqp.internal.transaction.AmqpTransaction.RecoverStrategy
Returns an array containing the constants of this enum type, in the order they are declared.

A B C D E F G H I L M N O P Q R S T U V

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