Class CompositeStateListener
- java.lang.Object
-
- io.streamthoughts.azkarra.api.streams.listener.CompositeStateListener
-
- All Implemented Interfaces:
KafkaStreamsContainerAware
,org.apache.kafka.streams.KafkaStreams.StateListener
public class CompositeStateListener extends Object implements org.apache.kafka.streams.KafkaStreams.StateListener, KafkaStreamsContainerAware
AKafkaStreams.StateListener
that delegates to one or moreKafkaStreams.StateListener
in order.
-
-
Constructor Summary
Constructors Constructor Description CompositeStateListener()
Creates a newCompositeStateListener
instance.CompositeStateListener(Collection<org.apache.kafka.streams.KafkaStreams.StateListener> delegates)
Creates a newCompositeStateListener
instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CompositeStateListener
addListener(org.apache.kafka.streams.KafkaStreams.StateListener listener)
void
onChange(org.apache.kafka.streams.KafkaStreams.State newState, org.apache.kafka.streams.KafkaStreams.State oldState)
void
setKafkaStreamsContainer(KafkaStreamsContainer container)
Sets the KafkaStreamsContainer that this object runs in.
-
-
-
Constructor Detail
-
CompositeStateListener
public CompositeStateListener()
Creates a newCompositeStateListener
instance.
-
CompositeStateListener
public CompositeStateListener(Collection<org.apache.kafka.streams.KafkaStreams.StateListener> delegates)
Creates a newCompositeStateListener
instance.- Parameters:
delegates
- the list ofCompositeStateListener
.
-
-
Method Detail
-
addListener
public CompositeStateListener addListener(org.apache.kafka.streams.KafkaStreams.StateListener listener)
-
onChange
public void onChange(org.apache.kafka.streams.KafkaStreams.State newState, org.apache.kafka.streams.KafkaStreams.State oldState)
- Specified by:
onChange
in interfaceorg.apache.kafka.streams.KafkaStreams.StateListener
-
setKafkaStreamsContainer
public void setKafkaStreamsContainer(KafkaStreamsContainer container)
Sets the KafkaStreamsContainer that this object runs in.- Specified by:
setKafkaStreamsContainer
in interfaceKafkaStreamsContainerAware
- Parameters:
container
- theKafkaStreamsContainer
.
-
-