reportActivity: add topic empty
This commit is contained in:
parent
12c35d903a
commit
2d4a4ad991
@ -1106,7 +1106,7 @@ public class DefaultTransportService extends TransportActivityManager implements
|
||||
tpi = partitionService.resolve(ServiceType.TB_CORE, tenantId, entityId);
|
||||
} catch (TenantNotFoundException e) {
|
||||
log.trace("Failed to send message to core. Tenant with ID [{}] not found in the database. Message delivery aborted.", tenantId, e);
|
||||
tpi = TopicPartitionInfo.builder().topic(e.getMessage()).build();
|
||||
tpi = TopicPartitionInfo.builder().topic("").build();
|
||||
if (callback != null) {
|
||||
callback.onError(e);
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user