(self, src_curs, dst_curs, ev)
Per-event callback.

        By default ignores cascading events and gives error on others.
        Can be called from user handler to finish unprocessed events.
Per-event callback.
Per - event callback .
def process_remote_event(self, src_curs, dst_curs, ev):
        """Per-event callback.

        By default ignores cascading events and gives error on others.
        Can be called from user handler to finish unprocessed events.
        """
        if ev.ev_type[:4] == "pgq.":
            # ignore cascading events
            pass
        else:
            raise Exception('Unhandled event type in queue: %s' % ev.ev_type)
def process_remote_event ( self , src_curs , dst_curs , ev ) : if ev . ev_type [ : 4 ] == "pgq." : # ignore cascading events pass else : raise Exception ( 'Unhandled event type in queue: %s' % ev . ev_type )