Method accept

storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:257–257

(Object event)

    public interface Consumer extends MessagePassingQueue.Consumer<Object> {
        @Override
        void accept(Object event);

        void flush() throws InterruptedException;