def testclientack10(self):
        queuename = '/queue/testclientack10-%s' % self.timestamp
        self.conn.subscribe(destination=queuename, id=1, ack='client')

        self.conn.send(body='this is a test', destination=queuename)

        self.listener.wait_for_message()

        (headers, _) = self.listener.get_latest_message()

        message_id = headers['message-id']

        self.conn.ack(message_id)

        time.sleep(1)
dataset/ETHPy150Open jasonrbriggs/stomp.py/stomp/test/s10_test.py/Test10Connect.testclientack10/original