简柏林 / thingskit · Commits

Commit aa89c1a544b465f63505a766b7c0efcb77f0fd9b

Authored by lonwern
1 parent 43e45020

Add SUB ACK on topic v1/gateway/rpc

Inline Side-by-side
Showing 1 changed file with 2 additions and 0 deletions
@@ -244,6 +244,8 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement @@ -244,6 +244,8 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
244 grantedQoSList.add(getMinSupportedQos(reqQoS)); 244 grantedQoSList.add(getMinSupportedQos(reqQoS));
245 } else if (topicName.equals(GATEWAY_ATTRIBUTES_TOPIC)) { 245 } else if (topicName.equals(GATEWAY_ATTRIBUTES_TOPIC)) {
246 grantedQoSList.add(getMinSupportedQos(reqQoS)); 246 grantedQoSList.add(getMinSupportedQos(reqQoS));
  247 + } else if (topicName.equals(GATEWAY_RPC_TOPIC)) {
  248 + grantedQoSList.add(getMinSupportedQos(reqQoS));
247 } else { 249 } else {
248 log.warn("[{}] Failed to subscribe to [{}][{}]", sessionId, topicName, reqQoS); 250 log.warn("[{}] Failed to subscribe to [{}][{}]", sessionId, topicName, reqQoS);
249 grantedQoSList.add(FAILURE.value()); 251 grantedQoSList.add(FAILURE.value());