Repository: qpid-interop-test Updated Branches: refs/heads/master 0e153797b -> 236d70795
QPIDIT-40: Added daemon status to sender and receiver threads so that they will respond to KeyboardInterrupts Project: http://git-wip-us.apache.org/repos/asf/qpid-interop-test/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-interop-test/commit/236d7079 Tree: http://git-wip-us.apache.org/repos/asf/qpid-interop-test/tree/236d7079 Diff: http://git-wip-us.apache.org/repos/asf/qpid-interop-test/diff/236d7079 Branch: refs/heads/master Commit: 236d7079583990492964f8d487a5a78cbbebd0d2 Parents: 0e15379 Author: Kim van der Riet <[email protected]> Authored: Wed Nov 23 16:49:46 2016 -0500 Committer: Kim van der Riet <[email protected]> Committed: Wed Nov 23 16:49:46 2016 -0500 ---------------------------------------------------------------------- src/python/qpid_interop_test/shims.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-interop-test/blob/236d7079/src/python/qpid_interop_test/shims.py ---------------------------------------------------------------------- diff --git a/src/python/qpid_interop_test/shims.py b/src/python/qpid_interop_test/shims.py index 431a2ff..a9553d6 100644 --- a/src/python/qpid_interop_test/shims.py +++ b/src/python/qpid_interop_test/shims.py @@ -162,11 +162,15 @@ class Shim(object): def create_sender(self, broker_addr, queue_name, test_key, json_test_str): """Create a new sender instance""" - return Sender(self.use_shell_flag, self.send_params, broker_addr, queue_name, test_key, json_test_str) + sender = Sender(self.use_shell_flag, self.send_params, broker_addr, queue_name, test_key, json_test_str) + sender.daemon = True + return sender def create_receiver(self, broker_addr, queue_name, test_key, json_test_str): """Create a new receiver instance""" - return Receiver(self.receive_params, broker_addr, queue_name, test_key, json_test_str) + receiver = Receiver(self.receive_params, broker_addr, queue_name, test_key, json_test_str) + receiver.daemon = True + return receiver class ProtonPythonShim(Shim): """Shim for qpid-proton Python client""" --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
