Package io.micronaut.configuration.kafka.streams.event

Class AbstractKafkaStreamsEvent

java.lang.Object

java.util.EventObject

io.micronaut.context.event.ApplicationEvent

io.micronaut.configuration.kafka.event.AbstractKafkaApplicationEvent<KafkaStreams>

io.micronaut.configuration.kafka.streams.event.AbstractKafkaStreamsEvent

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

AfterKafkaStreamsStart, BeforeKafkaStreamStart

public abstract class AbstractKafkaStreamsEvent
extends AbstractKafkaApplicationEvent<KafkaStreams>

Abstract class for kafka streams events.

Since:

2.0.0

Author:

graemerocher

See Also:

• Serialized Form

Field Summary

Fields inherited from class java.util.EventObject

source

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractKafkaStreamsEvent(KafkaStreams kafkaStreams)	Default constructor.

Method Summary

Modifier and Type	Method	Description
KafkaStreams	getKafkaStreams()

Methods inherited from class io.micronaut.configuration.kafka.event.AbstractKafkaApplicationEvent

getSource

Methods inherited from class java.util.EventObject

toString

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractKafkaStreamsEvent

protected AbstractKafkaStreamsEvent(KafkaStreams kafkaStreams)

Default constructor.

Parameters:

kafkaStreams - The streams

Method Details

getKafkaStreams

public KafkaStreams getKafkaStreams()

Returns:

The kafka streams object.