|
|
|
@ -51,6 +51,9 @@ public class TbMsgAttributesNode implements TbNode { |
|
|
|
@Override |
|
|
|
public void init(TbContext ctx, TbNodeConfiguration configuration) throws TbNodeException { |
|
|
|
this.config = TbNodeUtils.convert(configuration, TbMsgAttributesNodeConfiguration.class); |
|
|
|
if (config.getNotifyDevice() == null) { |
|
|
|
config.setNotifyDevice(true); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
@ -68,7 +71,8 @@ public class TbMsgAttributesNode implements TbNode { |
|
|
|
config.getScope(), |
|
|
|
new ArrayList<>(attributes), |
|
|
|
new TelemetryNodeCallback(ctx, msg), |
|
|
|
config.getNotifyDevice() || StringUtils.isEmpty(notifyDeviceStr) || Boolean.parseBoolean(notifyDeviceStr)); |
|
|
|
config.getNotifyDevice() || StringUtils.isEmpty(notifyDeviceStr) || Boolean.parseBoolean(notifyDeviceStr) |
|
|
|
); |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
|