Changes between Version 19 and Version 20 of jazz/ActiveMQ/08-10-27

Timestamp:

Oct 28, 2008, 2:15:00 PM (17 years ago)

Author:

jazz

Comment:

--

jazz/ActiveMQ/08-10-27

@@ -141 +141 @@
       // 627      initialize: function(url, options) {
       //
+      // 這裡的意思是當 AJAX XmlHttpRequest 完成 get amq.uri 時，執行 amq._pollHandler
       new Ajax.Request(amq.uri, { method: 'get', parameters: 'timeout=0', onSuccess: amq._pollHandler });
   }
-}}}
+
+  _pollHandler: function(request)
+  {
+    amq.startBatch();
+    try
+    {
+      amq._messageHandler(request);
+      amq._pollEvent(amq._first);
+      amq._first=false;
+    }
+    catch(e)
+    {
+        alert(e);
+    }
+    amq.endBatch();
+
+    if (amq._pollDelay>0)
+      setTimeout('amq._sendPoll()',amq._pollDelay);
+    else
+      amq._sendPoll();
+  },
+
+  startBatch: function()
+  {
+    amq._queueMessages++;
+  },
+
+  _messageHandler: function(request)
+  {
+    try
+    {
+      if (request.status == 200)
+      {
+        var response = request.responseXML.getElementsByTagName("ajax-response");
+        if (response != null && response.length == 1)
+        {
+          for ( var i = 0 ; i < response[0].childNodes.length ; i++ )
+          {
+            var responseElement = response[0].childNodes[i];
+
+            // only process nodes of type element.....
+            if ( responseElement.nodeType != 1 )
+              continue;
+
+            var id   = responseElement.getAttribute('id');
+
+
+            var handler = amq._handlers[id];
+            if (handler!=null)
+            {
+              for (var j = 0; j < responseElement.childNodes.length; j++)
+              {
+                handler(responseElement.childNodes[j]);
+                  }
+            }
+          }
+        }
+      }
+    }
+    catch(e)
+    {
+      alert(e);
+    }
+  },
+
+  endBatch: function()
+  {
+    amq._queueMessages--;
+    if (amq._queueMessages==0 && amq._messages>0)
+    {
+      var body = amq._messageQueue;
+      amq._messageQueue='';
+      amq._messages=0;
+      amq._queueMessages++;
+      new Ajax.Request(amq.uri, { method: 'post', postBody: body, onSuccess: amq.endBatch});
+    }
+  },
+}}}