Merge pull request #128 from leafnode/return-queue-length

Return queue length with metadata
arafato · Dec 15, 2017 · c08caca · c08caca
2 parents e1f886b + 997c57b
commit c08caca
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/lib/actions/queue/GetQueueMetadata.js b/lib/actions/queue/GetQueueMetadata.js
@@ -10,11 +10,13 @@ class GetQueueMetadata {
     process(request, res) {
         const queue = QueueManager.getQueueAndMessage({ queueName: request.queueName }).queue,
             metaProps = queue.metaProps,
+            queueLength = queue.getLength(),
             response = new AzuriteQueueResponse();
         response.addMetaProps(metaProps);
+        response.addHttpProperty(`x-ms-approximate-messages-count`, queueLength);
         res.set(response.httpProps);
         res.status(200).send();
     }
 }
 
-module.exports = new GetQueueMetadata();
+module.exports = new GetQueueMetadata();
diff --git a/lib/model/queue/AzuriteQueueResponse.js b/lib/model/queue/AzuriteQueueResponse.js
@@ -24,4 +24,4 @@ class AzuriteQueueResponse {
     }
 }
 
-module.exports = AzuriteQueueResponse;
+module.exports = AzuriteQueueResponse;
diff --git a/lib/model/queue/Queue.js b/lib/model/queue/Queue.js
@@ -122,6 +122,10 @@ class Queue {
             index: index
         };
     }
+
+    getLength() {
+        return this.messages.length;
+    }
 }
 
-module.exports = Queue;
+module.exports = Queue;
-Original file line number
+Diff line change
@@ Expand Up / @@ -24,4 +24,4 @@ class AzuriteQueueResponse { @@
         }
     }
-    module.exports = AzuriteQueueResponse;
+    module.exports = AzuriteQueueResponse;