You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/04/13 06:46:03 UTC
[camel] 02/02: Polished
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 1a55629290f2ed5089f815dcefb9298ef5293cfe
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Apr 13 07:37:34 2021 +0200
Polished
---
.../org/apache/camel/impl/engine/PrototypeExchangeFactory.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PrototypeExchangeFactory.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PrototypeExchangeFactory.java
index 9752f4d..e37be97 100644
--- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PrototypeExchangeFactory.java
+++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PrototypeExchangeFactory.java
@@ -145,6 +145,11 @@ public class PrototypeExchangeFactory extends PooledObjectFactorySupport<Exchang
boolean shouldLog = pooled > 0 || created > 0 || acquired > 0 || released > 0 || discarded > 0;
if (shouldLog) {
String id = getRouteId();
+ if (id == null) {
+ id = "";
+ } else {
+ id = " " + id;
+ }
String uri = consumer.getEndpoint().getEndpointBaseUri();
uri = URISupport.sanitizeUri(uri);
@@ -153,10 +158,10 @@ public class PrototypeExchangeFactory extends PooledObjectFactorySupport<Exchang
if (leak) {
long leaks = (created + acquired) - (released + discarded);
log.warn(
- "{} {} ({}) usage (leaks detected: {}) [pooled: {}, created: {}, acquired: {} released: {}, discarded: {}]",
+ "{}{} ({}) usage (leaks detected: {}) [pooled: {}, created: {}, acquired: {} released: {}, discarded: {}]",
name, id, uri, leaks, pooled, created, acquired, released, discarded);
} else {
- log.info("{} {} ({}) usage [pooled: {}, created: {}, acquired: {} released: {}, discarded: {}]",
+ log.info("{}{} ({}) usage [pooled: {}, created: {}, acquired: {} released: {}, discarded: {}]",
name, id, uri, pooled, created, acquired, released, discarded);
}
}