Uses of Interface
org.nuxeo.lib.stream.pattern.consumer.Consumer

Packages that use Consumer

Package	Description
org.nuxeo.importer.stream.consumer
org.nuxeo.lib.stream.pattern.consumer
org.nuxeo.lib.stream.pattern.consumer.internals

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

Classes in org.nuxeo.importer.stream.consumer that implement Consumer

Modifier and Type	Class	Description
class	BlobMessageConsumer	Import BlobMessage into a Nuxeo BlobProvider, persist BlobInformation.
class	BlobWatermarkMessageConsumer	Consume blobMessages and generate new blob by adding a unique watermark.
class	DocumentMessageConsumer	Consumes DocumentMessage and produce Nuxeo document.
class	RedisDocumentMessageConsumer	Consumes DocumentMessage and send them to Redis which can be used as Gatling feeder.

Methods in org.nuxeo.importer.stream.consumer that return Consumer

Modifier and Type	Method	Description
Consumer<BlobMessage>	BlobMessageConsumerFactory.createConsumer(String consumerId)
Consumer<DocumentMessage>	DocumentMessageConsumerFactory.createConsumer(String consumerId)
Consumer<DocumentMessage>	RedisDocumentMessageConsumerFactory.createConsumer(String consumerId)

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

Classes in org.nuxeo.lib.stream.pattern.consumer that implement Consumer

Modifier and Type	Class	Description
class	AbstractConsumer<M extends Message>

Methods in org.nuxeo.lib.stream.pattern.consumer that return Consumer

Modifier and Type	Method	Description
Consumer<M>	ConsumerFactory.createConsumer(String consumerId)

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

Fields in org.nuxeo.lib.stream.pattern.consumer.internals declared as Consumer

Modifier and Type	Field	Description
protected Consumer<M>	ConsumerRunner.consumer