Modifier and Type | Class and Description |
---|---|
class |
AbstractConsumer<M extends Message> |
interface |
Consumer<M extends Message>
A consumer consumes
Message by batch. |
interface |
ConsumerFactory<M extends Message> |
class |
ConsumerPool<M extends Message>
Run a pool of ConsumerRunner.
|
class |
ConsumerRunner<M extends Message>
Read messages from a tailer and drive a consumer according to its policy.
|
class |
DocumentConsumerPool<M extends Message>
Block Nuxeo listeners during import.
|
Modifier and Type | Class and Description |
---|---|
class |
BlobMessage
A message holding info to build a StringBlob.
|
class |
DocumentMessage
Message that represent an immutable Nuxeo document.
|
class |
IdMessage
Simple message with an Id and data payload.
|
Modifier and Type | Class and Description |
---|---|
class |
CQMQueues<M extends Message>
Chronicle Queue implementation of MQueues.
|
class |
CQTailer<M extends Message> |
interface |
MQueues<M extends Message>
A MQueues (for Multiple Queues) is a set of unbounded persisted queues.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractProducer<M extends Message> |
interface |
ProducerFactory<M extends Message> |
interface |
ProducerIterator<M extends Message>
A ProducerIterator returns
Message . |
class |
ProducerPool<M extends Message>
A Pool of ProducerRunner
|
class |
ProducerRunner<M extends Message>
A callable pulling a producer iterator in loop.
|
Copyright © 2017 Nuxeo. All rights reserved.