def consume_network_packet_messages_from_rabbitmq():
<EOL>sub = KombuSubscriber(<EOL>name,<EOL>FORWARD_BROKER_URL,<EOL>FORWARD_SSL_OPTIONS)<EOL>seconds_to_consume = <NUM_LIT><EOL>heartbeat = <NUM_LIT><EOL>serializer = "<STR_LIT:application/json>"<EOL>queue = FORWARD_QUEUE<EOL>sub.consume(<EOL>callback=recv_msg,<EOL>queue=queue,<EOL>exchange=None,<EOL>routing_key=None,<EOL>serializer=serializer,<EOL>heartbeat=heartbeat,<EOL>time_to_wait=seconds_to_consume)<EOL>log.info("<STR_LIT>".format(name))<EOL>
consume_network_packet_messages_from_rabbitmq

    Setup a ``celery_connectors.KombuSubscriber`` to consume meessages
    from the ``FORWARD_BROKER_URL`` broker in the ``FORWARD_QUEUE``
    queue.