public class RecordedConsumer extends RecordedEntity
channel
Constructor and Description |
---|
RecordedConsumer(AutorecoveringChannel channel,
String queue) |
Modifier and Type | Method and 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() |
getChannel, getDelegateChannel
public RecordedConsumer(AutorecoveringChannel channel, String queue)
public RecordedConsumer consumerTag(String value)
public RecordedConsumer consumer(Consumer value)
public RecordedConsumer exclusive(boolean value)
public RecordedConsumer autoAck(boolean value)
public String recover() throws IOException
IOException
public RecordedConsumer arguments(Map<String,Object> value)
public String getQueue()
public void setQueue(String queue)
public String getConsumerTag()
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.