简柏林 / thingskit · Commits

Commit 03a2d3e0e49082297e6d8b2e56d33a5da0e3d138

Authored by Igor Kulikov
Committed by GitHub
2 parents 1f80e8db 59187a12

Merge pull request #1115 from thingsboard/lonwern-gateway-rpc-suback 

Lonwern gateway rpc suback
Inline Side-by-side
Showing 1 changed file with 2 additions and 6 deletions
@@ -255,18 +255,14 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement @@ -255,18 +255,14 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
255 break; 255 break;
256 } 256 }
257 case DEVICE_RPC_RESPONSE_SUB_TOPIC: 257 case DEVICE_RPC_RESPONSE_SUB_TOPIC:
  258 + case GATEWAY_ATTRIBUTES_TOPIC:
  259 + case GATEWAY_RPC_TOPIC:
258 registerSubQoS(topic, grantedQoSList, reqQoS); 260 registerSubQoS(topic, grantedQoSList, reqQoS);
259 break; 261 break;
260 case DEVICE_ATTRIBUTES_RESPONSES_TOPIC: 262 case DEVICE_ATTRIBUTES_RESPONSES_TOPIC:
261 deviceSessionCtx.setAllowAttributeResponses(); 263 deviceSessionCtx.setAllowAttributeResponses();
262 registerSubQoS(topic, grantedQoSList, reqQoS); 264 registerSubQoS(topic, grantedQoSList, reqQoS);
263 break; 265 break;
264 - case GATEWAY_ATTRIBUTES_TOPIC:  
265 - registerSubQoS(topic, grantedQoSList, reqQoS);  
266 - break;  
267 - case GATEWAY_RPC_TOPIC:  
268 - registerSubQoS(topic, grantedQoSList, reqQoS);  
269 - break;  
270 default: 266 default:
271 log.warn("[{}] Failed to subscribe to [{}][{}]", sessionId, topic, reqQoS); 267 log.warn("[{}] Failed to subscribe to [{}][{}]", sessionId, topic, reqQoS);
272 grantedQoSList.add(FAILURE.value()); 268 grantedQoSList.add(FAILURE.value());