Method publish

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

Blocking call. Retries till it can successfully publish the obj. Can be interrupted via Thread.interrupt().

(Object obj)

     * Blocking call. Retries till it can successfully publish the obj. Can be interrupted via Thread.interrupt().
     */
    public void publish(Object obj) throws InterruptedException {
        Inserter inserter = getInserter();
        inserter.publish(obj);
    }

    /**
     * Non-blocking call, returns false if full.