io.micronaut.configuration.kafka.streams.event

Class AbstractKafkaStreamsEvent

java.lang.Object

java.util.EventObject

io.micronaut.context.event.ApplicationEvent

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

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

AfterKafkaStreamsStart, BeforeKafkaStreamStart

public abstract class AbstractKafkaStreamsEvent
extends io.micronaut.context.event.ApplicationEvent

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 and Description
protected	AbstractKafkaStreamsEvent(org.apache.kafka.streams.KafkaStreams kafkaStreams) Default constructor.

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.streams.KafkaStreams	getKafkaStreams()
org.apache.kafka.streams.KafkaStreams	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 Detail

AbstractKafkaStreamsEvent

protected AbstractKafkaStreamsEvent(org.apache.kafka.streams.KafkaStreams kafkaStreams)

Default constructor.

Parameters:

kafkaStreams - The streams

Method Detail

getSource

public org.apache.kafka.streams.KafkaStreams getSource()

Overrides:

getSource in class java.util.EventObject

getKafkaStreams

public org.apache.kafka.streams.KafkaStreams getKafkaStreams()

Returns:

The kafka streams object.