diff --git a/deps/rabbitmq_stomp/test/python_SUITE_data/src/parsing.py b/deps/rabbitmq_stomp/test/python_SUITE_data/src/parsing.py index d7e58ed22382..c2310c62f11a 100644 --- a/deps/rabbitmq_stomp/test/python_SUITE_data/src/parsing.py +++ b/deps/rabbitmq_stomp/test/python_SUITE_data/src/parsing.py @@ -182,7 +182,7 @@ def test_bad_command(self): def test_broadcast(self): ''' Single message should be delivered to two consumers: amq.topic --routing_key--> first_queue --> first_connection - \--routing_key--> second_queue--> second_connection + \\--routing_key--> second_queue--> second_connection ''' subscribe=( 'SUBSCRIBE\n' 'id: XsKNhAf\n' @@ -336,4 +336,4 @@ def test_message_in_packets(self): modules = [ __name__ ] - test_runner.run_unittests(modules) \ No newline at end of file + test_runner.run_unittests(modules) diff --git a/deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py b/deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py index 6bddac673c47..2aed99ec31f9 100644 --- a/deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py +++ b/deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py @@ -36,7 +36,7 @@ def test_exchange_dest(self): body='Hello World!') # check if we receive the message from the STOMP subscription - self.assertTrue(self.listener.wait(2), "initial message not received") + self.assertTrue(self.listener.wait(5), "initial message not received") self.assertEqual(1, len(self.listener.messages)) self.conn.disconnect() @@ -64,7 +64,7 @@ def test_topic_dest(self): body='Hello World!') # check if we receive the message from the STOMP subscription - self.assertTrue(self.listener.wait(2), "initial message not received") + self.assertTrue(self.listener.wait(5), "initial message not received") self.assertEqual(1, len(self.listener.messages)) self.conn.disconnect() @@ -76,4 +76,4 @@ def test_topic_dest(self): modules = [ __name__ ] - test_runner.run_unittests(modules) \ No newline at end of file + test_runner.run_unittests(modules)