(self)
Unregistration for subconsumer.
Unregistration for subconsumer.
Unregistration for subconsumer .
def unregister_consumer(self):
        """Unregistration for subconsumer."""

        self.log.info("Unregistering consumer from source queue")
        db = self.get_database(self.db_name)
        cx = db.cursor()
        cx.execute("select pgq_coop.unregister_subconsumer(%s, %s, %s, 0)",
                    [self.queue_name, self.consumer_name, self.subconsumer_name])
        db.commit()
def unregister_consumer ( self ) : self . log . info ( "Unregistering consumer from source queue" ) db = self . get_database ( self . db_name ) cx = db . cursor ( ) cx . execute ( "select pgq_coop.unregister_subconsumer(%s, %s, %s, 0)" , [ self . queue_name , self . consumer_name , self . subconsumer_name ] ) db . commit ( )