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
-
Method Details
-
accept
- Specified by:
accept
in interfaceorg.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
-
flush
- Throws:
InterruptedException
-