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 RecordedConsumer
arguments(Map<String,Object> value)
RecordedConsumer
autoAck(boolean value)
RecordedConsumer
consumer(Consumer value)
RecordedConsumer
consumerTag(String value)
RecordedConsumer
exclusive(boolean value)
String
getConsumerTag()
String
getQueue()
String
recover()
void
setQueue(String queue)
String
toString()
-
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()
-
-