def subscribe(self, destination, id, ack='auto', headers={}, **keyword_headers):
        assert destination is not None, "'destination' is required"
        assert id is not None, "'id' is required"
        headers = utils.merge_headers([headers, keyword_headers])
        headers[HDR_DESTINATION] = destination
        headers[HDR_ID] = id
        headers[HDR_ACK] = ack
        self.send_frame(CMD_SUBSCRIBE, headers)
Subscribe to a destination
dataset/ETHPy150Open jasonrbriggs/stomp.py/stomp/protocol.py/Protocol11.subscribe