void Consumer::Cleanup()

in src/Consumer.cc [490:497]

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

void Consumer::Cleanup() {
  if (this->listener != nullptr) {
    pulsar_consumer_pause_message_listener(this->cConsumer.get());
    this->listener->callback.Release();
    this->listener = nullptr;
    this->Unref();
  }
}