org.mule.transport.amqp.internal.client
Class DispatchingReturnListener
java.lang.Object
org.mule.transport.amqp.internal.client.AbstractAmqpReturnHandlerListener
org.mule.transport.amqp.internal.client.DispatchingReturnListener
- All Implemented Interfaces:
- com.rabbitmq.client.ReturnListener
public class DispatchingReturnListener
- extends AbstractAmqpReturnHandlerListener
eventFlowConstruct
protected final org.mule.api.construct.FlowConstruct eventFlowConstruct
returnMessageProcessors
protected final List<org.mule.api.processor.MessageProcessor> returnMessageProcessors
amqpConnector
protected volatile AmqpConnector amqpConnector
DispatchingReturnListener
public DispatchingReturnListener(List<org.mule.api.processor.MessageProcessor> returnMessageProcessors,
org.mule.api.MuleEvent event)
DispatchingReturnListener
public DispatchingReturnListener(List<org.mule.api.processor.MessageProcessor> returnMessageProcessors,
AmqpConnectorFlowConstruct flowConstruct)
setAmqpConnector
public void setAmqpConnector(AmqpConnector amqpConnector)
doHandleReturn
protected void doHandleReturn(String errorMessage,
Map<String,Object> returnContext,
AmqpMessage returnedAmqpMessage)
- Specified by:
doHandleReturn
in class AbstractAmqpReturnHandlerListener
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.