org.mule.transport.amqp.internal.processor
Class AbstractChannelMessageProcessor

java.lang.Object
  extended by org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
All Implemented Interfaces:
org.mule.api.processor.MessageProcessor
Direct Known Subclasses:
Acknowledger, Recover, Rejecter

public abstract class AbstractChannelMessageProcessor
extends Object
implements org.mule.api.processor.MessageProcessor

Provides common logic to all channel aware message processors.


Field Summary
protected  ChannelHandler channelHandler
           
 
Constructor Summary
AbstractChannelMessageProcessor()
           
 
Method Summary
protected  com.rabbitmq.client.Channel getChannelOrFail(org.mule.api.MuleMessage muleMessage, String channelAction)
           
 Long getDeliveryTagFromMessage(org.mule.api.MuleMessage message)
           
protected  Long getDeliveryTagOrFail(org.mule.api.MuleMessage muleMessage, String channelAction)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.mule.api.processor.MessageProcessor
process
 

Field Detail

channelHandler

protected ChannelHandler channelHandler
Constructor Detail

AbstractChannelMessageProcessor

public AbstractChannelMessageProcessor()
Method Detail

getDeliveryTagOrFail

protected Long getDeliveryTagOrFail(org.mule.api.MuleMessage muleMessage,
                                    String channelAction)
                             throws org.mule.api.MuleException
Throws:
org.mule.api.MuleException

getChannelOrFail

protected com.rabbitmq.client.Channel getChannelOrFail(org.mule.api.MuleMessage muleMessage,
                                                       String channelAction)
                                                throws org.mule.api.MuleException
Throws:
org.mule.api.MuleException

getDeliveryTagFromMessage

public Long getDeliveryTagFromMessage(org.mule.api.MuleMessage message)


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