svn commit: r930640 - in /camel/trunk/camel-core/src/main/java/org/apache/camel: component/seda/SedaComponent.java spi/Provider.java

[da...@apache.org]

Author: davsclaus
Date: Sun Apr  4 08:07:17 2010
New Revision: 930640

URL: http://svn.apache.org/viewvc?rev=930640&view=rev
Log:
Polished code a bit

Removed:
    camel/trunk/camel-core/src/main/java/org/apache/camel/spi/Provider.java
Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaComponent.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaComponent.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaComponent.java?rev=930640&r1=930639&r2=930640&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaComponent.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaComponent.java Sun Apr  4 08:07:17 2010
@@ -24,8 +24,6 @@ import java.util.concurrent.LinkedBlocki
 import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
 import org.apache.camel.impl.DefaultComponent;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 
 /**
  * An implementation of the <a href="http://camel.apache.org/seda.html">SEDA components</a>
@@ -34,8 +32,6 @@ import org.apache.commons.logging.LogFac
  * @version $Revision$
  */
 public class SedaComponent extends DefaultComponent {
-
-    private static final transient Log LOG = LogFactory.getLog(SedaComponent.class);
     private final Map<String, BlockingQueue<Exchange>> queues = new HashMap<String, BlockingQueue<Exchange>>();
     private final int maxConcurrentConsumers = 500;
     
@@ -64,7 +60,8 @@ public class SedaComponent extends Defau
         int consumers = getAndRemoveParameter(parameters, "concurrentConsumers", Integer.class, 1);
         boolean limitConcurrentConsumers = getAndRemoveParameter(parameters, "limitConcurrentConsumers", Boolean.class, true);
         if ((limitConcurrentConsumers) && (consumers >  maxConcurrentConsumers)) {
-            throw new IllegalArgumentException("The limitConcurrentConsumers flag in set to true. Concurrent Consumers cannot be set at a value greater than " + maxConcurrentConsumers);
+            throw new IllegalArgumentException("The limitConcurrentConsumers flag in set to true. ConcurrentConsumers cannot be set at a value greater than "
+                    + maxConcurrentConsumers + " was " + consumers);
         }
         SedaEndpoint answer = new SedaEndpoint(uri, this, createQueue(uri, parameters), consumers);
         answer.configureProperties(parameters);