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

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

public class Rejecter
extends AbstractChannelMessageProcessor

Used to manually perform a basic reject 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 requeue
           
 
Fields inherited from class org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
channelHandler
 
Constructor Summary
Rejecter()
           
 
Method Summary
 org.mule.api.MuleEvent process(org.mule.api.MuleEvent event)
           
 void reject(org.mule.api.MuleEvent event, boolean multiple)
           
 void reject(org.mule.api.MuleMessage message, boolean requeue)
           
 void setRequeue(boolean requeue)
           
 
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

requeue

protected boolean requeue
Constructor Detail

Rejecter

public Rejecter()
Method Detail

process

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

setRequeue

public void setRequeue(boolean requeue)

reject

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

reject

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


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