You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/05/05 11:26:25 UTC
svn commit: r771637 -
/camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisPollingConsumer.java
Author: davsclaus
Date: Tue May 5 09:26:25 2009
New Revision: 771637
URL: http://svn.apache.org/viewvc?rev=771637&view=rev
Log:
CAMEL-1572: API cleanup
Modified:
camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisPollingConsumer.java
Modified: camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisPollingConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisPollingConsumer.java?rev=771637&r1=771636&r2=771637&view=diff
==============================================================================
--- camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisPollingConsumer.java (original)
+++ camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisPollingConsumer.java Tue May 5 09:26:25 2009
@@ -18,7 +18,6 @@
import java.util.List;
-import org.apache.camel.AsyncCallback;
import org.apache.camel.Exchange;
import org.apache.camel.ExchangePattern;
import org.apache.camel.Message;
@@ -158,17 +157,15 @@
LOG.debug("Processing exchange: " + exchange);
}
- getAsyncProcessor().process(exchange, new AsyncCallback() {
- public void done(boolean sync) {
- try {
- if (onConsume != null) {
- endpoint.getProcessingStrategy().commit(endpoint, exchange, data, onConsume);
- }
- } catch (Exception e) {
- handleException(e);
- }
+ getProcessor().process(exchange);
+
+ try {
+ if (onConsume != null) {
+ endpoint.getProcessingStrategy().commit(endpoint, exchange, data, onConsume);
}
- });
+ } catch (Exception e) {
+ handleException(e);
+ }
}
/**