org.nuxeo.ecm.platform.importer.mqueues.pattern.consumer.internals

Class ConsumerRunner<M extends Message>

java.lang.Object

org.nuxeo.ecm.platform.importer.mqueues.pattern.consumer.internals.ConsumerRunner<M>

All Implemented Interfaces:

Callable<ConsumerStatus>, MQRebalanceListener

public class ConsumerRunner<M extends Message>
extends Object
implements Callable<ConsumerStatus>, MQRebalanceListener

Read messages from a tailer and drive a consumer according to its policy.

Since:

9.1

Field Summary

Fields

Modifier and Type	Field and Description
protected com.codahale.metrics.Timer	acceptTimer
protected com.codahale.metrics.Timer	batchCommitTimer
protected com.codahale.metrics.Counter	batchFailureCount
protected com.codahale.metrics.Counter	committedCounter
protected com.codahale.metrics.Counter	consumersCount
static String	NUXEO_METRICS_REGISTRY_NAME
protected com.codahale.metrics.MetricRegistry	registry

Constructor Summary

Constructors

Constructor and Description
ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, MQManager<M> manager, List<MQPartition> defaultAssignments)

Method Summary

Modifier and Type	Method and Description
ConsumerStatus	call()
void	onPartitionsAssigned(Collection<MQPartition> partitions)
void	onPartitionsRevoked(Collection<MQPartition> partitions)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NUXEO_METRICS_REGISTRY_NAME

public static final String NUXEO_METRICS_REGISTRY_NAME

See Also:

Constant Field Values

registry

protected final com.codahale.metrics.MetricRegistry registry

acceptTimer

protected com.codahale.metrics.Timer acceptTimer

committedCounter

protected com.codahale.metrics.Counter committedCounter

batchCommitTimer

protected com.codahale.metrics.Timer batchCommitTimer

batchFailureCount

protected com.codahale.metrics.Counter batchFailureCount

consumersCount

protected com.codahale.metrics.Counter consumersCount

Constructor Detail

ConsumerRunner

public ConsumerRunner(ConsumerFactory<M> factory,
                      ConsumerPolicy policy,
                      MQManager<M> manager,
                      List<MQPartition> defaultAssignments)

Method Detail

call

public ConsumerStatus call()
                    throws Exception

Specified by:

call in interface Callable<ConsumerStatus>

Throws:

Exception

onPartitionsRevoked

public void onPartitionsRevoked(Collection<MQPartition> partitions)

Specified by:

onPartitionsRevoked in interface MQRebalanceListener

onPartitionsAssigned

public void onPartitionsAssigned(Collection<MQPartition> partitions)

Specified by:

onPartitionsAssigned in interface MQRebalanceListener