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:
acceptin interfaceorg.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
-
flush
- Throws:
InterruptedException
-