|
@@ -33,8 +33,13 @@ public class NetPumpDeviceMetadataCodec implements DeviceMessageCodec {
|
|
|
@Override
|
|
@Override
|
|
|
public Publisher<DeviceMessage> decode(@Nonnull MessageDecodeContext context) {
|
|
public Publisher<DeviceMessage> decode(@Nonnull MessageDecodeContext context) {
|
|
|
byte[] bytes = context.getMessage().getPayload().array();
|
|
byte[] bytes = context.getMessage().getPayload().array();
|
|
|
- String value = DataUtils.byteArrToHexString(bytes);
|
|
|
|
|
-
|
|
|
|
|
|
|
+// String value = DataUtils.byteArrToHexString(bytes);
|
|
|
|
|
+ String value =new String(bytes);
|
|
|
|
|
+ MqttMessage message = (MqttMessage) context.getMessage();
|
|
|
|
|
+ String topic = message.getTopic();
|
|
|
|
|
+ if (!topic.endsWith("/properties/report")) {
|
|
|
|
|
+ throw new UnsupportedOperationException();
|
|
|
|
|
+ }
|
|
|
return decodeLong(value);
|
|
return decodeLong(value);
|
|
|
}
|
|
}
|
|
|
|
|
|