code: def wrap_subscribe(transport_layer, channel, callback, *args, **kwargs):
      
  
      return _wrap_subscription(
          transport_layer, transport_layer.subscribe, channel, callback, *args, **kwargs
      )
docs: Listen to a queue on the transport layer, similar to the subscribe call in
      transport/common_transport.py. Intercept all incoming messages and parse
      for recipe information.
      See common_transport.subscribe for possible additional keyword arguments.
        :param transport_layer: Reference to underlying transport object.
        :param channel:  Queue name to subscribe to.
        :param callback: Function to be called when messages are received.
                         The callback will pass three arguments,
                         a RecipeWrapper object (details below), the header as
                         a dictionary structure, and the message.
        :return: A unique subscription ID