|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |