|
|
@ -995,7 +995,6 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement |
|
|
@Override |
|
|
@Override |
|
|
public void onAttributeUpdate(UUID sessionId, TransportProtos.AttributeUpdateNotificationMsg notification) { |
|
|
public void onAttributeUpdate(UUID sessionId, TransportProtos.AttributeUpdateNotificationMsg notification) { |
|
|
log.trace("[{}] Received attributes update notification to device", sessionId); |
|
|
log.trace("[{}] Received attributes update notification to device", sessionId); |
|
|
log.info("[{}] : attrSubTopicType: {}", notification.toString(), attrSubTopicType); |
|
|
|
|
|
String topic; |
|
|
String topic; |
|
|
MqttTransportAdaptor adaptor; |
|
|
MqttTransportAdaptor adaptor; |
|
|
switch (attrSubTopicType) { |
|
|
switch (attrSubTopicType) { |
|
|
@ -1031,7 +1030,7 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public void onToDeviceRpcRequest(UUID sessionId, TransportProtos.ToDeviceRpcRequestMsg rpcRequest) { |
|
|
public void onToDeviceRpcRequest(UUID sessionId, TransportProtos.ToDeviceRpcRequestMsg rpcRequest) { |
|
|
log.info("[{}] Received RPC command to device", sessionId); |
|
|
log.trace("[{}] Received RPC command to device", sessionId); |
|
|
String baseTopic; |
|
|
String baseTopic; |
|
|
MqttTransportAdaptor adaptor; |
|
|
MqttTransportAdaptor adaptor; |
|
|
switch (rpcSubTopicType) { |
|
|
switch (rpcSubTopicType) { |
|
|
|