Uses of Interface
org.nuxeo.lib.stream.pattern.Message

Packages that use Message

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

Uses of Message in org.nuxeo.importer.stream.consumer

Classes in org.nuxeo.importer.stream.consumer with type parameters of type Message

Modifier and Type	Class	Description
class	DocumentConsumerPool<M extends Message>	Consumer Pool that block Nuxeo listeners during import.

Uses of Message in org.nuxeo.importer.stream.message

Classes in org.nuxeo.importer.stream.message that implement Message

Modifier and Type	Class	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.

Uses of Message in org.nuxeo.lib.stream.pattern

Classes in org.nuxeo.lib.stream.pattern that implement Message

Modifier and Type	Class	Description
class	KeyValueMessage	Simple key value message.

Uses of Message in org.nuxeo.lib.stream.pattern.consumer

Classes in org.nuxeo.lib.stream.pattern.consumer with type parameters of type Message

Modifier and Type	Class	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.

Uses of Message in org.nuxeo.lib.stream.pattern.consumer.internals

Classes in org.nuxeo.lib.stream.pattern.consumer.internals with type parameters of type Message

Modifier and Type	Class	Description
class	ConsumerRunner<M extends Message>	Read messages from a tailer and drive a consumer according to its policy.

Uses of Message in org.nuxeo.lib.stream.pattern.producer

Classes in org.nuxeo.lib.stream.pattern.producer with type parameters of type Message

Modifier and Type	Class	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

Uses of Message in org.nuxeo.lib.stream.pattern.producer.internals

Classes in org.nuxeo.lib.stream.pattern.producer.internals with type parameters of type Message

Modifier and Type	Class	Description
class	ProducerRunner<M extends Message>	A callable pulling a producer iterator in loop.