5064e583f4d372e3a4038df3123efe454d34fd7d,studio/rabbit_queue.py,RMQueue,enqueue,#RMQueue#Any#Any#,353

Before Change

            with self._msg_tracking_lock:
                if message_number not in self._deliveries:
                    tries = 0
                    break

            tries -= 1
            if tries <= 0:
                break

After Change

                else:
                    tries -= 1

        raise Exception("studioml message was never acknowledged to {} " +
                        "after waiting {} seconds"
                        .format(self._url, abs(tries - 5)))

    def dequeue(self, acknowledge=True, timeout=0):
        msg = None

Instances