Browse Source
Merge branch 'master' into fix/4807-alarm-comment-trim
pull/11976/head
Max Petrov
2 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with
10 additions and
2 deletions
-
common/transport/transport-api/src/main/java/org/thingsboard/server/common/transport/service/DefaultTransportService.java
|
|
|
@ -1101,11 +1101,19 @@ public class DefaultTransportService extends TransportActivityManager implements |
|
|
|
} |
|
|
|
|
|
|
|
private void sendToCore(TenantId tenantId, EntityId entityId, ToCoreMsg msg, UUID routingKey, TransportServiceCallback<Void> callback) { |
|
|
|
TopicPartitionInfo tpi = partitionService.resolve(ServiceType.TB_CORE, tenantId, entityId); |
|
|
|
TopicPartitionInfo tpi; |
|
|
|
try { |
|
|
|
tpi = partitionService.resolve(ServiceType.TB_CORE, tenantId, entityId); |
|
|
|
} catch (Exception e) { |
|
|
|
log.warn("Failed to send message to core. Tenant with ID [{}], routingKey [{}], msg [{}]. Message delivery aborted.", tenantId, routingKey, msg, e); |
|
|
|
if (callback != null) { |
|
|
|
callback.onError(e); |
|
|
|
} |
|
|
|
return; |
|
|
|
} |
|
|
|
if (log.isTraceEnabled()) { |
|
|
|
log.trace("[{}][{}] Pushing to topic {} message {}", tenantId, entityId, tpi.getFullTopicName(), msg); |
|
|
|
} |
|
|
|
|
|
|
|
TransportTbQueueCallback transportTbQueueCallback = callback != null ? |
|
|
|
new TransportTbQueueCallback(callback) : null; |
|
|
|
tbCoreProducerStats.incrementTotal(); |
|
|
|
|