Uses of Class
org.mule.transport.amqp.internal.domain.AmqpMessage

Packages that use AmqpMessage
org.mule.transport.amqp.internal.client   
org.mule.transport.amqp.internal.endpoint.dispatcher   
org.mule.transport.amqp.internal.endpoint.receiver   
org.mule.transport.amqp.internal.transformer   
 

Uses of AmqpMessage in org.mule.transport.amqp.internal.client
 

Methods in org.mule.transport.amqp.internal.client that return AmqpMessage
 AmqpMessage MessageConsumer.consumeMessage(com.rabbitmq.client.Channel channel, String queue, boolean autoAck, long timeout)
           
 

Methods in org.mule.transport.amqp.internal.client with parameters of type AmqpMessage
 void MessagePropertiesHandler.ackMessageIfNecessary(com.rabbitmq.client.Channel channel, AmqpMessage amqpMessage, org.mule.api.endpoint.ImmutableEndpoint endpoint)
           
 void MessagePropertiesHandler.addInvocationProperties(com.rabbitmq.client.Channel channel, AmqpMessage amqpMessage, org.mule.api.MuleMessage muleMessage, AmqpConnector connector)
           
protected abstract  void AbstractAmqpReturnHandlerListener.doHandleReturn(String errorMessage, Map<String,Object> returnContext, AmqpMessage returnedAmqpMessage)
           
protected  void LoggingReturnListener.doHandleReturn(String errorMessage, Map<String,Object> ignored, AmqpMessage returnedAmqpMessage)
           
protected  void DispatchingReturnListener.doHandleReturn(String errorMessage, Map<String,Object> returnContext, AmqpMessage returnedAmqpMessage)
           
 

Uses of AmqpMessage in org.mule.transport.amqp.internal.endpoint.dispatcher
 

Methods in org.mule.transport.amqp.internal.endpoint.dispatcher that return AmqpMessage
protected  AmqpMessage Dispatcher.doOutboundAction(org.mule.api.MuleEvent event, DispatcherAction outboundAction)
           
abstract  AmqpMessage DispatcherAction.run(AmqpConnector amqpConnector, com.rabbitmq.client.Channel channel, String exchange, String routingKey, AmqpMessage amqpMessage, long timeout)
           
 AmqpMessage DispatcherActionDispatch.run(AmqpConnector amqpConnector, com.rabbitmq.client.Channel channel, String exchange, String routingKey, AmqpMessage amqpMessage, long timeout)
           
 AmqpMessage DispatcherActionSend.run(AmqpConnector amqpConnector, com.rabbitmq.client.Channel channel, String exchange, String routingKey, AmqpMessage amqpMessage, long timeout)
           
 

Methods in org.mule.transport.amqp.internal.endpoint.dispatcher with parameters of type AmqpMessage
abstract  AmqpMessage DispatcherAction.run(AmqpConnector amqpConnector, com.rabbitmq.client.Channel channel, String exchange, String routingKey, AmqpMessage amqpMessage, long timeout)
           
 AmqpMessage DispatcherActionDispatch.run(AmqpConnector amqpConnector, com.rabbitmq.client.Channel channel, String exchange, String routingKey, AmqpMessage amqpMessage, long timeout)
           
 AmqpMessage DispatcherActionSend.run(AmqpConnector amqpConnector, com.rabbitmq.client.Channel channel, String exchange, String routingKey, AmqpMessage amqpMessage, long timeout)
           
 

Uses of AmqpMessage in org.mule.transport.amqp.internal.endpoint.receiver
 

Methods in org.mule.transport.amqp.internal.endpoint.receiver with parameters of type AmqpMessage
protected  void MessageReceiverConsumer.deliverAmqpMessage(AmqpMessage amqpMessage)
           
 

Uses of AmqpMessage in org.mule.transport.amqp.internal.transformer
 

Fields in org.mule.transport.amqp.internal.transformer with type parameters of type AmqpMessage
static org.mule.api.transformer.DataType<AmqpMessage> AbstractAmqpMessageToObject.AMQP_MESSAGE_DATA_TYPE
           
 



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