Browse Source

minor refactoring

pull/11151/head
YevhenBondarenko 2 years ago
parent
commit
92845f60b6
  1. 4
      application/src/main/java/org/thingsboard/server/service/queue/DefaultTbClusterService.java

4
application/src/main/java/org/thingsboard/server/service/queue/DefaultTbClusterService.java

@ -360,13 +360,13 @@ public class DefaultTbClusterService implements TbClusterService {
public void onResourceDeleted(TbResourceInfo resource, TbQueueCallback callback) { public void onResourceDeleted(TbResourceInfo resource, TbQueueCallback callback) {
if (resource.getResourceType() == ResourceType.LWM2M_MODEL) { if (resource.getResourceType() == ResourceType.LWM2M_MODEL) {
log.trace("[{}] Processing delete resource", resource); log.trace("[{}] Processing delete resource", resource);
TransportProtos.ResourceDeleteMsg resourceUpdateMsg = TransportProtos.ResourceDeleteMsg.newBuilder() TransportProtos.ResourceDeleteMsg resourceDeleteMsg = TransportProtos.ResourceDeleteMsg.newBuilder()
.setTenantIdMSB(resource.getTenantId().getId().getMostSignificantBits()) .setTenantIdMSB(resource.getTenantId().getId().getMostSignificantBits())
.setTenantIdLSB(resource.getTenantId().getId().getLeastSignificantBits()) .setTenantIdLSB(resource.getTenantId().getId().getLeastSignificantBits())
.setResourceType(resource.getResourceType().name()) .setResourceType(resource.getResourceType().name())
.setResourceKey(resource.getResourceKey()) .setResourceKey(resource.getResourceKey())
.build(); .build();
ToTransportMsg transportMsg = ToTransportMsg.newBuilder().setResourceDeleteMsg(resourceUpdateMsg).build(); ToTransportMsg transportMsg = ToTransportMsg.newBuilder().setResourceDeleteMsg(resourceDeleteMsg).build();
broadcast(transportMsg, DataConstants.LWM2M_TRANSPORT_NAME, callback); broadcast(transportMsg, DataConstants.LWM2M_TRANSPORT_NAME, callback);
} }
} }

Loading…
Cancel
Save