See: Description
Interface | Description |
---|---|
MQAppender<M extends Externalizable> |
An appender is used to append message into a MQueue.
|
MQManager<M extends Externalizable> |
Manage MQueue and give access to appender and tailers.
|
MQOffset |
A message position in a MQueue partition.
|
MQRebalanceListener |
Listener to be notified on partition rebalancing.
|
MQTailer<M extends Externalizable> |
Sequential reader for a partition or multiple partitions.
|
Class | Description |
---|---|
MQPartition |
A tuple to store MQueue name and the partition index.
|
MQRecord<M extends Externalizable> |
A MQRecord contains the message and source information.
|
Exception | Description |
---|---|
MQRebalanceException |
Exception raised during
MQTailer.read(Duration) if there is a rebalancing. |
Copyright © 2017 Nuxeo. All rights reserved.