com.espertech.esperio.amqp
Class AMQPSource

java.lang.Object
  extended by com.espertech.esperio.amqp.AMQPSource
All Implemented Interfaces:
DataFlowOpLifecycle, DataFlowSourceOperator

public class AMQPSource
extends java.lang.Object
implements DataFlowSourceOperator


Field Summary
protected  EPDataFlowEmitter graphContext
           
 
Constructor Summary
AMQPSource()
           
 
Method Summary
 void close(DataFlowOpCloseContext openContext)
           
 DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
           
 void next()
           
 void open(DataFlowOpOpenContext openContext)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

graphContext

protected EPDataFlowEmitter graphContext
Constructor Detail

AMQPSource

public AMQPSource()
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

next

public void next()
          throws java.lang.InterruptedException
Specified by:
next in interface DataFlowSourceOperator
Throws:
java.lang.InterruptedException

close

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

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