code: def purge_rmq(queue, logger):
      if queue is None:
          return
  
      try:
          queue.shutdown(True)
      except BaseException as exc:
          check_for_kb_interrupt()
          logger.warning(exc)
          return
      return
  
imports: import threading
  from studio.queues.rabbit_queue import RMQueue
  from studio.util.util import check_for_kb_interrupt
label_desc: Use image node_id 3 for calling a global function with example usage: purge_rmq(queue, logger) without return types