Merge pull request #35 from Ricool06/dev

Remove some unused lines (solves #29)
Netflix · Oct 15, 2018 · c8aa2cf · c8aa2cf
2 parents 82e5ae6 + 8af9b44
commit c8aa2cf
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 5 deletions.
diff --git a/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisDynoQueue.java b/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisDynoQueue.java
@@ -86,8 +86,6 @@ public class RedisDynoQueue implements DynoQueue {
 
 	private ScheduledExecutorService schedulerForUnacksProcessing;
 
-	private ScheduledExecutorService schedulerForPrefetchProcessing;
-
 	private int retryCount = 2;
 
 	public RedisDynoQueue(String redisKeyPrefix, String queueName, Set<String> allShards, String shardName) {
@@ -120,7 +118,6 @@ public RedisDynoQueue(Clock clock, String redisKeyPrefix, String queueName, Set<
 		this.prefetchedIds = new ConcurrentLinkedQueue<>();
 
 		schedulerForUnacksProcessing = Executors.newScheduledThreadPool(1);
-		schedulerForPrefetchProcessing = Executors.newScheduledThreadPool(1);
 
 		schedulerForUnacksProcessing.scheduleAtFixedRate(() -> processUnacks(), unackScheduleInMS, unackScheduleInMS, TimeUnit.MILLISECONDS);
 
@@ -616,7 +613,6 @@ private <R> R executeWithRetry(Callable<R> r, int retryCount) {
 	@Override
 	public void close() throws IOException {
 		schedulerForUnacksProcessing.shutdown();
-		schedulerForPrefetchProcessing.shutdown();
 		monitor.close();
 	}
 }
diff --git a/dyno-queues-redis/src/test/java/com/netflix/dyno/queues/redis/RedisDynoQueueTest.java b/dyno-queues-redis/src/test/java/com/netflix/dyno/queues/redis/RedisDynoQueueTest.java
@@ -22,7 +22,6 @@
 import static org.junit.Assert.assertTrue;
 
 import java.util.Arrays;
-import java.util.Collection;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;