Browse Source

create consumer when create tenant

pull/13061/head
IrynaMatveieva 1 year ago
parent
commit
ae894f9ed3
  1. 4
      application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCalculatedFieldConsumerService.java

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

@ -258,6 +258,10 @@ public class DefaultTbCalculatedFieldConsumerService extends AbstractPartitionBa
}
return toRemove;
});
} else if (event.getEvent() == ComponentLifecycleEvent.CREATED) {
if (partitionService.isManagedByCurrentService(event.getTenantId())) {
stateService.init(createConsumer(event.getTenantId()));
}
}
}
}

Loading…
Cancel
Save