org.mule.transport.amqp.internal.processor
Class Rejecter
java.lang.Object
org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
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
|
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
requeue
protected boolean requeue
Rejecter
public Rejecter()
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.