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
    --- | --- | ---
    `void` | `accept​(Object event)` |
    `void` | `flush()` |

- - ### Method Detail

    - #### accept

          void accept​(Object event)

      Specified by:
        `accept` in interface `org.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>`

    - #### flush

          void flush()
              throws InterruptedException

      Throws:
        `InterruptedException`