grs commented on a change in pull request #567: DISPATCH-1428 URL: https://github.com/apache/qpid-dispatch/pull/567#discussion_r329933791
########## File path: tests/system_tests_link_routes.py ########## @@ -2052,6 +2052,132 @@ def on_message(self, event): def run(self): Container(self).run() +class Dispatch1428(TestCase): + """ + Sets up 2 routers (one of which are acting as brokers (QDR.A)). + + QDR.A acting broker #1 + +---------+ +---------+ + | | <------ | | + | QDR.A | | QDR.B | + | | ------> | | + +---------+ +---------+ + + """ + @classmethod + def get_router(cls, index): + return cls.routers[index] + + @classmethod + def setUpClass(cls): + """Start two routers""" + super(Dispatch1428, cls).setUpClass() + + def router(name, connection): + + config = [ + ('router', {'mode': 'interior', 'id': 'QDR.%s'%name}), + ] + connection + + config = Qdrouterd.Config(config) + cls.routers.append(cls.tester.qdrouterd(name, config, wait=False)) + + cls.routers = [] + a_listener_port = cls.tester.get_port() + b_listener_port = cls.tester.get_port() + + router('A', + [ + ('listener', {'role': 'normal', 'host': '0.0.0.0', 'port': a_listener_port, 'saslMechanisms': 'ANONYMOUS'}), + ]) + router('B', + [ + ('listener', {'role': 'normal', 'host': '0.0.0.0', 'port': b_listener_port, 'saslMechanisms': 'ANONYMOUS'}), + ('connector', {'name': 'one', 'role': 'route-container', 'host': '0.0.0.0', 'port': a_listener_port, 'saslMechanisms': 'ANONYMOUS'}), + ('connector', {'name': 'two', 'role': 'route-container', 'host': '0.0.0.0', 'port': a_listener_port, 'saslMechanisms': 'ANONYMOUS'}) + ] + ) + sleep(2) + + + def run_qdmanage(self, cmd, input=None, expect=Process.EXIT_OK, address=None): + p = self.popen( + ['qdmanage'] + cmd.split(' ') + ['--bus', address or self.address(), '--indent=-1', '--timeout', str(TIMEOUT)], + stdin=PIPE, stdout=PIPE, stderr=STDOUT, expect=expect, + universal_newlines=True) + out = p.communicate(input)[0] + try: + p.teardown() + except Exception as e: + raise Exception("%s\n%s" % (e, out)) + return out + + def test_both_link_routes_active(self): + cmds = [ + 'CREATE --type=linkRoute name=foo prefix=foo direction=in connection=one', + 'CREATE --type=linkRoute name=bar prefix=bar direction=in connection=two' Review comment: Done! ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org For additional commands, e-mail: dev-h...@qpid.apache.org