Skip to content

Commit e20f101

Browse files
committed
Fix no header in reply-to message (see jlavallee#41)
1 parent c5c5abb commit e20f101

File tree

1 file changed

+11
-6
lines changed

1 file changed

+11
-6
lines changed

src/main/com/zeroclue/jmeter/protocol/amqp/AMQPConsumer.java

Lines changed: 11 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -365,13 +365,18 @@ private String formatHeaders(QueueingConsumer.Delivery delivery) {
365365
.append(": ")
366366
.append(delivery.getEnvelope().getRoutingKey())
367367
.append("\n");
368-
sb.append(DELIVERY_TAG_PARAMETER).append(": ").append(delivery.getEnvelope().getDeliveryTag()).append("\n");
368+
sb.append(DELIVERY_TAG_PARAMETER)
369+
.append(": ")
370+
.append(delivery.getEnvelope().getDeliveryTag())
371+
.append("\n");
369372

370-
for (String key : headers.keySet()) {
371-
sb.append(key)
372-
.append(": ")
373-
.append(headers.get(key))
374-
.append("\n");
373+
if (headers != null) {
374+
for (String key : headers.keySet()) {
375+
sb.append(key)
376+
.append(": ")
377+
.append(headers.get(key))
378+
.append("\n");
379+
}
375380
}
376381

377382
return sb.toString();

0 commit comments

Comments
 (0)