public void onStop()

in pulsar-spark/src/main/java/org/apache/pulsar/spark/SparkStreamingPulsarReceiver.java [96:107]

• 12 lines of code
• 4 McCabe index (conditional complexity)

    public void onStop() {
        try {
            if (consumer != null) {
                consumer.close();
            }
            if (pulsarClient != null) {
                pulsarClient.close();
            }
        } catch (PulsarClientException e) {
            LOG.error("Failed to close client : {}", e.getMessage());
        }
    }