diff --git a/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisQueues.java b/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisQueues.java index 197c271..9fce1c5 100644 --- a/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisQueues.java +++ b/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisQueues.java @@ -94,6 +94,10 @@ public DynoQueue get(String queueName) { } synchronized (this) { + queue = this.queues.get(key); + if (queue != null) { + return queue; + } queue = new RedisDynoQueue(redisKeyPrefix, queueName, allShards, shardName, dynoCallExecutor) .withUnackTime(unackTime) .withUnackSchedulerTime(unackHandlerIntervalInMS)