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 Modifier and Type Field Description private java.util.Map<java.lang.String,java.lang.Object>
arguments
private boolean
autoAck
private Consumer
consumer
private java.lang.String
consumerTag
private boolean
exclusive
private java.lang.String
queue
-
Fields inherited from class com.rabbitmq.client.impl.recovery.RecordedEntity
channel
-
-
Constructor Summary
Constructors Constructor Description RecordedConsumer(AutorecoveringChannel channel, java.lang.String queue)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RecordedConsumer
arguments(java.util.Map<java.lang.String,java.lang.Object> value)
RecordedConsumer
autoAck(boolean value)
RecordedConsumer
consumer(Consumer value)
RecordedConsumer
consumerTag(java.lang.String value)
RecordedConsumer
exclusive(boolean value)
java.lang.String
getConsumerTag()
java.lang.String
getQueue()
java.lang.String
recover()
void
setQueue(java.lang.String queue)
java.lang.String
toString()
-
Methods inherited from class com.rabbitmq.client.impl.recovery.RecordedEntity
getChannel, getDelegateChannel
-
-
-
-
Field Detail
-
queue
private java.lang.String queue
-
consumerTag
private java.lang.String consumerTag
-
consumer
private Consumer consumer
-
exclusive
private boolean exclusive
-
autoAck
private boolean autoAck
-
arguments
private java.util.Map<java.lang.String,java.lang.Object> arguments
-
-
Constructor Detail
-
RecordedConsumer
public RecordedConsumer(AutorecoveringChannel channel, java.lang.String queue)
-
-
Method Detail
-
consumerTag
public RecordedConsumer consumerTag(java.lang.String value)
-
consumer
public RecordedConsumer consumer(Consumer value)
-
exclusive
public RecordedConsumer exclusive(boolean value)
-
autoAck
public RecordedConsumer autoAck(boolean value)
-
recover
public java.lang.String recover() throws java.io.IOException
- Throws:
java.io.IOException
-
arguments
public RecordedConsumer arguments(java.util.Map<java.lang.String,java.lang.Object> value)
-
getQueue
public java.lang.String getQueue()
-
setQueue
public void setQueue(java.lang.String queue)
-
getConsumerTag
public java.lang.String getConsumerTag()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-