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

changed error message to be STOMP specific

This commit is contained in:
Giuseppe Privitera 2015-09-14 17:41:09 +01:00
parent 6afdecedd3
commit d3824cfc33
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/rabbitmq_stomp/src/rabbit_stomp_processor.erl vendored
View File

@ -596,8 +596,8 @@ do_subscribe(Destination, DestHdr, Frame,
end, end,
case dict:find(ConsumerTag, Subs) of case dict:find(ConsumerTag, Subs) of
{ok, #subscription{ack_mode = AckMode}} -> {ok, #subscription{ack_mode = AckMode}} ->
Message = "Duplicated ConsumerTag", Message = "Duplicated subscription identifier",
Detail = "attempt to reuse consumer tag '~s'.", Detail = "A subscription identified by '~s' alredy exists.",
log_error(Message, rabbit_misc:format(Detail, [ConsumerTag]), none), log_error(Message, rabbit_misc:format(Detail, [ConsumerTag]), none),
send_error(Message, send_error(Message,
Detail, Detail,

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

@ -23,8 +23,8 @@ class TestErrorsAndCloseConnection(base.BaseTest):
self.assertEquals(1, len(self.listener.errors)) self.assertEquals(1, len(self.listener.errors))
errorReceived = self.listener.errors[0] errorReceived = self.listener.errors[0]
self.assertEquals("Duplicated ConsumerTag", errorReceived['headers']['message']) self.assertEquals("Duplicated subscription identifier", errorReceived['headers']['message'])
self.assertEquals("attempt to reuse consumer tag 'T_1'.", errorReceived['message']) self.assertEquals("A subscription identified by 'T_1' alredy exists.", errorReceived['message'])
self.assertFalse(self.conn.is_connected()) self.assertFalse(self.conn.is_connected())
class TestErrors(base.BaseTest): class TestErrors(base.BaseTest):