public void close()

in rcomp-kafka/src/main/java/org/apache/karaf/rcomp/kafka/KafkaDestination.java [94:100]

• 7 lines of code
• 2 McCabe index (conditional complexity)

    public void close() {
        if (subscription != null) {
            subscription.cancel();
            subscription = null;
        }
        this.producer.close();
    }