public class ChronicleMQManager<M extends Externalizable> extends AbstractMQManager<M>
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_RETENTION_DURATION
Default retention duration for queue files
|
Constructor and Description |
---|
ChronicleMQManager(Path basePath) |
ChronicleMQManager(Path basePath,
String retentionDuration)
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected MQTailer<M> |
acquireTailer(Collection<MQPartition> partitions,
String group) |
void |
create(String name,
int size) |
MQAppender<M> |
createAppender(String name) |
boolean |
delete(String name)
Try to delete a MQueue.
|
protected MQTailer<M> |
doSubscribe(String group,
Collection<String> names,
MQRebalanceListener listener) |
boolean |
exists(String name)
Returns
true if a MQueue with this name exists. |
String |
getBasePath() |
close, createIfNotExists, createTailer, createTailer, getAppender, subscribe, supportSubscribe
public static final String DEFAULT_RETENTION_DURATION
public ChronicleMQManager(Path basePath)
public ChronicleMQManager(Path basePath, String retentionDuration)
basePath
- the base path.retentionDuration
- the retention duration. It is the time period the queue files will be retained. Once the
retention duration expires, the older files are candidates for being purged. The property can be
expressed as: 15s, 30m, 1h, 4d ... (where 's' is expressing a duration in seconds, 'm' in minutes,'h'
in hours and 'd' in days)public String getBasePath()
public boolean exists(String name)
MQManager
true
if a MQueue with this name
exists.public void create(String name, int size)
create
in class AbstractMQManager<M extends Externalizable>
public boolean delete(String name)
MQManager
delete
in interface MQManager<M extends Externalizable>
delete
in class AbstractMQManager<M extends Externalizable>
public MQAppender<M> createAppender(String name)
createAppender
in class AbstractMQManager<M extends Externalizable>
protected MQTailer<M> acquireTailer(Collection<MQPartition> partitions, String group)
acquireTailer
in class AbstractMQManager<M extends Externalizable>
protected MQTailer<M> doSubscribe(String group, Collection<String> names, MQRebalanceListener listener)
doSubscribe
in class AbstractMQManager<M extends Externalizable>
Copyright © 2017 Nuxeo. All rights reserved.