Uses of Interface
io.streamthoughts.azkarra.api.StreamsLifecycleContext
-
Packages that use StreamsLifecycleContext Package Description io.streamthoughts.azkarra.api io.streamthoughts.azkarra.api.streams io.streamthoughts.azkarra.runtime.interceptors -
-
Uses of StreamsLifecycleContext in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api with parameters of type StreamsLifecycleContext Modifier and Type Method Description default void
StreamsLifecycleInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.default void
StreamsLifecycleInterceptor. onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being stopped. -
Uses of StreamsLifecycleContext in io.streamthoughts.azkarra.api.streams
Classes in io.streamthoughts.azkarra.api.streams that implement StreamsLifecycleContext Modifier and Type Class Description class
KafkaStreamsContainer.InternalStreamsLifeCycleContext
-
Uses of StreamsLifecycleContext in io.streamthoughts.azkarra.runtime.interceptors
Methods in io.streamthoughts.azkarra.runtime.interceptors with parameters of type StreamsLifecycleContext Modifier and Type Method Description void
AutoCreateTopicsInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.void
ClassloadingIsolationInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.void
CompositeStreamsInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.void
WaitForSourceTopicsInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.void
AutoCreateTopicsInterceptor. onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being stopped.void
CompositeStreamsInterceptor. onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being stopped.
-