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 false
public 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 false
Copyright © 2021 Eclipse. All rights reserved.