org.mule.transport.amqp.internal.client
Class MessageConsumer
java.lang.Object
org.mule.transport.amqp.internal.client.MessageConsumer
public class MessageConsumer
- extends Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MessageConsumer
public MessageConsumer()
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.