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 and 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`

Copyright © 2021 The Apache Software Foundation. All rights reserved.