diff --git a/heat/engine/resources/signal_responder.py b/heat/engine/resources/signal_responder.py index 85659a9481..28a8ab9b95 100644 --- a/heat/engine/resources/signal_responder.py +++ b/heat/engine/resources/signal_responder.py @@ -394,6 +394,7 @@ class SignalResponder(stack_user.StackUser): queue = zaqar.queue(self._get_zaqar_signal_queue_id()) except Exception as ex: self.client_plugin('zaqar').ignore_not_found(ex) + return messages = list(queue.pop()) for message in messages: self.signal(details=message.body)