minor fix

2 years ago · 4440e559fe
1 changed files with 1 additions and 1 deletions
--- a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/session/AbstractGatewaySessionHandler.java
+++ b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/session/AbstractGatewaySessionHandler.java
@ -408,7 +408,7 @@ public abstract class AbstractGatewaySessionHandler<T extends AbstractGatewayDev
                    var publishedTs = jo.get("publishedTs").getAsLong();
                    return new GatewayMetricsData(connector, receivedTs, publishedTs);
                }).toList();
-        if (!metadata.isEmpty()) {
+        if (!metricsData.isEmpty()) {
            gatewayMetricsService.process(deviceSessionCtx.getSessionInfo(), gateway.getDeviceId(), metricsData, serverReceiveTs);
        }
    }