Polished
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/110da951 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/110da951 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/110da951 Branch: refs/heads/camel-2.12.x Commit: 110da951502922cebfe49909c4752463ef0c5961 Parents: b0c7920 Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Oct 3 18:19:30 2013 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Oct 3 18:21:06 2013 +0200 ---------------------------------------------------------------------- .../component/jms/reply/TemporaryQueueReplyManager.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/110da951/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java ---------------------------------------------------------------------- diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java index 8f9084e..a5e8798 100644 --- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java +++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java @@ -196,7 +196,7 @@ public class TemporaryQueueReplyManager extends ReplyManagerSupport { private final class TemporaryReplyQueueDestinationResolver implements DestinationResolver { private TemporaryQueue queue; - private AtomicBoolean refreshWanted = new AtomicBoolean(false); + private final AtomicBoolean refreshWanted = new AtomicBoolean(false); public Destination resolveDestinationName(Session session, String destinationName, boolean pubSubDomain) throws JMSException { // use a temporary queue to gather the reply message @@ -204,7 +204,9 @@ public class TemporaryQueueReplyManager extends ReplyManagerSupport { if (queue == null || refreshWanted.compareAndSet(true, false)) { queue = session.createTemporaryQueue(); setReplyTo(queue); - log.debug("Refreshed Temporary ReplyTo Queue. New queue: " + queue.getQueueName()); + if (log.isDebugEnabled()) { + log.debug("Refreshed Temporary ReplyTo Queue. New queue: {}", queue.getQueueName()); + } refreshWanted.notifyAll(); } } @@ -218,7 +220,7 @@ public class TemporaryQueueReplyManager extends ReplyManagerSupport { public void destinationReady() throws InterruptedException { if (refreshWanted.get()) { synchronized (refreshWanted) { - log.debug("Waiting for new Temp ReplyTo destination to be assigned to continue"); + log.debug("Waiting for new Temporary ReplyTo queue to be assigned before we can continue"); refreshWanted.wait(); } }
