Upgrade to rmr which required two changes

[ric-plt/a1.git] / a1 / a1rmr.py

diff --git a/a1/a1rmr.py b/a1/a1rmr.py
index 3858704..abbb84f 100644 (file)
--- a/a1/a1rmr.py
+++ b/a1/a1rmr.py
@@ -72,6 +72,7 @@ def send(payload, message_type=0):
 
     # we failed all RETRY_TIMES
     logger.debug("Send failed all %s times, stopping", RETRY_TIMES)
+    return None
 
 
 def dequeue_all_waiting_messages(filter_type=None):