refactor: use queue instead of deque

idealo · Jan 15, 2021 · 408c596 · 408c596
1 parent c0190c1
commit 408c596
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/de/idealo/spring/contract/aws/sns/AmazonSNSDummyClient.java b/src/main/java/de/idealo/spring/contract/aws/sns/AmazonSNSDummyClient.java
@@ -4,6 +4,7 @@
 import java.util.Map;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingDeque;
+import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
@@ -26,7 +27,7 @@ public class AmazonSNSDummyClient extends AbstractAmazonSNS {
 
     public AmazonSNSDummyClient(String[] topics) {
         this.outbound = Stream.of(topics)
-                .collect(Collectors.toMap(x -> x, x -> new LinkedBlockingDeque<>(), (x, y) -> x));
+                .collect(Collectors.toMap(x -> x, x -> new LinkedBlockingQueue<>(), (x, y) -> x));
     }
 
     @Override