diff --git a/django_q/brokers/__init__.py b/django_q/brokers/__init__.py
index 47e55e8..4dffaf0 100644
--- a/django_q/brokers/__init__.py
+++ b/django_q/brokers/__init__.py
@@ -55,6 +55,13 @@ class Broker(object):
         """
         pass
 
+    def fail(self, task_id):
+        """
+        Fails a task message
+        :param task_id:
+        :return:
+        """
+
     def ping(self):
         """
         Checks whether the broker connection is available
diff --git a/django_q/brokers/aws_sqs.py b/django_q/brokers/aws_sqs.py
index 12844ac..2b9e254 100644
--- a/django_q/brokers/aws_sqs.py
+++ b/django_q/brokers/aws_sqs.py
@@ -33,6 +33,9 @@ class Sqs(Broker):
         m.receipt_handle = task_id
         return self.queue.delete_message(m)
 
+    def fail(self, task_id):
+        self.delete(task_id)
+
     def delete_queue(self):
         self.connection.delete_queue(self.queue)
 
diff --git a/django_q/brokers/disque.py b/django_q/brokers/disque.py
index ab61694..8ae163e 100644
--- a/django_q/brokers/disque.py
+++ b/django_q/brokers/disque.py
@@ -27,6 +27,9 @@ class Disque(Broker):
     def delete(self, task_id):
         return self.connection.execute_command('DELJOB {}'.format(task_id))
 
+    def fail(self, task_id):
+        return self.delete(task_id)
+
     def delete_queue(self):
         jobs = self.connection.execute_command('JSCAN QUEUE {}'.format(self.list_key))[1]
         if jobs:
diff --git a/django_q/brokers/iron_mq.py b/django_q/brokers/iron_mq.py
index 57cac5a..d59d2f4 100644
--- a/django_q/brokers/iron_mq.py
+++ b/django_q/brokers/iron_mq.py
@@ -32,6 +32,9 @@ class IronMQBroker(Broker):
     def delete(self, task_id):
         return self.connection.delete(task_id)['msg']
 
+    def fail(self, task_id):
+        self.delete(task_id)
+
     def acknowledge(self, task_id):
         return self.delete(task_id)
 
diff --git a/django_q/cluster.py b/django_q/cluster.py
index 5faf7d5..d3b5663 100644
--- a/django_q/cluster.py
+++ b/django_q/cluster.py
@@ -311,6 +311,7 @@ def pusher(task_queue, event, broker=None):
                 task = signing.SignedPackage.loads(task[1])
             except (TypeError, signing.BadSignature) as e:
                 logger.error(e)
+                broker.fail(ack_id)
                 continue
             task['ack_id'] = ack_id
             task_queue.put(task)