InternalStreamsLifeCycleChain (Azkarra Streams 0.7.0 API)

java.lang.Object
- io.streamthoughts.azkarra.api.streams.InternalStreamsLifeCycleChain

All Implemented Interfaces:: StreamsLifecycleChain

public class InternalStreamsLifeCycleChain
extends Object
implements StreamsLifecycleChain

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static interface InternalStreamsLifeCycleChain.Callback

Constructor Summary

Constructors
Constructor	Description
`InternalStreamsLifeCycleChain(Iterator<StreamsLifecycleInterceptor> interceptors, InternalStreamsLifeCycleChain.Callback callback, Runnable runnable)`	Creates a new `InternalStreamsLifeCycleChain` instance.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method Description

void execute()
Executes the operation on the current KafkaStreams instance.
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - InternalStreamsLifeCycleChain
```
public InternalStreamsLifeCycleChain(Iterator<StreamsLifecycleInterceptor> interceptors,
                                     InternalStreamsLifeCycleChain.Callback callback,
                                     Runnable runnable)
```
    Creates a new InternalStreamsLifeCycleChain instance.
    
    Parameters:
    
    interceptors - the list of StreamsLifecycleInterceptor instance.
    
    callback - the InternalStreamsLifeCycleChain.Callback to invoke on each interceptor.
    
    runnable - the Runnable to execute at the end of the chain.
- Method Detail
  - execute
```
public void execute()
```
    Executes the operation on the current KafkaStreams instance.
    
    Specified by:
    
    execute in interface StreamsLifecycleChain