JCQueue.Consumer (Storm 2.7.1 API)

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