sparkplug: delete isSparkplug from transport proto

3 years ago · 8236e26e5c
2 changed files with 0 additions and 2 deletions
--- a/common/cluster-api/src/main/proto/queue.proto
+++ b/common/cluster-api/src/main/proto/queue.proto
@ -186,7 +186,6 @@ message GetOrCreateDeviceFromGatewayRequestMsg {
  int64 gatewayIdLSB = 2;
  string deviceName = 3;
  string deviceType = 4;
-  bool sparkplug = 5;
 }

 message GetOrCreateDeviceFromGatewayResponseMsg {
--- 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
@ -253,7 +253,6 @@ public abstract class AbstractGatewaySessionHandler<T extends AbstractGatewayDev
                            .setDeviceType(deviceType)
                            .setGatewayIdMSB(gateway.getDeviceId().getId().getMostSignificantBits())
                            .setGatewayIdLSB(gateway.getDeviceId().getId().getLeastSignificantBits())
-                            .setSparkplug(this.deviceSessionCtx.isSparkplug())
                            .build(),
                    new TransportServiceCallback<>() {
                        @Override