src/main/java/com/rapportive/storm/spout/AMQPSpout.java
/**
     * Acks the message with the AMQP broker.
     */
Acks the message with the AMQP broker.
Acks the message with the AMQP broker .
@Override
    public void ack(Object msgId) {
        if (msgId instanceof Long) {
            final long deliveryTag = (Long) msgId;
            if (amqpChannel != null) {
                try {
                    amqpChannel.basicAck(deliveryTag, false /* not multiple */);
                } catch (IOException e) {
                    log.warn("Failed to ack delivery-tag " + deliveryTag, e);
                }
            }
        } else {
            log.warn(String.format("don't know how to ack(%s: %s)", msgId.getClass().getName(), msgId));
        }
    }
@ Override public void ack ( Object msgId ) { if ( msgId instanceof Long ) { final long deliveryTag = ( Long ) msgId ; if ( amqpChannel != null ) { try { amqpChannel . basicAck ( deliveryTag , false /* not multiple */ ) ; } catch ( IOException e ) { log . warn ( "Failed to ack delivery-tag " + deliveryTag , e ) ; } } } else { log . warn ( String . format ( "don't know how to ack(%s: %s)" , msgId . getClass ( ) . getName ( ) , msgId ) ) ; } }
Acks the message with the AMQP broker.
Acks the message with the AMQP broker .