Allow "immediate" flag to be specified in publish

edinburghhacklab · Feb 20, 2014 · 8fe0ed5 · 8fe0ed5
1 parent 8b76f65
commit 8fe0ed5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/hacksense.py b/lib/hacksense.py
@@ -81,7 +81,7 @@ def digest(self, key, timestamp, topic, headers, body):
         h.update(text)
         return h.hexdigest()
 
-    def publish(self, topic, headers={}, body="", retry=False, key=None):
+    def publish(self, topic, headers={}, body="", retry=False, key=None, immediate=False):
         new_headers = headers.copy()
         new_headers['src_hostname'] = socket.getfqdn()
         new_headers['src_script'] = sys.argv[0]
@@ -99,6 +99,7 @@ def publish(self, topic, headers={}, body="", retry=False, key=None):
                     self.channel.basic_publish(exchange=amqp_exchange,
                                                routing_key=topic,
                                                body=body,
+                                               immediate=immediate,
                                                properties=pika.BasicProperties(
                                                    timestamp=timestamp,
                                                    headers=new_headers