Added a null check if someone passes null as headers for amqp

This commit is contained in:
Marcin Grzejszczak
2017-06-09 12:15:43 +02:00
parent 325afbe3ec
commit 2b527b5579

View File

@@ -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);