Do not buffer when there's no trusted streams available.

lsm · Apr 13, 2016 · eb5e559 · eb5e559
1 parent 9df9a42
commit eb5e559
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/lib/queue/gateway.js b/lib/queue/gateway.js
@@ -125,8 +125,8 @@ QueueGateway.prototype.onGatewayInf = function(pack, stream) {
       // Route this message to one of any streams which has tag `[ns]::ACK`
       var tag = prefixTags(meta[MNS], ACK)
       var streams = this.socket.getStreamsByTag(tag, null, stream)
-      // console.log('ack trusted', pack);
-      this.one(streams, INF, ACK, ackMsg, meta)
+      if (streams.length > 0)
+        this.one(streams, INF, ACK, ackMsg, meta)
     } else {
       // If ACK from trusted streams, it could be one of following 2 cases:
       if (meta[SID]) {
@@ -279,7 +279,6 @@ QueueGateway.prototype.dispatch = function(buf, stream) {
         case INF:
           pack = gateway.decode(buf)
           pack.meta = meta
-          // console.log('gateway inf', pack);
           gateway.onGatewayInf(pack, stream)
           break
       }