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, getDelegateChannelpublic 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
IOExceptionpublic RecordedConsumer arguments(Map<String,Object> value)
public String getQueue()
public void setQueue(String queue)
public String getConsumerTag()
Copyright © 2021 VMware, Inc. or its affiliates.. All rights reserved.