From e87cf1262f4a2beec4f3d72cd0cdf68a0516846c Mon Sep 17 00:00:00 2001 From: Libert Date: Wed, 3 May 2017 14:17:47 +0200 Subject: [PATCH] Correcting no header in reply-to message. @see https://github.com/jlavallee/JMeter-Rabbit-AMQP/issues/41 --- .../com/zeroclue/jmeter/protocol/amqp/AMQPConsumer.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/main/com/zeroclue/jmeter/protocol/amqp/AMQPConsumer.java b/src/main/com/zeroclue/jmeter/protocol/amqp/AMQPConsumer.java index cf06354..c19f39c 100644 --- 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(); } }