org.mule.transport.amqp.internal.client
Class MessageConsumer

java.lang.Object
  extended by org.mule.transport.amqp.internal.client.MessageConsumer

public class MessageConsumer
extends Object


Constructor Summary
MessageConsumer()
           
 
Method Summary
 AmqpMessage consumeMessage(com.rabbitmq.client.Channel channel, String queue, boolean autoAck, long timeout)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessageConsumer

public MessageConsumer()
Method Detail

consumeMessage

public AmqpMessage consumeMessage(com.rabbitmq.client.Channel channel,
                                  String queue,
                                  boolean autoAck,
                                  long timeout)
                           throws IOException,
                                  InterruptedException
Throws:
IOException
InterruptedException


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