camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r771637 - /camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisPollingConsumer.java
Date Tue, 05 May 2009 09:26:25 GMT
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);
+        }
     }
     
     /**



Mime
View raw message