[qpid-dispatch] branch master updated: DISPATCH-1782: Added some print messages to see what prints out in CI. Also created sender after creating receiver

[gm...@apache.org]

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 a1d5898  DISPATCH-1782: Added some print messages to see what prints out in CI. Also created sender after creating receiver
a1d5898 is described below

commit a1d58983a1adb2fce8c3bd895d85658ab56030be
Author: Ganesh Murthy <gm...@apache.org>
AuthorDate: Thu Oct 8 16:45:47 2020 -0400

    DISPATCH-1782: Added some print messages to see what prints out in CI. Also created sender after creating receiver
---
 tests/system_tests_two_routers.py | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/tests/system_tests_two_routers.py b/tests/system_tests_two_routers.py
index 0419fdb..3cf049f 100644
--- a/tests/system_tests_two_routers.py
+++ b/tests/system_tests_two_routers.py
@@ -1105,10 +1105,9 @@ class MessageAnnotationsStripAddTraceTest(MessagingHandler):
 
     def on_start(self, event):
         self.timer = event.reactor.schedule(TIMEOUT, TestTimeout(self))
-        self.conn1 = event.container.connect(self.address1)
-        self.sender = event.container.create_sender(self.conn1, self.dest)
         self.conn2 = event.container.connect(self.address2)
         self.receiver = event.container.create_receiver(self.conn2, self.dest)
+        self.conn1 = event.container.connect(self.address1)
 
     def on_sendable(self, event):
         if self.msg_not_sent:
@@ -1118,9 +1117,15 @@ class MessageAnnotationsStripAddTraceTest(MessagingHandler):
             event.sender.send(msg)
             self.msg_not_sent = False
 
+    def on_link_opened(self, event):
+        if event.receiver == self.receiver:
+            self.sender = event.container.create_sender(self.conn1, self.dest)
+
     def on_message(self, event):
+        print (event.message)
         if 0 == event.message.body['number']:
             ma = event.message.annotations
+            print (ma)
             if ma['x-opt-qd.ingress'] == '0/QDR.A' and ma['x-opt-qd.trace'] == ['0/QDR.1', '0/QDR.A', '0/QDR.B']:
                 self.error = None
         self.accept(event.delivery)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org