Updated Branches: refs/heads/master 5a986c507 -> cba66ff78
CAMEL-6545 polish the code as Claus suggested Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cba66ff7 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cba66ff7 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cba66ff7 Branch: refs/heads/master Commit: cba66ff78f2541d054a5b48d73165942ca034594 Parents: 5a986c5 Author: Willem Jiang <ningji...@apache.org> Authored: Thu Aug 22 15:16:10 2013 +0800 Committer: Willem Jiang <ningji...@apache.org> Committed: Thu Aug 22 15:17:21 2013 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/camel/component/seda/SedaEndpoint.java | 3 +-- .../main/java/org/apache/camel/component/seda/SedaProducer.java | 1 - 2 files changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/cba66ff7/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java b/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java index 5fe1b8c..228eb00 100644 --- a/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java +++ b/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java @@ -175,9 +175,8 @@ public class SedaEndpoint extends DefaultEndpoint implements BrowsableEndpoint, String key = getComponent().getQueueKey(getEndpointUri()); QueueReference ref = getComponent().getQueueReference(key); if (ref == null) { - LOG.warn("There was no queue reference for this queue!"); + LOG.warn("There was no queue reference for the endpoint {0}", getEndpointUri()); } - return ref; } http://git-wip-us.apache.org/repos/asf/camel/blob/cba66ff7/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java b/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java index ada3cde..379443d 100644 --- a/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java +++ b/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java @@ -214,7 +214,6 @@ public class SedaProducer extends DefaultAsyncProducer { BlockingQueue<Exchange> queue = queueReference.getQueue(); if (endpoint.isFailIfNoConsumers() && !queueReference.hasConsumers()) { - LOG.warn("No consumers available on endpoint: " + endpoint + " to process: " + exchange); throw new SedaConsumerNotAvailableException("No consumers available on endpoint: " + endpoint, exchange); } if (blockWhenFull) {
