Correcting no header in reply-to message. @see jlavallee#41

gregLibert · May 3, 2017 · e87cf12 · e87cf12
1 parent b157526
commit e87cf12
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/main/com/zeroclue/jmeter/protocol/amqp/AMQPConsumer.java b/src/main/com/zeroclue/jmeter/protocol/amqp/AMQPConsumer.java
@@ -354,9 +354,11 @@ private String formatHeaders(QueueingConsumer.Delivery delivery){
         sb.append(EXCHANGE_PARAMETER).append(": ").append(delivery.getEnvelope().getExchange()).append("\n");
         sb.append(ROUTING_KEY_PARAMETER).append(": ").append(delivery.getEnvelope().getRoutingKey()).append("\n");
         sb.append(DELIVERY_TAG_PARAMETER).append(": ").append(delivery.getEnvelope().getDeliveryTag()).append("\n");
-        for (String key : headers.keySet()) {
-            sb.append(key).append(": ").append(headers.get(key)).append("\n");
-        }
+      	if(headers != null){
+      	        for (String key : headers.keySet()) {
+              	    sb.append(key).append(": ").append(headers.get(key)).append("\n");
+              	}
+      	}
         return sb.toString();
     }
 }