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()`

- ## Method Details

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