|
|
|
@ -700,7 +700,7 @@ public class WebsocketApiTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
private void sendAttributes(TenantId tenantId, EntityId entityId, TbAttributeSubscriptionScope scope, List<AttributeKvEntry> attrData) throws InterruptedException { |
|
|
|
CountDownLatch latch = new CountDownLatch(1); |
|
|
|
tsService.saveAndNotify(tenantId, entityId, scope.name(), attrData, new FutureCallback<Void>() { |
|
|
|
tsService.saveAndNotify(tenantId, entityId, scope.getAttributeScope(), attrData, new FutureCallback<Void>() { |
|
|
|
@Override |
|
|
|
public void onSuccess(@Nullable Void result) { |
|
|
|
log.debug("sendAttributes callback onSuccess"); |
|
|
|
|