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 2013/10/03 18:00:23 UTC
[4/4] git commit: Added trace logging when getting correlation key
from map in camel-jms.
Added trace logging when getting correlation key from map in camel-jms.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b0c7920b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b0c7920b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b0c7920b
Branch: refs/heads/camel-2.12.x
Commit: b0c7920b7cd345c16b89629f109a3fb6c97eb6f0
Parents: fcf4684
Author: Claus Ibsen <da...@apache.org>
Authored: Thu Oct 3 17:59:26 2013 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Oct 3 18:00:07 2013 +0200
----------------------------------------------------------------------
.../camel/component/jms/reply/CorrelationTimeoutMap.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/b0c7920b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/CorrelationTimeoutMap.java
----------------------------------------------------------------------
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/CorrelationTimeoutMap.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/CorrelationTimeoutMap.java
index fdc96e6..7b279d9 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/CorrelationTimeoutMap.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/CorrelationTimeoutMap.java
@@ -57,6 +57,13 @@ public class CorrelationTimeoutMap extends DefaultTimeoutMap<String, ReplyHandle
}
@Override
+ public ReplyHandler get(String key) {
+ ReplyHandler answer = super.get(key);
+ log.trace("Get correlationID: {} -> {}", key, answer != null);
+ return answer;
+ }
+
+ @Override
public void put(String key, ReplyHandler value, long timeoutMillis) {
try {
if (listener != null) {