Merge pull request #24 from agorapulse/bug/redist-spec-unstable

get more details about the wrong type returned from the transaction

Author: musketyr

libs/micronaut-worker-queues-redis/src/main/java/com/agorapulse/worker/queues/redis/RedisQueues.java

@@ -62,6 +62,7 @@ public RedisQueues(ObjectMapper objectMapper, RedisClient client, RedisPoolConfi
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public <T> void readMessages(String queueName, int maxNumberOfMessages, Duration waitTime, Argument<T> argument, Consumer<T> action) {
         TransactionResult result = withTransaction(redisCommands -> {
             String key = getKey(queueName);
@@ -73,7 +74,14 @@ public <T> void readMessages(String queueName, int maxNumberOfMessages, Duration
             return;
         }
 
-        List<String> messages = result.get(0);
+
+        Object firstResponse = result.get(0);
+
+        if (!(firstResponse instanceof List)) {
+            throw new IllegalStateException("There result is not a list of Strings. Got: " + firstResponse);
+        }
+
+        List<String> messages = (List<String>) firstResponse;
 
         messages.forEach(body -> {
             try {