Author: dkulp Date: Mon Sep 19 22:46:38 2011 New Revision: 1172872 URL: http://svn.apache.org/viewvc?rev=1172872&view=rev Log: Merged revisions 1161393 via svnmerge from https://svn.apache.org/repos/asf/camel/trunk
........ r1161393 | davsclaus | 2011-08-25 01:42:48 -0400 (Thu, 25 Aug 2011) | 1 line CAMEL-4227: Polished ........ Modified: camel/branches/camel-2.8.x/ (props changed) camel/branches/camel-2.8.x/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java Propchange: camel/branches/camel-2.8.x/ ------------------------------------------------------------------------------ Binary property 'svnmerge-integrated' - no diff available. Modified: camel/branches/camel-2.8.x/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java URL: http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java?rev=1172872&r1=1172871&r2=1172872&view=diff ============================================================================== --- camel/branches/camel-2.8.x/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java (original) +++ camel/branches/camel-2.8.x/camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java Mon Sep 19 22:46:38 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);