Package | Description |
---|---|
org.nuxeo.importer.stream.consumer | |
org.nuxeo.importer.stream.message | |
org.nuxeo.lib.stream.pattern |
Here is a producer consumer pattern that relies on Log.
|
org.nuxeo.lib.stream.pattern.consumer | |
org.nuxeo.lib.stream.pattern.consumer.internals | |
org.nuxeo.lib.stream.pattern.producer | |
org.nuxeo.lib.stream.pattern.producer.internals |
Modifier and Type | Class and Description |
---|---|
class |
DocumentConsumerPool<M extends Message>
Consumer Pool that block Nuxeo listeners during import.
|
Modifier and Type | Class and Description |
---|---|
class |
BlobInfoMessage
A message holding BlobInfo.
|
class |
BlobMessage
A message holding info to build a StringBlob.
|
class |
DocumentMessage
Message that represent an immutable Nuxeo document.
|
Modifier and Type | Class and Description |
---|---|
class |
KeyValueMessage
Simple key value message.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
ConsumerRunner<M extends Message>
Read messages from a tailer and drive a consumer according to its policy.
|
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
|
Modifier and Type | Class and Description |
---|---|
class |
ProducerRunner<M extends Message>
A callable pulling a producer iterator in loop.
|
Copyright © 2018 Nuxeo. All rights reserved.