This is an automated email from the ASF dual-hosted git repository. gmurthy pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
The following commit(s) were added to refs/heads/master by this push: new bc06083 DISPATCH-1408 - Made sure that the correct sender and not the management sender is used to send messages to the router. This will ensure that we are testing the closest distribution correctly bc06083 is described below commit bc06083a429e1a3032b5da6f665f1c2c6e5e9d59 Author: Ganesh Murthy <gmur...@apache.org> AuthorDate: Fri Sep 6 13:09:35 2019 -0400 DISPATCH-1408 - Made sure that the correct sender and not the management sender is used to send messages to the router. This will ensure that we are testing the closest distribution correctly --- tests/system_tests_distribution.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/tests/system_tests_distribution.py b/tests/system_tests_distribution.py index 0442095..c3be49c 100644 --- a/tests/system_tests_distribution.py +++ b/tests/system_tests_distribution.py @@ -2271,6 +2271,8 @@ class ClosestTest ( MessagingHandler ): self.bailed = False self.test_name = test_name + self.sender = None + def timeout ( self ): self.bail ( "Timeout Expired " ) @@ -2333,10 +2335,11 @@ class ClosestTest ( MessagingHandler ): def on_sendable ( self, event ): - msg = Message ( body = "Hello, closest.", - address = self.dest - ) - event.sender.send ( msg ) + # Fix for DISPATCH-1408 - Make sure that the correct sender is sending the messages to self.dest + if event.sender == self.sender: + msg = Message ( body = "Hello, closest.", + address = self.dest) + event.sender.send ( msg ) def on_message ( self, event ): --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org