(self, parent_node_name)
return res.keys()
Find subscribers for particular node.
Find subscribers for particular node.
Find subscribers for particular node .
def find_subscribers_for(self, parent_node_name):
        """Find subscribers for particular node."""

        # use dict to eliminate duplicates
        res = {}

        nodelist = self.queue_info.member_map.keys()
        for node_name in nodelist:
            if node_name == parent_node_name:
                continue
            if not self.node_alive(node_name):
                continue
            n = self.get_node_info(node_name)
            if not n:
                continue
            if n.provider_node == parent_node_name:
                res[n.name] = 1
        return res.keys()
def find_subscribers_for ( self , parent_node_name ) : # use dict to eliminate duplicates res = { } nodelist = self . queue_info . member_map . keys ( ) for node_name in nodelist : if node_name == parent_node_name : continue if not self . node_alive ( node_name ) : continue n = self . get_node_info ( node_name ) if not n : continue if n . provider_node == parent_node_name : res [ n . name ] = 1 return res . keys ( )