|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esperio.amqp.AMQPSource
public class AMQPSource
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 |
---|
protected EPDataFlowEmitter graphContext
Constructor Detail |
---|
public AMQPSource()
Method Detail |
---|
public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context) throws java.lang.Exception
initialize
in interface DataFlowOpLifecycle
java.lang.Exception
public void open(DataFlowOpOpenContext openContext)
open
in interface DataFlowOpLifecycle
public void next() throws java.lang.InterruptedException
next
in interface DataFlowSourceOperator
java.lang.InterruptedException
public void close(DataFlowOpCloseContext openContext)
close
in interface DataFlowOpLifecycle
|
© 2006-2014 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |