Uses of Class
org.nuxeo.ecm.platform.importer.mqueues.consumer.ConsumerPolicy

Packages that use ConsumerPolicy

Package	Description
org.nuxeo.ecm.platform.importer.mqueues.consumer

Uses of ConsumerPolicy in org.nuxeo.ecm.platform.importer.mqueues.consumer

Fields in org.nuxeo.ecm.platform.importer.mqueues.consumer declared as ConsumerPolicy

Modifier and Type	Field and Description
static ConsumerPolicy	ConsumerPolicy.BOUNDED Consumer policy that stop on starvation and failure.
static ConsumerPolicy	ConsumerPolicy.UNBOUNDED Consumer policy that wait for ever for new message and skip failure.

Methods in org.nuxeo.ecm.platform.importer.mqueues.consumer that return ConsumerPolicy

Modifier and Type	Method and Description
ConsumerPolicy	ConsumerPolicy.Builder.build()

Constructors in org.nuxeo.ecm.platform.importer.mqueues.consumer with parameters of type ConsumerPolicy

Constructor and Description
ConsumerPool(MQueues<M> qm, ConsumerFactory<M> factory, ConsumerPolicy policy)
ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, MQueues.Tailer<M> tailer)
DocumentConsumerPool(MQueues<M> qm, ConsumerFactory<M> factory, ConsumerPolicy policy)