use a heartbeat when connecting to the messagebus

2012-06-29 12:17:59 -04:00 · 2012-06-29 12:17:59 -04:00 · bec96c17e1
commit bec96c17e1
parent 58a57ea71b
1 changed files with 2 additions and 1 deletions
--- a/plugins/messagebus.py
+++ b/plugins/messagebus.py
@ -55,7 +55,8 @@ def get_sender():
    url += config.get('broker', 'port')

    conn = qpid.messaging.Connection.establish(url,
-                                               sasl_mechanisms=config.get('broker', 'auth'))
+                                               sasl_mechanisms=config.get('broker', 'auth'),
+                                               heartbeat=60)
    sess = conn.session()
    tgt = """%s;
             { create: sender,