dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #10394 from thingsboard/fix/queue-deletion-event

Browse Source 
Ignore partition change event for deleted queues
This commit is contained in:
Viacheslav Klimov 2024-03-19 13:34:51 +02:00 committed by GitHub
commit ac430e9a80
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
application/src/main/java/org/thingsboard/server/service/queue/DefaultTbRuleEngineConsumerService.java
View File

@ -114,10 +114,18 @@ public class DefaultTbRuleEngineConsumerService extends AbstractConsumerService<
if (partitionService.isManagedByCurrentService(queueKey.getTenantId())) { if (partitionService.isManagedByCurrentService(queueKey.getTenantId())) {
var consumer = getConsumer(queueKey).orElseGet(() -> { var consumer = getConsumer(queueKey).orElseGet(() -> {
Queue config = queueService.findQueueByTenantIdAndName(queueKey.getTenantId(), queueKey.getQueueName()); Queue config = queueService.findQueueByTenantIdAndName(queueKey.getTenantId(), queueKey.getQueueName());
if (config == null) {
if (!partitions.isEmpty()) {
log.error("[{}] Queue configuration is missing", queueKey, new RuntimeException("stacktrace"));
}
return null;
}
return createConsumer(queueKey, config); return createConsumer(queueKey, config);
}); });
if (consumer != null) {
consumer.update(partitions); consumer.update(partitions);
} }
}
}); });
consumers.keySet().stream() consumers.keySet().stream()
.collect(Collectors.groupingBy(QueueKey::getTenantId)) .collect(Collectors.groupingBy(QueueKey::getTenantId))