edit EncryptionConsumer to use PriorityBlockingQueue

src/main/java/consumer/EncryptionConsumer.java

 package consumer;
 
 import model.SequencedLine;
-import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.PriorityBlockingQueue;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
 
 public class EncryptionConsumer implements Runnable {
     private final int consumerId;
-    private final BlockingQueue<SequencedLine> inputQueue;
-    private final BlockingQueue<SequencedLine> outputQueue;
+    private final PriorityBlockingQueue<SequencedLine> inputQueue;
+    private final PriorityBlockingQueue<SequencedLine> outputQueue;
     private final AtomicBoolean productionFinished;
     private final AtomicInteger activeConsumers;
     private final EncryptionProcessor processor;
 
     public EncryptionConsumer(int consumerId,
-                              BlockingQueue<SequencedLine> inputQueue,
-                              BlockingQueue<SequencedLine> outputQueue,
+                              PriorityBlockingQueue<SequencedLine> inputQueue,
+                              PriorityBlockingQueue<SequencedLine> outputQueue,
                               AtomicBoolean productionFinished,
                               AtomicInteger activeConsumers,
                               EncryptionProcessor processor) {