You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by dk...@apache.org on 2011/09/20 00:46:38 UTC
svn commit: r1172872 - in /camel/branches/camel-2.8.x: ./
camel-core/src/main/java/org/apache/camel/component/seda/SedaProducer.java
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);