diff --git a/celery_haystack/signals.py b/celery_haystack/signals.py
index 1c7974f55bae473144e4a8343072a6019237f383..c6e4a0d752ed9ffa90680efd6a06740c78b548df 100644
--- a/celery_haystack/signals.py
+++ b/celery_haystack/signals.py
@@ -32,6 +32,8 @@ class CelerySignalProcessor(RealtimeSignalProcessor):
         task = get_update_task()
         task.apply_async((self._queue,), {}, **options)
 
+        self._queue = []
+
 
     def enqueue(self, action, instance, sender, **kwargs):
         """