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:21 UTC
[2/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/a27ca6c8
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a27ca6c8
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a27ca6c8
Branch: refs/heads/master
Commit: a27ca6c8e09e67023271fe69ac6362007f7d03be
Parents: 196f527
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 17:59:26 2013 +0200
----------------------------------------------------------------------
.../camel/component/jms/reply/CorrelationTimeoutMap.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/a27ca6c8/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) {