com.espertech.esperio.amqp
Class AMQPSink

java.lang.Object
  extended by com.espertech.esperio.amqp.AMQPSink
All Implemented Interfaces:
DataFlowOpLifecycle

public class AMQPSink
extends java.lang.Object
implements DataFlowOpLifecycle


Constructor Summary
AMQPSink()
           
 
Method Summary
 void close(DataFlowOpCloseContext openContext)
           
 DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
           
 void onInput(java.lang.Object event)
           
 void open(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()
Method Detail

initialize

public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
                                      throws java.lang.Exception
Specified by:
initialize in interface DataFlowOpLifecycle
Throws:
java.lang.Exception

open

public void open(DataFlowOpOpenContext openContext)
Specified by:
open in interface DataFlowOpLifecycle

onInput

public void onInput(java.lang.Object event)

close

public void close(DataFlowOpCloseContext openContext)
Specified by:
close in interface DataFlowOpLifecycle

© 2006-2011 EsperTech Inc.
All rights reserved.
Visit us at espertech.com