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

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

public class Recover
extends AbstractChannelMessageProcessor

Used to manually perform a basic recover of the current channel.


Field Summary
protected  boolean requeue
           
 
Fields inherited from class org.mule.transport.amqp.internal.processor.AbstractChannelMessageProcessor
channelHandler
 
Constructor Summary
Recover()
           
 
Method Summary
 org.mule.api.MuleEvent process(org.mule.api.MuleEvent event)
           
 void recover(org.mule.api.MuleEvent event, boolean requeue)
           
 void recover(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

Recover

public Recover()
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)

recover

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

recover

public void recover(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.