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

    Modifier and Type
    Method
    Description
    void
    accept(Object event)
     
    void
    flush()