Browse Source

activity: add return if callback error

pull/11893/head
nick 2 years ago
parent
commit
d77e557945
  1. 6
      common/transport/transport-api/src/main/java/org/thingsboard/server/common/transport/service/DefaultTransportService.java

6
common/transport/transport-api/src/main/java/org/thingsboard/server/common/transport/service/DefaultTransportService.java

@ -1104,12 +1104,12 @@ public class DefaultTransportService extends TransportActivityManager implements
TopicPartitionInfo tpi; TopicPartitionInfo tpi;
try { try {
tpi = partitionService.resolve(ServiceType.TB_CORE, tenantId, entityId); tpi = partitionService.resolve(ServiceType.TB_CORE, tenantId, entityId);
} catch (TenantNotFoundException e) { } catch (Exception e) {
log.trace("Failed to send message to core. Tenant with ID [{}] not found in the database. Message delivery aborted.", tenantId, e); log.trace("Failed to send message to core. Tenant with ID [{}], entityType [{}], entityId [{}], routingKey [{}], \nmsg [{}].\n Message delivery aborted.", tenantId, entityId.getEntityType(), entityId.toString(), routingKey, msg, e);
tpi = TopicPartitionInfo.builder().topic("").build();
if (callback != null) { if (callback != null) {
callback.onError(e); callback.onError(e);
} }
return;
} }
if (log.isTraceEnabled()) { if (log.isTraceEnabled()) {
log.trace("[{}][{}] Pushing to topic {} message {}", tenantId, entityId, tpi.getFullTopicName(), msg); log.trace("[{}][{}] Pushing to topic {} message {}", tenantId, entityId, tpi.getFullTopicName(), msg);

Loading…
Cancel
Save