def stop_listening(self):
        """Stop listener threads for acquistion queues"""
        self._halt_threads = True
        # wake them up so that they can die
        for name, queue_waker in self.recieved_signals.items():
            q, wake_event = queue_waker
            wake_event.set()
Stop listener threads for acquistion queues