org.mule.transport.amqp.internal.client
Class DispatchingReturnListener

java.lang.Object
  extended by org.mule.transport.amqp.internal.client.AbstractAmqpReturnHandlerListener
      extended by org.mule.transport.amqp.internal.client.DispatchingReturnListener
All Implemented Interfaces:
com.rabbitmq.client.ReturnListener

public class DispatchingReturnListener
extends AbstractAmqpReturnHandlerListener


Field Summary
protected  AmqpConnector amqpConnector
           
protected  org.mule.api.construct.FlowConstruct eventFlowConstruct
           
protected  List<org.mule.api.processor.MessageProcessor> returnMessageProcessors
           
 
Constructor Summary
DispatchingReturnListener(List<org.mule.api.processor.MessageProcessor> returnMessageProcessors, AmqpConnectorFlowConstruct flowConstruct)
           
DispatchingReturnListener(List<org.mule.api.processor.MessageProcessor> returnMessageProcessors, org.mule.api.MuleEvent event)
           
 
Method Summary
protected  void doHandleReturn(String errorMessage, Map<String,Object> returnContext, AmqpMessage returnedAmqpMessage)
           
 void setAmqpConnector(AmqpConnector amqpConnector)
           
 
Methods inherited from class org.mule.transport.amqp.internal.client.AbstractAmqpReturnHandlerListener
handleReturn, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

eventFlowConstruct

protected final org.mule.api.construct.FlowConstruct eventFlowConstruct

returnMessageProcessors

protected final List<org.mule.api.processor.MessageProcessor> returnMessageProcessors

amqpConnector

protected volatile AmqpConnector amqpConnector
Constructor Detail

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)
Method Detail

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.