Added getQueues feature to get the name of all active queues

Author: mcweba

README.md

@@ -103,6 +103,25 @@ Response Data
 }
 ```
 
+#### getQueues
+
+Request Data
+
+```
+{
+    "operation": "getQueues"
+}
+```
+
+Response Data
+
+```
+{
+    "status": "ok" / "error",
+    "value": <objArr RESULT>
+}
+```
+
 #### getQueuesCount
 
 Request Data

src/main/java/org/swisspush/redisques/RedisQues.java

@@ -230,8 +230,10 @@ public void handle(final Message<JsonObject> event) {
                         redisClient.llen(queuesPrefix + event.body().getJsonObject(PAYLOAD).getString(QUEUENAME), new GetQueueItemsCountHandler(event));
                         break;
                     case getQueuesCount:
-                        long timestamp = System.currentTimeMillis() - MAX_AGE_MILLISECONDS;
-                        redisClient.zcount(redisPrefix + "queues", timestamp, Double.MAX_VALUE, new GetQueuesCountHandler(event));
+                        redisClient.zcount(redisPrefix + "queues", getMaxAgeTimestamp(), Double.MAX_VALUE, new GetQueuesCountHandler(event));
+                        break;
+                    case getQueues:
+                        redisClient.zrangebyscore(redisPrefix + "queues", String.valueOf(getMaxAgeTimestamp()), "+inf", RangeLimitOptions.NONE, new GetQueuesHandler(event));
                         break;
                     default:
                         unsupportedOperation(operation, event);
@@ -276,6 +278,10 @@ public void handle(Message<String> event) {
         });
     }
 
+    private long getMaxAgeTimestamp(){
+        return System.currentTimeMillis() - MAX_AGE_MILLISECONDS;
+    }
+
     private void unsupportedOperation(String operation, Message<JsonObject> event){
         JsonObject reply = new JsonObject();
         String message = "QUEUE_ERROR: Unsupported operation received: " + operation;

src/main/java/org/swisspush/redisques/handler/GetQueuesHandler.java

@@ -0,0 +1,40 @@
+package org.swisspush.redisques.handler;
+
+import io.vertx.core.AsyncResult;
+import io.vertx.core.Handler;
+import io.vertx.core.eventbus.Message;
+import io.vertx.core.json.JsonArray;
+import io.vertx.core.json.JsonObject;
+
+import java.util.List;
+
+import static org.swisspush.redisques.util.RedisquesAPI.*;
+
+/**
+ * Class GetQueuesCountHandler.
+ *
+ * @author https://github.com/mcweba [Marc-Andre Weber]
+ */
+public class GetQueuesHandler implements Handler<AsyncResult<JsonArray>> {
+    private Message<JsonObject> event;
+
+    public GetQueuesHandler(Message<JsonObject> event) {
+        this.event = event;
+    }
+
+    @Override
+    public void handle(AsyncResult<JsonArray> reply) {
+        if(reply.succeeded()){
+            List<Object> list = reply.result().getList();
+            JsonObject result = new JsonObject();
+            JsonArray items = new JsonArray();
+            for (Object item : list.toArray()) {
+                items.add((String) item);
+            }
+            result.put("queues", items);
+            event.reply(new JsonObject().put(STATUS, OK).put(VALUE, result));
+        } else {
+            event.reply(new JsonObject().put(STATUS, ERROR));
+        }
+    }
+}

src/main/java/org/swisspush/redisques/util/RedisquesAPI.java

@@ -26,7 +26,7 @@ public class RedisquesAPI {
     public enum QueueOperation {
         enqueue, check, reset, stop, getQueueItems, addQueueItem, deleteQueueItem,
         getQueueItem, replaceQueueItem, deleteAllQueueItems, getAllLocks, putLock,
-        getLock, deleteLock, getQueuesCount, getQueueItemsCount;
+        getLock, deleteLock, getQueues, getQueuesCount, getQueueItemsCount;
 
         public static QueueOperation fromString(String op){
             for (QueueOperation queueOperation : values()) {
@@ -84,6 +84,10 @@ public static JsonObject buildDeleteAllQueueItemsOperation(String queueName){
         return buildOperation(QueueOperation.deleteAllQueueItems, new JsonObject().put(QUEUENAME, queueName));
     }
 
+    public static JsonObject buildGetQueuesOperation(){
+        return buildOperation(QueueOperation.getQueues);
+    }
+
     public static JsonObject buildGetQueuesCountOperation(){
         return buildOperation(QueueOperation.getQueuesCount);
     }

src/test/java/org/swisspush/redisques/RedisQuesTest.java

@@ -91,6 +91,32 @@ public void getQueueItems(TestContext context) {
         });
     }
 
+    @Test
+    public void getQueues(TestContext context) {
+        Async asyncEnqueue = context.async(100);
+        flushAll();
+        assertKeyCount(context, QUEUES_PREFIX, 0);
+        for (int i = 0; i < 100; i++) {
+            eventBusSend(buildEnqueueOperation("queue" + i, "testItem"), message -> {
+                context.assertEquals(OK, message.result().body().getString(STATUS));
+                asyncEnqueue.countDown();
+            });
+        }
+        asyncEnqueue.awaitSuccess();
+
+        assertKeyCount(context, QUEUES_PREFIX, 100);
+        Async async = context.async();
+        eventBusSend(buildGetQueuesOperation(), message -> {
+            context.assertEquals(OK, message.result().body().getString(STATUS));
+            JsonArray queuesArray = message.result().body().getJsonObject(VALUE).getJsonArray("queues");
+            context.assertEquals(100, queuesArray.size());
+            for (int i = 0; i < 100; i++) {
+                context.assertTrue(queuesArray.contains("queue"+i), "item queue" + i + " expected to be in result");
+            }
+            async.complete();
+        });
+    }
+
     @Test
     public void getQueuesCount(TestContext context) {
         Async asyncEnqueue = context.async(100);