root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Give a client some time to notice that connection was closed

This commit is contained in:
Michael Klishin 2015-09-16 16:24:56 +03:00
parent 6854d078f5
commit a3f3317c10
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
deps/rabbitmq_stomp/test/src/errors.py vendored
View File

@ -17,9 +17,10 @@ class TestErrorsAndCloseConnection(base.BaseTest):
errorReceived = self.listener.errors[0]
self.assertEquals("Duplicated subscription identifier", errorReceived['headers']['message'])
self.assertEquals("A subscription identified by 'T_1' alredy exists.", errorReceived['message'])
self.assertFalse(self.conn.is_connected())
time.sleep(2)
self.assertFalse(self.conn.is_connected())
def test_duplicate_consumer_tag_with_transient_destination(self):
destination = "/exchange/amq.direct/duplicate-consumer-tag-test1"
self.__test_duplicate_consumer_tag_with_headers(destination, {'id': 1})
@ -28,7 +29,7 @@ class TestErrorsAndCloseConnection(base.BaseTest):
destination = "/queue/duplicate-consumer-tag-test2"
self.__test_duplicate_consumer_tag_with_headers(destination, {'id': 1,
'persistent': True})
class TestErrors(base.BaseTest):