From 3081db034fe1b6ae7670bc5cf07556a40f799b20 Mon Sep 17 00:00:00 2001 From: erickson Date: Mon, 26 Nov 2007 22:27:50 +0000 Subject: [PATCH] in addition to pushing the received message to the callback, we return the message from recv() git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@1145 9efc2488-bf62-4759-914b-345cdb29e865 --- src/python/osrf/net.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/python/osrf/net.py b/src/python/osrf/net.py index a6fddf8..f04efa0 100644 --- a/src/python/osrf/net.py +++ b/src/python/osrf/net.py @@ -128,7 +128,6 @@ class osrfNetwork(JabberClient): If a message is received in 'timeout' seconds, the message is passed to the recvCallback is called and True is returned. Otherwise, false is returned.""" - msg = None if len(self.queue) == 0: while timeout >= 0 and len(self.queue) == 0: starttime = time.time() @@ -141,11 +140,13 @@ class osrfNetwork(JabberClient): if not act: self.idle() # if we've acquired a message, handle it + msg = None if len(self.queue) > 0: - self.recvCallback(self.queue.pop(0)) - return True + msg = self.queue.pop(0) + if self.recvCallback: + self.recvCallback(msg) - return False + return msg -- 2.43.2