Package com.espertech.esperio.amqp
Class AMQPSinkForge
java.lang.Object
com.espertech.esperio.amqp.AMQPSinkForge
- All Implemented Interfaces:
com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorForge
public class AMQPSinkForge
extends Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorForge
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptioncom.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpForgeInitializeResult
initializeForge
(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpForgeInitializeContext context) com.espertech.esper.common.internal.bytecodemodel.model.expression.CodegenExpression
make
(com.espertech.esper.common.internal.bytecodemodel.base.CodegenMethodScope parent, com.espertech.esper.common.internal.context.aifactory.core.SAIFFInitializeSymbol symbols, com.espertech.esper.common.internal.bytecodemodel.base.CodegenClassScope classScope)
-
Constructor Details
-
AMQPSinkForge
public AMQPSinkForge()
-
-
Method Details
-
initializeForge
public com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpForgeInitializeResult initializeForge(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpForgeInitializeContext context) throws com.espertech.esper.common.internal.epl.expression.core.ExprValidationException - Specified by:
initializeForge
in interfacecom.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorForge
- Throws:
com.espertech.esper.common.internal.epl.expression.core.ExprValidationException
-
make
public com.espertech.esper.common.internal.bytecodemodel.model.expression.CodegenExpression make(com.espertech.esper.common.internal.bytecodemodel.base.CodegenMethodScope parent, com.espertech.esper.common.internal.context.aifactory.core.SAIFFInitializeSymbol symbols, com.espertech.esper.common.internal.bytecodemodel.base.CodegenClassScope classScope) - Specified by:
make
in interfacecom.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorForge
-