removed payloadType from SessionLimits

application/src/test/java/org/thingsboard/server/transport/mqtt/mqttv3/rpc/MqttClientSideRpcIntegrationTest.java

@@ -68,7 +68,6 @@ public class MqttClientSideRpcIntegrationTest extends AbstractMqttIntegrationTes
         expectedLimits.setRateLimits(deviceLimits);
         expectedLimits.setMaxPayloadSize(maxPayloadSize);
         expectedLimits.setMaxInflightMessages(maxInflightMessages);
-        expectedLimits.setPayloadType(TransportPayloadType.JSON);
 
         MqttTestConfigProperties configProperties = MqttTestConfigProperties.builder()
                 .deviceName("Test Get Service Configuration")
@@ -122,7 +121,6 @@ public class MqttClientSideRpcIntegrationTest extends AbstractMqttIntegrationTes
         expectedLimits.setRateLimits(gatewayDeviceLimits);
         expectedLimits.setMaxPayloadSize(maxPayloadSize);
         expectedLimits.setMaxInflightMessages(maxInflightMessages);
-        expectedLimits.setPayloadType(TransportPayloadType.JSON);
 
         MqttTestConfigProperties configProperties = MqttTestConfigProperties.builder()
                 .gatewayName("Test Get Service Configuration Gateway")

common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java

@@ -1364,7 +1364,6 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
         }
         sessionLimits.setMaxPayloadSize(context.getMaxPayloadSize());
         sessionLimits.setMaxInflightMessages(context.getMessageQueueSizePerDeviceLimit());
-        sessionLimits.setPayloadType(deviceSessionCtx.getPayloadType());
 
         ack(ctx, msgId, MqttReasonCodes.PubAck.SUCCESS);
 

common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/limits/SessionLimits.java

@@ -23,7 +23,6 @@ public class SessionLimits {
 
     private int maxPayloadSize;
     private int maxInflightMessages;
-    private TransportPayloadType payloadType;
     private SessionRateLimits rateLimits;
 
     public record SessionRateLimits(String messages, String telemetryMessages, String telemetryDataPoints) {}