Class Hierarchy
- java.lang.Object
- org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool<T> (implements java.lang.AutoCloseable)
- org.nuxeo.lib.stream.pattern.consumer.ConsumerPool<M>
- org.nuxeo.importer.stream.consumer.DocumentConsumerPool<M>
- org.nuxeo.lib.stream.pattern.consumer.ConsumerPool<M>
- org.nuxeo.lib.stream.pattern.consumer.AbstractConsumer<M> (implements org.nuxeo.lib.stream.pattern.consumer.Consumer<M>)
- org.nuxeo.importer.stream.consumer.BlobMessageConsumer
- org.nuxeo.importer.stream.consumer.BlobWatermarkMessageConsumer
- org.nuxeo.importer.stream.consumer.DocumentMessageConsumer
- org.nuxeo.importer.stream.consumer.RedisDocumentMessageConsumer
- org.nuxeo.importer.stream.consumer.BlobMessageConsumer
- org.nuxeo.importer.stream.consumer.BlobMessageConsumer.CloseableBlob (implements java.lang.AutoCloseable)
- org.nuxeo.importer.stream.consumer.BlobMessageConsumerFactory (implements org.nuxeo.lib.stream.pattern.consumer.ConsumerFactory<M>)
- org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicy
- org.nuxeo.importer.stream.consumer.DocumentConsumerPolicy
- org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicyBuilder
- org.nuxeo.importer.stream.consumer.DocumentConsumerPolicyBuilder
- org.nuxeo.importer.stream.consumer.DocumentMessageConsumerFactory (implements org.nuxeo.lib.stream.pattern.consumer.ConsumerFactory<M>)
- org.nuxeo.importer.stream.consumer.LogBlobInfoWriter (implements org.nuxeo.importer.stream.consumer.BlobInfoWriter)
- org.nuxeo.importer.stream.consumer.RedisDocumentMessageConsumerFactory (implements org.nuxeo.lib.stream.pattern.consumer.ConsumerFactory<M>)
- org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool<T> (implements java.lang.AutoCloseable)
Interface Hierarchy
- java.lang.AutoCloseable
- org.nuxeo.importer.stream.consumer.BlobInfoWriter