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)
select_version changes the version of the currently open vistrail
dataset/ETHPy150Open comodit/synapse-agent/synapse/amqp.py/AmqpSynapse._publisher--crossover with--dataset/ETHPy150Open VisTrails/VisTrails/vistrails/core/application.py/VistrailsApplicationInterface.select_version