diff options
Diffstat (limited to 'qpid/extras/dispatch/python')
| -rw-r--r-- | qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py | 1 | ||||
| -rw-r--r-- | qpid/extras/dispatch/python/qpid/dispatch/router/routing.py | 4 |
2 files changed, 3 insertions, 2 deletions
diff --git a/qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py b/qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py index 02f0315104..03bf0638a5 100644 --- a/qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py +++ b/qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py @@ -176,6 +176,7 @@ class RouterEngine: This is the IoAdapter message-receive handler """ try: + #self.log(LOG_DEBUG, "Raw Receive: mp=%r body=%r link_id=%r" % (message_properties, body, link_id)) self.handleControlMessage(message_properties['opcode'], body, link_id) except Exception, e: self.log(LOG_ERROR, "Exception in raw message processing: properties=%r body=%r exception=%r" % diff --git a/qpid/extras/dispatch/python/qpid/dispatch/router/routing.py b/qpid/extras/dispatch/python/qpid/dispatch/router/routing.py index 1097d8fbba..a4b3e5484a 100644 --- a/qpid/extras/dispatch/python/qpid/dispatch/router/routing.py +++ b/qpid/extras/dispatch/python/qpid/dispatch/router/routing.py @@ -48,13 +48,13 @@ class RoutingTableEngine(object): self.container.router_adapter.set_next_hop(mb_id, mb_nh) - def valid_origins_changes(self, valid_origins): + def valid_origins_changed(self, valid_origins): for _id, vo in valid_origins.items(): mb_id = self.node_tracker.maskbit_for_node(_id) mb_vo = [] for o in vo: mb_vo.append(self.node_tracker.maskbit_for_node(o)) - self.container.router_adapted.set_valid_origins(mb_id, mb_vo) + self.container.router_adapter.set_valid_origins(mb_id, mb_vo) def get_next_hops(self): |