fix(rabbitmq): NPE during properties deserialization (#689)

camunda · Jun 7, 2023 · aac9c5b · aac9c5b
1 parent 2adb598
commit aac9c5b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/.../src/main/java/io/camunda/connector/runtime/core/inbound/InboundConnectorContextImpl.java b/.../src/main/java/io/camunda/connector/runtime/core/inbound/InboundConnectorContextImpl.java
@@ -40,6 +40,7 @@
 
 public class InboundConnectorContextImpl extends AbstractConnectorContext
     implements InboundConnectorContext {
+
   private final Logger LOG = LoggerFactory.getLogger(InboundConnectorContextImpl.class);
   private static final Set<String> reservedKeys =
       Set.of(
@@ -111,8 +112,10 @@ public InboundConnectorProperties getProperties() {
 
   @Override
   public <T> T getPropertiesAsType(Class<T> cls) {
+
     Map<String, Object> result =
         properties.getPropertiesAsObjectMap().entrySet().stream()
+            .filter(entry -> entry.getValue() != null)
             .collect(
                 Collectors.toMap(
                     Map.Entry::getKey,
@@ -121,6 +124,7 @@ public <T> T getPropertiesAsType(Class<T> cls) {
                             ? entry.getValue()
                             : FeelParserWrapper.parseIfIsFeelExpressionOrGetOriginal(
                                 entry.getValue())));
+
     return objectMapper.convertValue(result, cls);
   }