From: erickson <erickson@9efc2488-bf62-4759-914b-345cdb29e865>
Date: Wed, 18 Aug 2010 20:12:40 +0000 (+0000)
Subject: back-port 2008: async message handling ordering
X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=ba96e8e299d39ec95d7b073ca8a24364ec2c6928;p=OpenSRF.git

back-port 2008: async message handling ordering

git-svn-id: svn://svn.open-ils.org/OpenSRF/branches/rel_1_2@2010 9efc2488-bf62-4759-914b-345cdb29e865
---

diff --git a/src/javascript/opensrf.js b/src/javascript/opensrf.js
index 5675cbd..5fb66c0 100644
--- a/src/javascript/opensrf.js
+++ b/src/javascript/opensrf.js
@@ -230,13 +230,24 @@ OpenSRF.NetMessage = function(to, from, thread, body) {
 OpenSRF.Stack = function() {
 }
 
+// global inbound message queue
+OpenSRF.Stack.queue = [];
+
 OpenSRF.Stack.push = function(net_msg, callbacks) {
     var ses = OpenSRF.Session.find_session(net_msg.thread); 
     if(!ses) return;
     ses.remote_id = net_msg.from;
     osrf_msgs = JSON2js(net_msg.body);
-    for(var i = 0; i < osrf_msgs.length; i++) 
-        OpenSRF.Stack.handle_message(ses, osrf_msgs[i], callbacks);        
+
+    // push the latest responses onto the end of the inbound message queue
+    for(var i = 0; i < osrf_msgs.length; i++)
+        OpenSRF.Stack.queue.push({msg : osrf_msgs[i], callbacks : callbacks});
+
+    // continue processing responses, oldest to newest
+    while(OpenSRF.Stack.queue.length) {
+        var data = OpenSRF.Stack.queue.shift();
+        OpenSRF.Stack.handle_message(ses, data.msg, data.callbacks);
+    }
 }
 
 OpenSRF.Stack.handle_message = function(ses, osrf_msg, callbacks) {