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