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