From 7e28fba104a118c64caa9662de396c54e1030e70 Mon Sep 17 00:00:00 2001
From: Florian Ruschbaschan <46709526+floruschbaschan@users.noreply.github.com>
Date: Wed, 3 Nov 2021 13:15:47 +0100
Subject: [PATCH] Use an empty AMQP Message body instead of a null value
 (#1200)

---
 .../eclipse/hawkbit/amqp/AmqpMessageDispatcherService.java    | 4 ++--
 .../hawkbit/rabbitmq/test/AbstractAmqpIntegrationTest.java    | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/hawkbit-dmf/hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpMessageDispatcherService.java b/hawkbit-dmf/hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpMessageDispatcherService.java
index 4339d3926..8daa8916c 100644
--- a/hawkbit-dmf/hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpMessageDispatcherService.java
+++ b/hawkbit-dmf/hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpMessageDispatcherService.java
@@ -367,7 +367,7 @@ public class AmqpMessageDispatcherService extends BaseAmqpService {
             return;
         }
 
-        final Message message = new Message(null, createConnectorMessagePropertiesDeleteThing(tenant, controllerId));
+        final Message message = new Message("".getBytes(), createConnectorMessagePropertiesDeleteThing(tenant, controllerId));
         amqpSenderService.sendMessage(message, URI.create(targetAddress));
     }
 
@@ -409,7 +409,7 @@ public class AmqpMessageDispatcherService extends BaseAmqpService {
             return;
         }
 
-        final Message message = new Message(null,
+        final Message message = new Message("".getBytes(),
                 createConnectorMessagePropertiesEvent(tenant, controllerId, EventTopic.REQUEST_ATTRIBUTES_UPDATE));
 
         amqpSenderService.sendMessage(message, URI.create(targetAddress));
diff --git a/hawkbit-dmf/hawkbit-dmf-rabbitmq-test/src/main/java/org/eclipse/hawkbit/rabbitmq/test/AbstractAmqpIntegrationTest.java b/hawkbit-dmf/hawkbit-dmf-rabbitmq-test/src/main/java/org/eclipse/hawkbit/rabbitmq/test/AbstractAmqpIntegrationTest.java
index 9bf22c49f..5d5de762e 100644
--- a/hawkbit-dmf/hawkbit-dmf-rabbitmq-test/src/main/java/org/eclipse/hawkbit/rabbitmq/test/AbstractAmqpIntegrationTest.java
+++ b/hawkbit-dmf/hawkbit-dmf-rabbitmq-test/src/main/java/org/eclipse/hawkbit/rabbitmq/test/AbstractAmqpIntegrationTest.java
@@ -66,7 +66,7 @@ public abstract class AbstractAmqpIntegrationTest extends AbstractIntegrationTes
     protected Message createMessage(final Object payload, final MessageProperties messageProperties) {
         if (payload == null) {
             messageProperties.setContentType(MessageProperties.CONTENT_TYPE_JSON);
-            return new Message(null, messageProperties);
+            return new Message("".getBytes(), messageProperties);
         }
         return getDmfClient().getMessageConverter().toMessage(payload, messageProperties);
     }