Activity: comments1
This commit is contained in:
parent
d77e557945
commit
737962ae07
@ -1105,7 +1105,7 @@ public class DefaultTransportService extends TransportActivityManager implements
|
|||||||
try {
|
try {
|
||||||
tpi = partitionService.resolve(ServiceType.TB_CORE, tenantId, entityId);
|
tpi = partitionService.resolve(ServiceType.TB_CORE, tenantId, entityId);
|
||||||
} catch (Exception e) {
|
} catch (Exception 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);
|
log.warn("Failed to send message to core. Tenant with ID [{}], routingKey [{}], msg [{}]. Message delivery aborted.", tenantId, routingKey, msg, e);
|
||||||
if (callback != null) {
|
if (callback != null) {
|
||||||
callback.onError(e);
|
callback.onError(e);
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user