exception handling

Signed-off-by: Pranshu-G <pranshu.grover18@gmail.com>
eclipse-ditto · Sep 6, 2022 · 65cc533 · 65cc533
1 parent 36166a1
commit 65cc533
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...rvice/src/main/java/org/eclipse/ditto/connectivity/service/mapping/CloudEventsMapper.java b/...rvice/src/main/java/org/eclipse/ditto/connectivity/service/mapping/CloudEventsMapper.java
@@ -64,8 +64,7 @@ public List<Adaptable> map(final ExternalMessage message) {
     MessageMappingFailedException mappingFailedException = MessageMappingFailedException.newBuilder(
             message.findContentType().orElse("")).description("This is not a CloudEvent")
         .dittoHeaders(DittoHeaders.of(message.getHeaders())).build();
-    final String contentType = message.findContentType().orElse(null);
-    if (contentType.equals(CONTENT_TYPE)) {
+    if (message.findContentType().orElse("").equals(CONTENT_TYPE)) {
       final String payload = extractPayloadAsString(message);
       try {
         if (isBinaryCloudEvent(message)) {