Package org.apache.storm.utils
Interface JCQueue.Consumer
-
- All Superinterfaces:
org.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
- All Known Implementing Classes:
BoltExecutor,Executor,SpoutExecutor,WorkerTransfer
- Enclosing class:
- JCQueue
public static interface JCQueue.Consumer extends org.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidaccept(Object event)voidflush()
-
-
-
Method Detail
-
accept
void accept(Object event)
- Specified by:
acceptin interfaceorg.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
-
flush
void flush() throws InterruptedException- Throws:
InterruptedException
-
-