Browse Source

fixed race condition during queue creating

pull/6534/head
YevhenBondarenko 4 years ago
parent
commit
0bf8749ca5
  1. 2
      common/data/src/main/java/org/thingsboard/server/common/data/TenantProfile.java
  2. 2
      common/queue/src/main/java/org/thingsboard/server/queue/discovery/HashPartitionService.java

2
common/data/src/main/java/org/thingsboard/server/common/data/TenantProfile.java

@ -21,6 +21,7 @@ import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.ToString;
import lombok.extern.slf4j.Slf4j;
import org.thingsboard.server.common.data.id.TenantProfileId;
import org.thingsboard.server.common.data.tenant.profile.DefaultTenantProfileConfiguration;
@ -36,6 +37,7 @@ import static org.thingsboard.server.common.data.SearchTextBasedWithAdditionalIn
@ApiModel
@Data
@ToString(exclude = {"profileDataBytes"})
@EqualsAndHashCode(callSuper = true)
@Slf4j
public class TenantProfile extends SearchTextBased<TenantProfileId> implements HasName {

2
common/queue/src/main/java/org/thingsboard/server/queue/discovery/HashPartitionService.java

@ -214,8 +214,6 @@ public class HashPartitionService implements PartitionService {
@Override
public synchronized void recalculatePartitions(ServiceInfo currentService, List<ServiceInfo> otherServices) {
partitionsInit();
tbTransportServicesByType.clear();
logServiceInfo(currentService);
otherServices.forEach(this::logServiceInfo);

Loading…
Cancel
Save