org.mule.transport.amqp.internal.processor
Class AbstractChannelMessageProcessor
java.lang.Object
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.
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 |
channelHandler
protected ChannelHandler channelHandler
AbstractChannelMessageProcessor
public AbstractChannelMessageProcessor()
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.