code: def subscribe(self, destination, id, ack='auto', headers=None, **keyword_headers):
          
          self.transport.subscriptions[id] = destination
docs: :param str destination:
          :param str id:
          :param str ack:
          :param dict headers:
          :param keyword_headers: