You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ch...@apache.org on 2007/09/17 18:37:54 UTC
svn commit: r576510 -
/activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
Author: chirino
Date: Mon Sep 17 09:37:49 2007
New Revision: 576510
URL: http://svn.apache.org/viewvc?rev=576510&view=rev
Log:
Simplify using a helper
Modified:
activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
Modified: activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java?rev=576510&r1=576509&r2=576510&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java (original)
+++ activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java Mon Sep 17 09:37:49 2007
@@ -5,6 +5,7 @@
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.impl.DefaultProducer;
+import org.apache.camel.util.AsyncProcessorHelper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.http.*;
@@ -102,15 +103,7 @@
if (LOG.isDebugEnabled()) {
LOG.debug("process: " + exchange);
}
- AsyncCallback callback = new AsyncCallback() {
- public synchronized void done(boolean doneSynchronously) {
- notify();
- }
- };
- synchronized (callback) {
- process(exchange, callback);
- callback.wait();
- }
+ AsyncProcessorHelper.process(this, exchange);
}
public boolean process(Exchange exchange, AsyncCallback callback) {