src/main/java/com/rapportive/storm/spout/AMQPSpout.java
/**
     * Cancels the queue subscription, and disconnects from the AMQP broker.
     */
Cancels the queue subscription, and disconnects from the AMQP broker.
Cancels the queue subscription and disconnects from the AMQP broker .
@Override
    public void close() {
        try {
            if (amqpChannel != null) {
              if (amqpConsumerTag != null) {
                  amqpChannel.basicCancel(amqpConsumerTag);
              }
              amqpChannel.close();
            }
        } catch (IOException e) {
            log.warn("Error closing AMQP channel", e);
        }
        try {
            if (amqpConnection != null) {
              amqpConnection.close();
            }
        } catch (IOException e) {
            log.warn("Error closing AMQP connection", e);
        }
    }
@ Override public void close ( ) { try { if ( amqpChannel != null ) { if ( amqpConsumerTag != null ) { amqpChannel . basicCancel ( amqpConsumerTag ) ; } amqpChannel . close ( ) ; } } catch ( IOException e ) { log . warn ( "Error closing AMQP channel" , e ) ; } try { if ( amqpConnection != null ) { amqpConnection . close ( ) ; } } catch ( IOException e ) { log . warn ( "Error closing AMQP connection" , e ) ; } }
Cancels the queue subscription, and disconnects from the AMQP broker.
Cancels the queue subscription and disconnects from the AMQP broker .