From 2b527b55795f0cc34b75b256abe9fe40e157935b Mon Sep 17 00:00:00 2001 From: Marcin Grzejszczak Date: Fri, 9 Jun 2017 12:15:43 +0200 Subject: [PATCH] Added a null check if someone passes null as headers for amqp --- .../verifier/messaging/amqp/SpringAmqpStubMessages.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/amqp/SpringAmqpStubMessages.java b/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/amqp/SpringAmqpStubMessages.java index 60f87482c9..06e072aa0c 100644 --- a/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/amqp/SpringAmqpStubMessages.java +++ b/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/amqp/SpringAmqpStubMessages.java @@ -78,7 +78,7 @@ public class SpringAmqpStubMessages implements .setContentType((String) headers.get("contentType")) .copyHeaders(headers).build()) .build(); - if (headers.containsKey(DEFAULT_CLASSID_FIELD_NAME)) { + if (headers != null && headers.containsKey(DEFAULT_CLASSID_FIELD_NAME)) { message.getMessageProperties().setHeader(DEFAULT_CLASSID_FIELD_NAME, headers.get(DEFAULT_CLASSID_FIELD_NAME)); } send(message, destination);