public Delivery nextDelivery()

in flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/QueueingConsumer.java [120:123]


    public Delivery nextDelivery(long timeout)
            throws InterruptedException, ShutdownSignalException, ConsumerCancelledException {
        return nextDelivery(timeout, TimeUnit.MILLISECONDS);
    }