Custom Consumer class for issue hobbit-project#45

pom.xml

@@ -56,7 +56,7 @@
         <dependency>
             <groupId>com.rabbitmq</groupId>
             <artifactId>amqp-client</artifactId>
-            <version>4.8.0</version>
+            <version>5.7.3</version>
         </dependency>
         <!-- Jena -->
         <dependency>

src/main/java/org/hobbit/core/rabbit/CustomConsumer.java

@@ -0,0 +1,26 @@
+package org.hobbit.core.rabbit;
+
+import java.io.IOException;
+import java.util.concurrent.LinkedBlockingQueue;
+
+import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.DefaultConsumer;
+import com.rabbitmq.client.Delivery;
+import com.rabbitmq.client.Envelope;
+public class CustomConsumer extends DefaultConsumer {
+
+    public LinkedBlockingQueue<Delivery> deliveryQueue = new LinkedBlockingQueue<>();
+    public CustomConsumer(Channel channel) {
+        super(channel);
+    }
+    @Override
+   public void handleDelivery(String consumerTag,
+                              Envelope envelope,
+                              AMQP.BasicProperties properties,
+                              byte[] body)
+       throws IOException
+   {
+        deliveryQueue.add(new Delivery(envelope,properties,body));
+   }
+}