org.nuxeo.ecm.platform.importer.mqueues.mqueues

Interface MQRebalanceListener

All Known Implementing Classes:

ConsumerRunner, MQComputationRunner

public interface MQRebalanceListener

Listener to be notified on partition rebalancing.

Since:

9.2

Method Summary

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

Method Detail

onPartitionsRevoked

void onPartitionsRevoked(Collection<MQPartition> partitions)

onPartitionsAssigned

void onPartitionsAssigned(Collection<MQPartition> partitions)