Package com.espertech.esperio.kafka

Class EsperIOKafkaOutputFlowControllerByAnnotatedStmt

java.lang.Object

com.espertech.esperio.kafka.EsperIOKafkaOutputFlowControllerByAnnotatedStmt

All Implemented Interfaces:

EsperIOKafkaOutputFlowController

public class EsperIOKafkaOutputFlowControllerByAnnotatedStmt
extends Object
implements EsperIOKafkaOutputFlowController

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EsperIOKafkaOutputFlowControllerByAnnotatedStmt.KafkaOutputDefaultListener

Constructor Summary

Constructors

Constructor	Description
EsperIOKafkaOutputFlowControllerByAnnotatedStmt()

Method Summary

Modifier and Type	Method	Description
void	close()
void	initialize(EsperIOKafkaOutputFlowControllerContext context)

Methods inherited from class java.lang.Object

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

Constructor Details

EsperIOKafkaOutputFlowControllerByAnnotatedStmt

public EsperIOKafkaOutputFlowControllerByAnnotatedStmt()

Method Details

initialize

public void initialize(EsperIOKafkaOutputFlowControllerContext context)

Specified by:

initialize in interface EsperIOKafkaOutputFlowController

close

public void close()

Specified by:

close in interface EsperIOKafkaOutputFlowController