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

java.lang.Object
  extended by org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
      extended by org.mule.transport.amqp.internal.processor.Acknowledger
All Implemented Interfaces:
org.mule.api.processor.MessageProcessor

public class Acknowledger
extends AbstractChannelMessageProcessor

Used to manually perform a basic ack of the message in flow, allowing fine control of message throttling. It looks for a delivery-tag inbound message property and an amqp.channel session property. If the former is missing, it logs a warning. If the former is present but not the latter, it throws an exception.


Field Summary
protected  boolean multiple
           
 
Fields inherited from class org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
channelHandler
 
Constructor Summary
Acknowledger()
           
 
Method Summary
 void ack(org.mule.api.MuleEvent event, boolean multiple)
           
 void ack(org.mule.api.MuleMessage message, boolean multiple)
           
 org.mule.api.MuleEvent process(org.mule.api.MuleEvent event)
           
 void setMultiple(boolean multiple)
           
 
Methods inherited from class org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
getChannelOrFail, getDeliveryTagFromMessage, getDeliveryTagOrFail
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

multiple

protected boolean multiple
Constructor Detail

Acknowledger

public Acknowledger()
Method Detail

process

public org.mule.api.MuleEvent process(org.mule.api.MuleEvent event)
                               throws org.mule.api.MuleException
Throws:
org.mule.api.MuleException

setMultiple

public void setMultiple(boolean multiple)

ack

public void ack(org.mule.api.MuleEvent event,
                boolean multiple)
         throws org.mule.api.MuleException
Throws:
org.mule.api.MuleException

ack

public void ack(org.mule.api.MuleMessage message,
                boolean multiple)
         throws org.mule.api.MuleException
Throws:
org.mule.api.MuleException


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