[CONF] Apache Camel Articles

2011-09-05 Thread confluence 







Articles
Page edited by Claus Ibsen


 Changes (2)
 




...
* [JEEConf 2011 - What riding the Camel can do to make integration easier for you|http://jeeconf.com/program/camel/] \- Video presentation by Claus Ibsen, at the JEEConference in Kiew, Ukraine, May 2011. * [Belgium JUG 2011 - Integration with Apache ServiceMix and Camel|http://www.parleys.com/#id=2601st=5] \- Video presentation by Charles Moulliard, talking about ESB and Camel. 
* [In the brain of James Strachan, riding the Camel|http://skillsmatter.com/podcast/design-architecture/riding-camel/JS-2327] \- Video presentation by [James Strachan|http://macstrac.blogspot.com/], talking about Camel at Skillsmatter, August 2011. * [CamelOne 2011 Video presentations|http://fusesource.com/fuse/camelone-2011-videos/] \- The video presentations from the [CamelOne 2011 conference|http://fusesource.com/camelone2011/], which took place in May 2011. 
 
h2. Podcasts where Camel is taking part  
...
* [Marcelo Jarbalis Blog|http://marcelojabali.blogspot.com/] \- Marcelo works in the fields and blogs about Camel and integration. * [Jean-Baptiste Onofrés Blog|http://blog.nanthrax.net] \- JB blogs about Camel, CXF, Karaf, ServiceMix and OSGi in general. 
* [Kai Wähners Blog|http://www.kai-waehner.de/blog] \- Kai blogs about Camel, ESB, Cloud, and present Camel at various conferences as well. 


Full Content

See alsoSee also Camel User Stories.

Articles on Apache Camel


	Wanna try our Apache Camel developer tools for Enterprise Integration Patterns?  by James Strachan
	A bit more meat: Camel applied : JMS to File by Mike McLean
	Matteo wrote a blog entry about using Camel with iBatis
	Knowledge Tree integration using Apache Camel
	Integrating Apache Camel with JBoss ESB by Edgar Ankiewsky
	Simple DSL OSGi bundle example by Andrej Koelewijn
	Realization of EAI Patterns with Apache Camel by Pascal Kolb at the Universität Stuttgart
	Spring Remoting with JMS Example on Amin Abbaspour's Weblog
	Implementing Fuji integration scenario using Camel SE by Louis Polycarpou on using Camel with Open ESB
	Using the Camel aggregator correctly by Torsten Mielke, a great blog entry how to use the Camel aggregator.
	Camel routes and HL7 by Roger Searjeant on using Camel and its HL7 support in the health care space.
	Combining ApacheCamel+BSF to make JBoss ESB polyglot by Edgard Ankiewsky Silva, a JBoss employeer.
	Groovy and Grape - easiest way to send gtalk message with Apache Camel by Andrej Koelewijn how easy it is to use Groovy and Grape to quickly try out new frameworks such as Apache Camel.
	Domain-Specific Languages (DSLs) in Apache Camel (Spanish) by Gema Perdiguero, Tecsisa.
	Apache Camel integration in ServiceMix (Spanish) by Sebastián Gómez, Tecsisa.
	Open Source Integration with Apache Camel and How Fuse IDE Can Help by Jonathan Anstey. Updated article of the Apache Camel: Integration Nirvana. Great for learning what Camel is and what it can do
	Leverage EIP with Apache Camel and Twitter by Bruno Borges
	Apache Camel Reference Card at DZone (the first card out of two) by Claus Ibsen
	Updated Apache Camel Reference Card at DZone by Claus Ibsen, updated for Camel 2.x Reference Card
	Using RSS with Apache Camel by Jeroen Reijn
	Using Groovy and Camel to pool Google Analyst email reports by Mr. Haki
	Using grails-camel plugin to work with Camel in Grails land by Mr. Haki
	Send mail with Apache Camel from Gails by Mr. Haki
	Navigating the Integration Landscape - Claus Ibsen on Apache Camel Claus Ibsen was interviewed at DZone discussing the integration landscape
	Apache Camel: Enterprise Integration met scripttalen en DSLs (Dutch) by Peter Maas, Finalist IT Group.
	Axis 2 ride with Camel how to use Axis 2 with the Camel report incident tutorial by Sagara
	Introduction to the Open eHealth Integration Platform (based on top of Apache Camel) Excellent DZone article by Martin Krasser
	An IRC alerter written using Apache Camel and Java how to easily integrate IRC with Camel to monitor and do alerts.
	Entreprise Integration Pattern with Apache Camel 2.0 by Julien Dechmann, how to use Camel to split and transform CSV files to POJO and XML and sending to a JMS destination
	A Camel based XML payload HTTP polling provider by Christopher Hunt to use Camel with AJAX. Interesting read.
	Camel vs. JBI by Adrian Trenaman.
	Things to consider when selecting between Apache Camel and Apache Servicemix by Ashwin Karpe
	Groovy and Camel for monitoring ActiveMQ by Eric Hauser how to monitor AMQ Advisory queues from a single groovy file.
	Camellos - Discovering Apache Camel by Gunnar Hillert. A very nice and short blog series about Camel showing its powers in a simple and intuitive way. Highly recommended

svn commit: r1165193 - in /camel/trunk/components/camel-jpa/src: main/java/org/apache/camel/component/jpa/ main/java/org/apache/camel/processor/idempotent/jpa/ main/java/org/apache/camel/processor/int

2011-09-05 Thread davsclaus 
Author: davsclaus
Date: Mon Sep  5 07:51:28 2011
New Revision: 1165193

URL: http://svn.apache.org/viewvc?rev=1165193view=rev
Log:
CAMEL-3142: Polished code. Thanks to Mathieu Lalonde for the patch.

Modified:

camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaConsumer.java

camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java

camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java

camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaTemplateTransactionStrategy.java

camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/QueryBuilder.java

camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/TransactionStrategy.java

camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/processor/idempotent/jpa/JpaMessageIdRepository.java

camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/processor/idempotent/jpa/MessageProcessed.java

camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/processor/interceptor/jpa/JpaTraceEventMessage.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/AbstractJpaMethodTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaEndpointTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaUseMergeTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaWithNamedQueryTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/QueryBuilderTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/interceptor/JpaTraceEventMessageTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/FileConsumerJpaIdempotentTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaBatchConsumerTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaFlushOnSendTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaProducerConcurrentTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaProducerNoBodyTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaRouteConsumeLockEntityTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaRouteMaximumResultsTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaRouteTest.java

camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaRoutemaxMessagesPerPollTest.java

Modified: 
camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaConsumer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaConsumer.java?rev=1165193r1=1165192r2=1165193view=diff
==
--- 
camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaConsumer.java
 (original)
+++ 
camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaConsumer.java
 Mon Sep  5 07:51:28 2011
@@ -52,7 +52,7 @@ public class JpaConsumer extends Schedul
 private String query;
 private String namedQuery;
 private String nativeQuery;
-private Class resultClass;
+private Class? resultClass;
 private int maxMessagesPerPoll;
 private volatile ShutdownRunningTask shutdownRunningTask;
 private volatile int pendingExchanges;
@@ -77,7 +77,7 @@ public class JpaConsumer extends Schedul
 shutdownRunningTask = null;
 pendingExchanges = 0;
 
-Object messagePolled = template.execute(new JpaCallback() {
+Object messagePolled = template.execute(new JpaCallbackObject() {
 public Object doInJpa(EntityManager entityManager) throws 
PersistenceException {
 QueueDataHolder answer = new LinkedListDataHolder();
 
@@ -242,11 +242,11 @@ public class JpaConsumer extends Schedul
 this.query = query;
 }
 
-public Class getResultClass() {
+public Class? getResultClass() {
 return resultClass;
 }
 
-public void setResultClass(Class resultClass) {
+public void setResultClass(Class? resultClass) {
 this.resultClass = resultClass;
 }
 

Modified: 
camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
URL:

svn commit: r1165246 - in /camel/trunk/camel-core/src: main/java/org/apache/camel/builder/ main/java/org/apache/camel/component/log/ main/java/org/apache/camel/util/ test/java/org/apache/camel/process

2011-09-05 Thread cschneider 
Author: cschneider
Date: Mon Sep  5 11:47:15 2011
New Revision: 1165246

URL: http://svn.apache.org/viewvc?rev=1165246view=rev
Log:
CAMEL-4414 Fixes

Modified:

camel/trunk/camel-core/src/main/java/org/apache/camel/builder/DefaultErrorHandlerBuilder.java

camel/trunk/camel-core/src/main/java/org/apache/camel/component/log/LogProducer.java
camel/trunk/camel-core/src/main/java/org/apache/camel/util/CamelLogger.java

camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ThroughPutLoggerTest.java

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/builder/DefaultErrorHandlerBuilder.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/builder/DefaultErrorHandlerBuilder.java?rev=1165246r1=1165245r2=1165246view=diff
==
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/builder/DefaultErrorHandlerBuilder.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/builder/DefaultErrorHandlerBuilder.java
 Mon Sep  5 11:47:15 2011
@@ -16,7 +16,6 @@
  */
 package org.apache.camel.builder;
 
-import static org.apache.camel.builder.PredicateBuilder.toPredicate;
 import org.apache.camel.CamelContext;
 import org.apache.camel.Endpoint;
 import org.apache.camel.Expression;
@@ -30,6 +29,8 @@ import org.apache.camel.spi.RouteContext
 import org.apache.camel.util.CamelLogger;
 import org.slf4j.LoggerFactory;
 
+import static org.apache.camel.builder.PredicateBuilder.toPredicate;
+
 /**
  * The default error handler builder.
  *

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/log/LogProducer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/log/LogProducer.java?rev=1165246r1=1165245r2=1165246view=diff
==
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/log/LogProducer.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/log/LogProducer.java
 Mon Sep  5 11:47:15 2011
@@ -20,7 +20,6 @@ import org.apache.camel.AsyncCallback;
 import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
-import org.apache.camel.RuntimeCamelException;
 import org.apache.camel.impl.DefaultAsyncProducer;
 
 /**
@@ -39,9 +38,10 @@ public class LogProducer extends Default
 try {
 logger.process(exchange);
 } catch (Exception e) {
-throw new RuntimeCamelException(e);
+exchange.setException(e);
+} finally {
+callback.done(true);
 }
-callback.done(true);
 return true;
 }
 }

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/util/CamelLogger.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/util/CamelLogger.java?rev=1165246r1=1165245r2=1165246view=diff
==
--- camel/trunk/camel-core/src/main/java/org/apache/camel/util/CamelLogger.java 
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/util/CamelLogger.java 
Mon Sep  5 11:47:15 2011
@@ -45,7 +45,7 @@ public class CamelLogger {
 
 public CamelLogger(Logger log, LoggingLevel level) {
 this.log = log;
-this.level = level;
+setLevel(level);
 }
 
 public CamelLogger(String logName) {
@@ -70,7 +70,7 @@ public class CamelLogger {
 
 public void log(String message) {
 if (shouldLog(log, level)) {
-log(log, level,message);
+log(log, level, message);
 }
 }
 
@@ -97,6 +97,10 @@ public class CamelLogger {
 }
 
 public void setLevel(LoggingLevel level) {
+if (level == null) {
+throw new IllegalArgumentException(Log level may not be null);
+}
+
 this.level = level;
 }
 
@@ -105,9 +109,6 @@ public class CamelLogger {
 }
 
 public static boolean shouldLog(Logger log, LoggingLevel level) {
-if (level == null) {
-throw new NullPointerException(Log level may not be null);
-}
 return level == LoggingLevel.DEBUG  log.isDebugEnabled() 
 || level == LoggingLevel.ERROR  log.isErrorEnabled()
 || level == LoggingLevel.INFO  log.isInfoEnabled()
@@ -116,9 +117,6 @@ public class CamelLogger {
 }
 
 public static void log(Logger log, LoggingLevel level, String message) {
-if (level == null) {
-throw new NullPointerException(Log level may not be null);
-}
 switch (level) {
 case DEBUG:
 log.debug(message);
@@ -135,13 +133,11 @@ public class CamelLogger {
 case WARN:
 log.warn(message);
 break;
+default:
 }
 }
 
 public static void

svn commit: r1165267 - in /camel/trunk: camel-core/src/main/java/org/apache/camel/component/bean/ camel-core/src/main/java/org/apache/camel/component/file/ components/camel-hazelcast/src/main/java/org

2011-09-05 Thread cschneider 
Author: cschneider
Date: Mon Sep  5 12:56:45 2011
New Revision: 1165267

URL: http://svn.apache.org/viewvc?rev=1165267view=rev
Log:
Avoiding new DefaultExchange where it can be easily created using the endpoint

Modified:

camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/CamelInvocationHandler.java

camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/FileEndpoint.java

camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java

camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java

camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/CamelInvocationHandler.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/CamelInvocationHandler.java?rev=1165267r1=1165266r2=1165267view=diff
==
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/CamelInvocationHandler.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/CamelInvocationHandler.java
 Mon Sep  5 12:56:45 2011
@@ -33,7 +33,6 @@ import org.apache.camel.ExchangePattern;
 import org.apache.camel.InvalidPayloadException;
 import org.apache.camel.Producer;
 import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.impl.DefaultExchange;
 import org.apache.camel.util.ObjectHelper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -65,7 +64,7 @@ public class CamelInvocationHandler impl
 MethodInfo methodInfo = methodInfoCache.getMethodInfo(method);
 
 final ExchangePattern pattern = methodInfo != null ? 
methodInfo.getPattern() : ExchangePattern.InOut;
-final Exchange exchange = new DefaultExchange(endpoint, pattern);
+final Exchange exchange = endpoint.createExchange(pattern);
 exchange.getIn().setBody(invocation);
 
 // is the return type a future

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/FileEndpoint.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/FileEndpoint.java?rev=1165267r1=1165266r2=1165267view=diff
==
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/FileEndpoint.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/FileEndpoint.java
 Mon Sep  5 12:56:45 2011
@@ -22,7 +22,6 @@ import java.io.FileNotFoundException;
 import org.apache.camel.Component;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
-import org.apache.camel.impl.DefaultExchange;
 import org.apache.camel.processor.idempotent.MemoryIdempotentRepository;
 import org.apache.camel.util.FileUtil;
 import org.apache.camel.util.ObjectHelper;
@@ -104,7 +103,7 @@ public class FileEndpoint extends Generi
 }
 
 public Exchange createExchange(GenericFileFile file) {
-Exchange exchange = new DefaultExchange(this);
+Exchange exchange =  createExchange();
 if (file != null) {
 file.bindToExchange(exchange);
 }

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java?rev=1165267r1=1165266r2=1165267view=diff
==
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java
 Mon Sep  5 12:56:45 2011
@@ -27,7 +27,6 @@ import org.apache.camel.BatchConsumer;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.ShutdownRunningTask;
-import org.apache.camel.impl.DefaultExchange;
 import org.apache.camel.impl.ScheduledPollConsumer;
 import org.apache.camel.spi.ShutdownAware;
 import org.apache.camel.util.CastUtils;
@@ -518,7 +517,7 @@ public abstract class GenericFileConsume
 private void evaluateFileExpression() {
 if (fileExpressionResult == null) {
 // create a dummy exchange as Exchange is needed for expression 
evaluation
-Exchange dummy = new DefaultExchange(endpoint.getCamelContext());
+Exchange dummy = endpoint.createExchange();
 fileExpressionResult = endpoint.getFileName().evaluate(dummy, 
String.class);
 }
 }

Modified: 
camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java

svn commit: r1165283 - in /camel/trunk: camel-core/src/main/java/org/apache/camel/component/direct/ camel-core/src/main/java/org/apache/camel/component/seda/ camel-core/src/main/java/org/apache/camel/

2011-09-05 Thread cschneider 
Author: cschneider
Date: Mon Sep  5 13:54:44 2011
New Revision: 1165283

URL: http://svn.apache.org/viewvc?rev=1165283view=rev
Log:
CAMEL-4417 Move AsnycProcessorTypeConverter.convert method to processor while 
keeping the old one for compatibility

Added:

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/AsyncProcessorConverterHelper.java
Modified:

camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectProducer.java

camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java

camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultConsumer.java

camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProducerCache.java

camel/trunk/camel-core/src/main/java/org/apache/camel/impl/converter/AsyncProcessorTypeConverter.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ChoiceProcessor.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DefaultChannel.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DelegateAsyncProcessor.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Enricher.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/InterceptorToAsyncProcessorBridge.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/TryProcessor.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/FailOverLoadBalancer.java

camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java

camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointPolicyTest.java

camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java

camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectConsumer.java

camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectProducer.java

camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaConsumer.java

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectProducer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectProducer.java?rev=1165283r1=1165282r2=1165283view=diff
==
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectProducer.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectProducer.java
 Mon Sep  5 13:54:44 2011
@@ -21,7 +21,7 @@ import org.apache.camel.AsyncProcessor;
 import org.apache.camel.CamelExchangeException;
 import org.apache.camel.Exchange;
 import org.apache.camel.impl.DefaultProducer;
-import org.apache.camel.impl.converter.AsyncProcessorTypeConverter;
+import org.apache.camel.processor.AsyncProcessorConverterHelper;
 import org.apache.camel.util.AsyncProcessorHelper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -57,7 +57,7 @@ public class DirectProducer extends Defa
 callback.done(true);
 return true;
 } else {
-AsyncProcessor processor = 
AsyncProcessorTypeConverter.convert(endpoint.getConsumer().getProcessor());
+AsyncProcessor processor = 
AsyncProcessorConverterHelper.convert(endpoint.getConsumer().getProcessor());
 return AsyncProcessorHelper.process(processor, exchange, callback);
 }
 }

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java?rev=1165283r1=1165282r2=1165283view=diff
==
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
 Mon Sep  5 13:54:44 2011
@@ -31,7 +31,7 @@ import org.apache.camel.Processor;
 import org.apache.camel.ShutdownRunningTask;
 import org.apache.camel.SuspendableService;
 import org.apache.camel.impl.LoggingExceptionHandler;
-import org.apache.camel.impl.converter.AsyncProcessorTypeConverter;
+import org.apache.camel.processor.AsyncProcessorConverterHelper;
 import