|
|
|
@ -37,6 +37,7 @@ import org.thingsboard.server.common.data.tenant.profile.DefaultTenantProfileCon |
|
|
|
import org.thingsboard.server.common.data.tenant.profile.TenantProfileData; |
|
|
|
import org.thingsboard.server.common.data.tenant.profile.TenantProfileQueueConfiguration; |
|
|
|
import org.thingsboard.server.dao.service.DaoSqlTest; |
|
|
|
import org.thingsboard.server.queue.TbQueueCallback; |
|
|
|
|
|
|
|
import java.util.ArrayList; |
|
|
|
import java.util.Collections; |
|
|
|
@ -44,6 +45,7 @@ import java.util.List; |
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
|
import static org.hamcrest.Matchers.containsString; |
|
|
|
import static org.mockito.ArgumentMatchers.eq; |
|
|
|
import static org.mockito.Mockito.never; |
|
|
|
import static org.mockito.Mockito.times; |
|
|
|
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status; |
|
|
|
@ -354,7 +356,7 @@ public class TenantProfileControllerTest extends AbstractControllerTest { |
|
|
|
argument -> argument.getClass().equals(TenantProfile.class); |
|
|
|
if (ComponentLifecycleEvent.DELETED.equals(event)) { |
|
|
|
Mockito.verify(tbClusterService, times(cntTime)).onTenantProfileDelete(Mockito.argThat(matcherTenantProfile), |
|
|
|
Mockito.isNull()); |
|
|
|
eq(TbQueueCallback.EMPTY)); |
|
|
|
testBroadcastEntityStateChangeEventNever(createEntityId_NULL_UUID(new Tenant())); |
|
|
|
} else { |
|
|
|
Mockito.verify(tbClusterService, times(cntTime)).onTenantProfileChange(Mockito.argThat(matcherTenantProfile), |
|
|
|
|