com.espertech.esperio.amqp

Class AMQPSink

java.lang.Object

com.espertech.esperio.amqp.AMQPSink

All Implemented Interfaces:

com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle

public class AMQPSink
extends java.lang.Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle

Constructor Summary

Constructors

Constructor and Description
AMQPSink(AMQPSettingsSinkValues settings)

Method Summary

Modifier and Type	Method and Description
void	close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext openContext)
void	onInput(java.lang.Object event)
void	open(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpOpenContext openContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPSink

public AMQPSink(AMQPSettingsSinkValues settings)

Method Detail

open

public void open(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpOpenContext openContext)

Specified by:

open in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle

onInput

public void onInput(java.lang.Object event)

close

public void close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext openContext)

Specified by:

close in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle