Package io.streamthoughts.azkarra.runtime.interceptors

Class CompositeStreamsInterceptor

java.lang.Object

io.streamthoughts.azkarra.runtime.interceptors.CompositeStreamsInterceptor

All Implemented Interfaces:

StreamsExecutionEnvironmentAware, StreamsLifecycleInterceptor

public class CompositeStreamsInterceptor
extends Object
implements StreamsLifecycleInterceptor, StreamsExecutionEnvironmentAware

Constructor Summary

Constructors

Constructor	Description
CompositeStreamsInterceptor()	Creates a new CompositeStreamsInterceptor instance.
CompositeStreamsInterceptor(Collection<StreamsLifecycleInterceptor> interceptors)	Creates a new CompositeStreamsInterceptor instance.

Method Summary

Modifier and Type	Method	Description
void	addInterceptors(Collection<StreamsLifecycleInterceptor> interceptors)
String	name()	The Interceptor name is mostly used for logging information.
void	onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)	Intercepts the streams instance before being started.
void	onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)	Intercepts the streams instance before being stopped.
void	setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)	Set the StreamsExecutionEnvironment.

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeStreamsInterceptor

public CompositeStreamsInterceptor()

Creates a new CompositeStreamsInterceptor instance.

CompositeStreamsInterceptor

public CompositeStreamsInterceptor(Collection<StreamsLifecycleInterceptor> interceptors)

Creates a new CompositeStreamsInterceptor instance.

Parameters:

interceptors - the list of interceptors.

Method Detail

addInterceptors

public void addInterceptors(Collection<StreamsLifecycleInterceptor> interceptors)

onStart

public void onStart(StreamsLifecycleContext context,
                    StreamsLifecycleChain chain)

Intercepts the streams instance before being started.

Specified by:

onStart in interface StreamsLifecycleInterceptor

chain - the StreamsLifecycleChain instance.

onStop

public void onStop(StreamsLifecycleContext context,
                   StreamsLifecycleChain chain)

Intercepts the streams instance before being stopped.

Specified by:

onStop in interface StreamsLifecycleInterceptor

chain - the StreamsLifecycleChain instance.

setExecutionEnvironment

public void setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)

Set the StreamsExecutionEnvironment.

Specified by:

setExecutionEnvironment in interface StreamsExecutionEnvironmentAware

Parameters:

environment - the StreamsExecutionEnvironment instance

name

public String name()

The Interceptor name is mostly used for logging information.

Specified by:

name in interface StreamsLifecycleInterceptor

Returns:

the name of this interceptor.