code: def consume_network_packet_messages_from_redis():
      
      # end of recv_message
      # Initialize KombuSubscriber
      sub = KombuSubscriber(
          name,
          FORWARD_BROKER_URL,
          FORWARD_SSL_OPTIONS)
  
      # Now consume:
      seconds_to_consume = 10.0
      heartbeat = 60
      serializer = "application/json"
      queue = FORWARD_QUEUE
  
      sub.consume(
          callback=recv_msg,
          queue=queue,
          exchange=None,
          routing_key=None,
          serializer=serializer,
          heartbeat=heartbeat,
          time_to_wait=seconds_to_consume)
  
      log.info("end - {}".format(name))
docs: consume_network_packet_messages_from_redis
  
      Setup a ``celery_connectors.KombuSubscriber`` to consume meessages
      from the ``FORWARD_BROKER_URL`` broker in the ``FORWARD_QUEUE``
      queue.