Fix no header in reply-to message (see jlavallee#41)

aliesbelik · Oct 29, 2021 · d9b0864 · d9b0864
1 parent c813e1a
commit d9b0864
Showing 1 changed file with 11 additions and 6 deletions.
diff --git a/src/main/java/com/zeroclue/jmeter/protocol/amqp/AMQPConsumer.java b/src/main/java/com/zeroclue/jmeter/protocol/amqp/AMQPConsumer.java
@@ -365,13 +365,18 @@ private String formatHeaders(QueueingConsumer.Delivery delivery) {
             .append(": ")
             .append(delivery.getEnvelope().getRoutingKey())
             .append("\n");
-        sb.append(DELIVERY_TAG_PARAMETER).append(": ").append(delivery.getEnvelope().getDeliveryTag()).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();