public class QueueOptions extends Object
RabbitMQClient.basicConsumer(String, QueueOptions, Handler)| Constructor and Description |
|---|
QueueOptions() |
QueueOptions(JsonObject json) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
isAutoAck() |
boolean |
isKeepMostRecent() |
int |
maxInternalQueueSize() |
QueueOptions |
setAutoAck(boolean autoAck) |
QueueOptions |
setKeepMostRecent(boolean keepMostRecent) |
QueueOptions |
setMaxInternalQueueSize(int maxInternalQueueSize) |
public QueueOptions()
public QueueOptions(JsonObject json)
public QueueOptions setAutoAck(boolean autoAck)
autoAck - true if the server should consider messages
acknowledged once delivered; false if the server should expect
explicit acknowledgementspublic QueueOptions setKeepMostRecent(boolean keepMostRecent)
keepMostRecent - true for discarding old messages instead of recent ones,
otherwise use falsepublic QueueOptions setMaxInternalQueueSize(int maxInternalQueueSize)
maxInternalQueueSize - the size of internal queuepublic boolean isAutoAck()
public int maxInternalQueueSize()
public boolean isKeepMostRecent()
true if old messages will be discarded instead of recent ones,
otherwise use falseCopyright © 2021 Eclipse. All rights reserved.