com.espertech.esperio.kafka

Class EsperIOKafkaOutputFlowControllerByAnnotatedStmt

java.lang.Object

com.espertech.esperio.kafka.EsperIOKafkaOutputFlowControllerByAnnotatedStmt

All Implemented Interfaces:

EsperIOKafkaOutputFlowController

public class EsperIOKafkaOutputFlowControllerByAnnotatedStmt
extends java.lang.Object
implements EsperIOKafkaOutputFlowController

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EsperIOKafkaOutputFlowControllerByAnnotatedStmt.KafkaOutputDefaultListener

Constructor Summary

Constructors

Constructor and Description
EsperIOKafkaOutputFlowControllerByAnnotatedStmt()

Method Summary

Modifier and Type	Method and 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 Detail

EsperIOKafkaOutputFlowControllerByAnnotatedStmt

public EsperIOKafkaOutputFlowControllerByAnnotatedStmt()

Method Detail

initialize

public void initialize(EsperIOKafkaOutputFlowControllerContext context)

Specified by:

initialize in interface EsperIOKafkaOutputFlowController

close

public void close()

Specified by:

close in interface EsperIOKafkaOutputFlowController