svn commit: r1161393 - /camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java

[davsclaus]

Author: davsclaus
Date: Thu Aug 25 05:42:48 2011
New Revision: 1161393

URL: http://svn.apache.org/viewvc?rev=1161393&view=rev
Log:
CAMEL-4227: Polished

Modified:
    
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java?rev=1161393&r1=1161392&r2=1161393&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java
 Thu Aug 25 05:42:48 2011
@@ -16,7 +16,6 @@
  */
 package org.apache.camel.component.seda;
 
-import java.util.Collection;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
@@ -33,7 +32,7 @@ import org.apache.camel.util.ExchangeHel
  * @version 
  */
 public class SedaProducer extends DefaultAsyncProducer {
-    protected final Collection<Exchange> queue;
+    protected final BlockingQueue<Exchange> queue;
     private final SedaEndpoint endpoint;
     private final WaitForTaskToComplete waitForTaskToComplete;
     private final long timeout;
@@ -177,9 +176,10 @@ public class SedaProducer extends Defaul
     protected void addToQueue(Exchange exchange) {
         if (blockWhenFull) {
             try {
-                ((BlockingQueue<Exchange>)queue).put(exchange);
+                queue.put(exchange);
             } catch (InterruptedException e) {
                 // ignore
+                log.debug("Put interrupted, are we stopping? {}", isStopping() 
|| isStopped());
             }
         } else {
             queue.add(exchange);