(self, target_node, subscriber_node, tick_pos)
Subscribing one node to another.
Subscribing one node to another.
Subscribing one node to another .
def subscribe_node(self, target_node, subscriber_node, tick_pos):
        """Subscribing one node to another."""
        q = "select * from pgq_node.subscribe_node(%s, %s, %s)"
        self.node_cmd(target_node, q, [self.queue_name, subscriber_node, tick_pos])
def subscribe_node ( self , target_node , subscriber_node , tick_pos ) : q = "select * from pgq_node.subscribe_node(%s, %s, %s)" self . node_cmd ( target_node , q , [ self . queue_name , subscriber_node , tick_pos ] )