Sendiing only changed data now works

Author: codepitbull

modules/hivemq-edge-module-s7/src/main/java/com/hivemq/edge/adapters/s7/S7ProtocolAdapter.java

@@ -136,13 +136,18 @@ public void poll(
             dataPoint = s7Client.read(s7ToMqtt.getDataType(), List.of(tagAddress)).get(0);
         }
 
-        if(adapterConfig.getPublishChangedDataOnly() && dataPoints.containsKey(tagAddress)) {
-            final DataPoint existingDataPoint = dataPoints.get(tagAddress);
-            if(existingDataPoint != null && !existingDataPoint.equals(dataPoint)) {
+        if(adapterConfig.getPublishChangedDataOnly()) {
+            if(dataPoints.containsKey(tagAddress)) {
+                final DataPoint existingDataPoint = dataPoints.get(tagAddress);
+                if(existingDataPoint != null && existingDataPoint.equals(dataPoint)) {
+                    log.info("Skipping sending for {} because publishChangedDataOnly=true", tagAddress);
+                } else {
+                    dataPoints.put(tagAddress, dataPoint);
+                    pollingOutput.addDataPoint(dataPoint);
+                }
+            } else {
                 dataPoints.put(tagAddress, dataPoint);
                 pollingOutput.addDataPoint(dataPoint);
-            } else {
-                log.debug("Skipping sending for {} because publishChangedDataOnly=true", tagAddress);
             }
         } else {
             pollingOutput.addDataPoint(dataPoint);

modules/hivemq-edge-module-s7/src/main/java/com/hivemq/edge/adapters/s7/config/S7AdapterConfig.java

@@ -124,7 +124,7 @@ public enum ControllerType {
     @JsonCreator
     public S7AdapterConfig(
             @JsonProperty(value = "id", required = true) final @NotNull String id,
-            @JsonProperty(value = "port", required = true) final int port,
+            @JsonProperty(value = "port", required = true, defaultValue = "102") final int port,
             @JsonProperty(value = "host", required = true) final @NotNull String host,
             @JsonProperty(value = "controllerType", required = true) final @NotNull ControllerType controllerType,
             @JsonProperty(value = "remoteRack") final @Nullable Integer remoteRack,