summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2021-03-22 20:02:10 +0300
committerMichael Klishin <michael@clojurewerkz.org>2021-03-22 20:03:30 +0300
commit65969888445b7dddf30c6b70f16b213270b2981d (patch)
tree5c1c4da53b0502957943820ecac7631d3b3b7a91
parent5c6c5205e297dc43383fe826f40e61435264fd1e (diff)
downloadrabbitmq-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.py29
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'''