|
|
@ -205,7 +205,7 @@ public class DefaultDeviceStateServiceTest { |
|
|
|
|
|
|
|
|
// THEN
|
|
|
// THEN
|
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(DataConstants.SERVER_SCOPE), eq(LAST_CONNECT_TIME), eq(lastConnectTime), any() |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(AttributeScope.SERVER_SCOPE), eq(LAST_CONNECT_TIME), eq(lastConnectTime), any() |
|
|
); |
|
|
); |
|
|
|
|
|
|
|
|
var msgCaptor = ArgumentCaptor.forClass(TbMsg.class); |
|
|
var msgCaptor = ArgumentCaptor.forClass(TbMsg.class); |
|
|
@ -289,7 +289,7 @@ public class DefaultDeviceStateServiceTest { |
|
|
|
|
|
|
|
|
// THEN
|
|
|
// THEN
|
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(DataConstants.SERVER_SCOPE), |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(AttributeScope.SERVER_SCOPE), |
|
|
eq(LAST_DISCONNECT_TIME), eq(lastDisconnectTime), any() |
|
|
eq(LAST_DISCONNECT_TIME), eq(lastDisconnectTime), any() |
|
|
); |
|
|
); |
|
|
|
|
|
|
|
|
@ -410,11 +410,11 @@ public class DefaultDeviceStateServiceTest { |
|
|
|
|
|
|
|
|
// THEN
|
|
|
// THEN
|
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(DataConstants.SERVER_SCOPE), |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(AttributeScope.SERVER_SCOPE), |
|
|
eq(INACTIVITY_ALARM_TIME), eq(lastInactivityTime), any() |
|
|
eq(INACTIVITY_ALARM_TIME), eq(lastInactivityTime), any() |
|
|
); |
|
|
); |
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(DataConstants.SERVER_SCOPE), |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(AttributeScope.SERVER_SCOPE), |
|
|
eq(ACTIVITY_STATE), eq(false), any() |
|
|
eq(ACTIVITY_STATE), eq(false), any() |
|
|
); |
|
|
); |
|
|
|
|
|
|
|
|
@ -450,11 +450,11 @@ public class DefaultDeviceStateServiceTest { |
|
|
|
|
|
|
|
|
// THEN
|
|
|
// THEN
|
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(DataConstants.SERVER_SCOPE), |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(AttributeScope.SERVER_SCOPE), |
|
|
eq(INACTIVITY_ALARM_TIME), anyLong(), any() |
|
|
eq(INACTIVITY_ALARM_TIME), anyLong(), any() |
|
|
); |
|
|
); |
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
then(telemetrySubscriptionService).should().saveAttrAndNotify( |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(DataConstants.SERVER_SCOPE), |
|
|
eq(TenantId.SYS_TENANT_ID), eq(deviceId), eq(AttributeScope.SERVER_SCOPE), |
|
|
eq(ACTIVITY_STATE), eq(false), any() |
|
|
eq(ACTIVITY_STATE), eq(false), any() |
|
|
); |
|
|
); |
|
|
|
|
|
|
|
|
|