From 957fff5ff5e156f3281f6561581990957dae64cc Mon Sep 17 00:00:00 2001
From: Mike Bonnet <mikeb@redhat.com>
Date: Fri, 29 Jun 2012 17:35:54 -0400
Subject: [PATCH] block for a maximum of 60 seconds when sending a message

---
 plugins/messagebus.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/plugins/messagebus.py b/plugins/messagebus.py
index fd5640ea..aeda7abe 100644
--- a/plugins/messagebus.py
+++ b/plugins/messagebus.py
@@ -166,5 +166,6 @@ def send_message(cbtype, *args, **kws):
     else:
         raise koji.PluginError, 'unsupported exchange type: %s' % exchange_type
 
-    sender.send(message)
+    sender.send(message, sync=False)
+    sender.sync(timeout=60)
     sender.close()