public static interface JCQueue.Consumer extends org.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
| Modifier and Type | Method and Description |
|---|---|
void |
accept(Object event) |
void |
flush() |
void accept(Object event)
accept in interface org.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>void flush()
throws InterruptedException
InterruptedExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.