diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2021-03-22 20:02:10 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2021-03-22 20:03:30 +0300 |
| commit | 65969888445b7dddf30c6b70f16b213270b2981d (patch) | |
| tree | 5c1c4da53b0502957943820ecac7631d3b3b7a91 | |
| parent | 5c6c5205e297dc43383fe826f40e61435264fd1e (diff) | |
| download | rabbitmq-server-git-65969888445b7dddf30c6b70f16b213270b2981d.tar.gz | |
STOMP: remove a flaky Python test already covered in Erlang
(cherry picked from commit 1587e080b9df60a7038474b321f9a7f25c34ede9)
| -rw-r--r-- | deps/rabbitmq_stomp/test/python_SUITE_data/src/destinations.py | 29 |
1 files changed, 0 insertions, 29 deletions
diff --git a/deps/rabbitmq_stomp/test/python_SUITE_data/src/destinations.py b/deps/rabbitmq_stomp/test/python_SUITE_data/src/destinations.py index 4ad4bd3c1c..c527b1759b 100644 --- a/deps/rabbitmq_stomp/test/python_SUITE_data/src/destinations.py +++ b/deps/rabbitmq_stomp/test/python_SUITE_data/src/destinations.py @@ -296,35 +296,6 @@ class TestTopic(base.BaseTest): class TestReplyQueue(base.BaseTest): - def test_reply_queue(self): - ''' Test with two separate clients. Client 1 sends - a message to a known destination with a defined reply - queue. Client 2 receives on known destination and replies - on the reply destination. Client 1 gets the reply message''' - - known = '/queue/known' - reply = '/temp-queue/0' - - ## Client 1 uses pre-supplied connection and listener - ## Set up client 2 - conn2, listener2 = self.create_subscriber_connection(known) - - try: - self.conn.send(known, "test", - headers = {"reply-to": reply}) - - self.assertTrue(listener2.wait_for_complete_countdown()) - self.assertEqual(1, len(listener2.messages)) - - reply_to = listener2.messages[0]['headers']['reply-to'] - self.assertTrue(reply_to.startswith('/reply-queue/')) - - conn2.send(reply_to, "reply") - self.assertTrue(self.listener.wait_for_complete_countdown()) - self.assertEqual("reply", self.listener.messages[0]['message']) - finally: - conn2.disconnect() - def test_durable_known_reply_queue(self): '''As test_reply_queue, but with a non-temp reply queue''' |
