Consume_channel: avoid repeating query if previous query is not yet f…

…inished
pydio · Feb 25, 2015 · 73a1f43 · 73a1f43
1 parent 2e6cf3f
commit 73a1f43
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/core/src/plugins/core.mq/class.AjxpMqObserver.js b/core/src/plugins/core.mq/class.AjxpMqObserver.js
@@ -28,6 +28,7 @@ Class.create("AjxpMqObserver", {
     clientId:null,
     ws: null,
     configs: null,
+    channel_pending: false,
 
     initialize : function(){
         "use strict";
@@ -147,6 +148,9 @@ Class.create("AjxpMqObserver", {
     },
 
     consumeChannel : function(){
+        if(this.channel_pending) {
+            return;
+        }
         var conn = new Connexion();
         conn.setParameters($H({
             get_action:'client_consume_channel',
@@ -155,11 +159,13 @@ Class.create("AjxpMqObserver", {
         }));
         conn.discrete = true;
         conn.onComplete = function(transport){
+            this.channel_pending = false;
             if(transport.responseXML){
                 ajaxplorer.actionBar.parseXmlMessage(transport.responseXML);
                 ajaxplorer.notify("server_message", transport.responseXML);
             }
-        };
+        }.bind(this);
+        this.channel_pending = true;
         conn.sendAsync();
     }