Class RecordedConsumer
- java.lang.Object
-
- com.rabbitmq.client.impl.recovery.RecordedEntity
-
- com.rabbitmq.client.impl.recovery.RecordedConsumer
-
public class RecordedConsumer extends RecordedEntity
- Since:
- 3.3.0
-
-
Field Summary
-
Fields inherited from class com.rabbitmq.client.impl.recovery.RecordedEntity
channel
-
-
Constructor Summary
Constructors Constructor Description RecordedConsumer(AutorecoveringChannel channel, String queue)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RecordedConsumerarguments(Map<String,Object> value)RecordedConsumerautoAck(boolean value)RecordedConsumerconsumer(Consumer value)RecordedConsumerconsumerTag(String value)RecordedConsumerexclusive(boolean value)StringgetConsumerTag()StringgetQueue()Stringrecover()voidsetQueue(String queue)StringtoString()-
Methods inherited from class com.rabbitmq.client.impl.recovery.RecordedEntity
getChannel, getDelegateChannel
-
-
-
-
Constructor Detail
-
RecordedConsumer
public RecordedConsumer(AutorecoveringChannel channel, String queue)
-
-
Method Detail
-
consumerTag
public RecordedConsumer consumerTag(String value)
-
consumer
public RecordedConsumer consumer(Consumer value)
-
exclusive
public RecordedConsumer exclusive(boolean value)
-
autoAck
public RecordedConsumer autoAck(boolean value)
-
recover
public String recover() throws IOException
- Throws:
IOException
-
arguments
public RecordedConsumer arguments(Map<String,Object> value)
-
getQueue
public String getQueue()
-
setQueue
public void setQueue(String queue)
-
getConsumerTag
public String getConsumerTag()
-
-