Uses of Interface
org.nuxeo.lib.stream.log.RebalanceListener

Packages that use RebalanceListener

Package	Description
org.nuxeo.lib.stream.computation.log	Computation pattern implemented with Log
org.nuxeo.lib.stream.log	The Log interface with In-Memory and Kafka implementation.
org.nuxeo.lib.stream.log.internals
org.nuxeo.lib.stream.log.kafka
org.nuxeo.lib.stream.log.mem
org.nuxeo.lib.stream.pattern.consumer.internals

Uses of RebalanceListener in org.nuxeo.lib.stream.computation.log

Classes in org.nuxeo.lib.stream.computation.log that implement RebalanceListener

Modifier and Type	Class	Description
class	ComputationRunner	Thread driving a Computation

Methods in org.nuxeo.lib.stream.computation.log with parameters of type RebalanceListener

Modifier and Type	Method	Description
LogTailer<Record>	LogStreamManager.subscribe(Name computationName, Collection<Name> streams, RebalanceListener listener)

Uses of RebalanceListener in org.nuxeo.lib.stream.log

Methods in org.nuxeo.lib.stream.log with parameters of type RebalanceListener

Modifier and Type	Method	Description
default <M extends Externalizable> LogTailer<M>	LogManager.subscribe(String group, Collection<String> names, RebalanceListener listener)	Deprecated. since 11.1 use LogManager.subscribe(Name, Collection, RebalanceListener) instead
default <M extends Externalizable> LogTailer<M>	LogManager.subscribe(String group, Collection<String> names, RebalanceListener listener, Codec<M> codec)	Deprecated. since 11.1 use LogManager.subscribe(Name, Collection, RebalanceListener, Codec) instead
default <M extends Externalizable> LogTailer<M>	LogManager.subscribe(Name group, Collection<Name> names, RebalanceListener listener)
<M extends Externalizable> LogTailer<M>	LogManager.subscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)	Creates a tailer for a consumer group and subscribe to multiple Logs.
<M extends Externalizable> LogTailer<M>	UnifiedLogManager.subscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)

Uses of RebalanceListener in org.nuxeo.lib.stream.log.internals

Methods in org.nuxeo.lib.stream.log.internals with parameters of type RebalanceListener

Modifier and Type	Method	Description
protected abstract <M extends Externalizable> LogTailer<M>	AbstractLogManager.doSubscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)
<M extends Externalizable> LogTailer<M>	AbstractLogManager.subscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)

Uses of RebalanceListener in org.nuxeo.lib.stream.log.kafka

Fields in org.nuxeo.lib.stream.log.kafka declared as RebalanceListener

Modifier and Type	Field	Description
protected RebalanceListener	KafkaLogTailer.listener

Methods in org.nuxeo.lib.stream.log.kafka with parameters of type RebalanceListener

Modifier and Type	Method	Description
static <M extends Externalizable> KafkaLogTailer<M>	KafkaLogTailer.createAndSubscribe(Codec<M> codec, NameResolver resolver, Collection<Name> names, Name group, Properties consumerProps, RebalanceListener listener)
protected <M extends Externalizable> LogTailer<M>	KafkaLogManager.doSubscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)

Uses of RebalanceListener in org.nuxeo.lib.stream.log.mem

Methods in org.nuxeo.lib.stream.log.mem with parameters of type RebalanceListener

Modifier and Type	Method	Description
protected <M extends Externalizable> LogTailer<M>	MemLogManager.doSubscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)

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

Classes in org.nuxeo.lib.stream.pattern.consumer.internals that implement RebalanceListener

Modifier and Type	Class	Description
class	ConsumerRunner<M extends Message>	Read messages from a tailer and drive a consumer according to its policy.