def _publisher(self):
        try:
            for i in range(10):
                pt = self.pq.get(False)
                self._handle_publish(pt)
        except Empty:
            pass

        if self._connection:
            self._connection.add_timeout(.1, self._publisher)
This callback is used to check at regular interval if there's any
dataset/ETHPy150Open comodit/synapse-agent/synapse/amqp.py/AmqpSynapse._publisher