Code changes to handle null delivery issue hobbit-project#45

melissadas · Nov 28, 2019 · bde3c4a · bde3c4a
1 parent c5c57ad
commit bde3c4a
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/src/main/java/org/hobbit/core/components/AbstractEvaluationModule.java b/src/main/java/org/hobbit/core/components/AbstractEvaluationModule.java
@@ -20,7 +20,6 @@
 import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.util.concurrent.TimeUnit;
-
 import org.apache.commons.io.IOUtils;
 import org.apache.jena.rdf.model.Model;
 import org.apache.jena.rdf.model.ModelFactory;
@@ -124,8 +123,12 @@ protected void collectResponses() throws Exception {
             //Wait for delivery message
             Delivery delivery = consumer.getDeliveryQueue().poll(QUEUEPOLLTIMEOUT, TimeUnit.MILLISECONDS);
             // parse the response
-            try
+            if (delivery == null)
             {
+            	LOGGER.error("No Message Received after waiting for ten minutes");
+            	return;
+            }
+
             	buffer = ByteBuffer.wrap(delivery.getBody());
 
 
@@ -151,11 +154,7 @@ protected void collectResponses() throws Exception {
 
 
             evaluateResponse(expectedData, receivedData, taskSentTimestamp, responseReceivedTimestamp);
-            }catch(NullPointerException e) 
 
-            {
-            	LOGGER.error("No Message Received after waiting for ten minutes");
-            }
         }
     }