org.mule.transport.amqp.internal.confirm
Class DefaultConfirmsManager

java.lang.Object
  extended by org.mule.transport.amqp.internal.confirm.DefaultConfirmsManager
All Implemented Interfaces:
ConfirmsManager

public class DefaultConfirmsManager
extends Object
implements ConfirmsManager


Constructor Summary
DefaultConfirmsManager(AmqpConnector connector)
           
 
Method Summary
 boolean awaitConfirm(com.rabbitmq.client.Channel channel, org.mule.api.MuleEvent event, long timeout, TimeUnit timeUnit)
           
 void forget(org.mule.api.MuleEvent event)
           
 void requestConfirm(com.rabbitmq.client.Channel channel, org.mule.api.MuleEvent event)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultConfirmsManager

public DefaultConfirmsManager(AmqpConnector connector)
Method Detail

requestConfirm

public void requestConfirm(com.rabbitmq.client.Channel channel,
                           org.mule.api.MuleEvent event)
                    throws Exception
Specified by:
requestConfirm in interface ConfirmsManager
Throws:
Exception

awaitConfirm

public boolean awaitConfirm(com.rabbitmq.client.Channel channel,
                            org.mule.api.MuleEvent event,
                            long timeout,
                            TimeUnit timeUnit)
Specified by:
awaitConfirm in interface ConfirmsManager

forget

public void forget(org.mule.api.MuleEvent event)
Specified by:
forget in interface ConfirmsManager


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