[CONF] Apache Camel > Articles
Articles Page edited by Jean-Baptiste Onofré Changes (2) ... * [Apache Camel and SOAP|http://blog.jayway.com/2011/07/14/apache_camel_and_soap/] by Jan Kronquist showing an integration scenario using freely available SOAP web services to create a service that can return the weather at an airport. * [Using Apache Camel to monitor SNMP devices|http://marcelojabali.blogspot.com/2011/07/using-apache-camel-to-monitor-snmp.html] by Marcelo Jabali showing how to monitor SNMP devices using Apache Camel in a few lines of code * [Website mashup with Apache Camel|http://blog.nanthrax.net/2011/07/website-mashup-with-apache-camel/] by Jean Baptiste Jean-Baptiste Onofré shows how to extract data from HTML web sites using Apache Camel * [Using NetBeans 7.0 to create a new Apache Camel project|http://coders-unite.blogspot.com/2011/07/using-netbeans-70-to-create-new-project.html] shows how to start from scratch in NetBeans to setup a Apache Camel project (tutorial style with screenshots) * [Using NetBeans 7.0 to create a new Apache Camel project without Spring dependency|http://coders-unite.blogspot.com/2011/07/using-netbeans-70-to-create-apache.html] shows how to start from scratch in NetBeans to setup a Apache Camel project (tutorial style with screenshots) without any Spring dependency * [Error handling in Camel for JMS consumer endpoint|http://tmielke.blogspot.com/2011/07/error-handling-in-camel-for-jms.html] by Torsten Mielke explains some of the options you have for error handling when using [JMS]. * [Use remote EJB in Camel routes|http://blog.nanthrax.net/2011/08/use-a-remote-ejb-in-camel-routes/] by Jean-Baptiste Onofré explains how to use an EJB hosted in a remote J2EE application server in a Camel route hosted in Apache ServiceMix. ... 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. JB
svn commit: r1155338 - in /camel/branches/camel-2.8.x: ./ examples/camel-example-cxf-proxy/src/main/resources/META-INF/spring/ examples/camel-example-cxf-tomcat/src/main/resources/ examples/camel-exam
Author: ningjiang Date: Tue Aug 9 12:44:22 2011 New Revision: 1155338 URL: http://svn.apache.org/viewvc?rev=1155338&view=rev Log: CAMEL-4317 Merged revisions 1155230 via svnmerge from https://svn.apache.org/repos/asf/camel/trunk r1155230 | ningjiang | 2011-08-09 14:55:40 +0800 (Tue, 09 Aug 2011) | 1 line Clean up the camel context file of the example after upgrading to CXF 2.4.x Modified: camel/branches/camel-2.8.x/ (props changed) camel/branches/camel-2.8.x/examples/camel-example-cxf-proxy/src/main/resources/META-INF/spring/camel-config.xml camel/branches/camel-2.8.x/examples/camel-example-cxf-tomcat/src/main/resources/camel-config.xml camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring/CamelCXFProviderRouteConfig.xml camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring/CamelTransportSpringConfig.xml camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring/CxfRouteCamelContext.xml camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring/JAXRSCamelContext.xml Propchange: camel/branches/camel-2.8.x/ -- svn:mergeinfo = /camel/trunk:1155230 Propchange: camel/branches/camel-2.8.x/ -- --- svnmerge-integrated (original) +++ svnmerge-integrated Tue Aug 9 12:44:22 2011 @@ -1 +1 @@ -/camel/trunk:1-1148091,1149488,1153146,1153323,1155229,1155231,1155233-1155276,1155278-1155291,1155293-1155318,1155320-1155327 +/camel/trunk:1-1148091,1149488,1153146,1153323,1155229-1155231,1155233-1155276,1155278-1155291,1155293-1155318,1155320-1155327 Modified: camel/branches/camel-2.8.x/examples/camel-example-cxf-proxy/src/main/resources/META-INF/spring/camel-config.xml URL: http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/examples/camel-example-cxf-proxy/src/main/resources/META-INF/spring/camel-config.xml?rev=1155338&r1=1155337&r2=1155338&view=diff == --- camel/branches/camel-2.8.x/examples/camel-example-cxf-proxy/src/main/resources/META-INF/spring/camel-config.xml (original) +++ camel/branches/camel-2.8.x/examples/camel-example-cxf-proxy/src/main/resources/META-INF/spring/camel-config.xml Tue Aug 9 12:44:22 2011 @@ -26,11 +26,8 @@ http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd http://camel.apache.org/schema/cxf http://camel.apache.org/schema/cxf/camel-cxf.xsd";> - - - - + @@ -70,4 +67,4 @@ - \ No newline at end of file + Modified: camel/branches/camel-2.8.x/examples/camel-example-cxf-tomcat/src/main/resources/camel-config.xml URL: http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/examples/camel-example-cxf-tomcat/src/main/resources/camel-config.xml?rev=1155338&r1=1155337&r2=1155338&view=diff == --- camel/branches/camel-2.8.x/examples/camel-example-cxf-tomcat/src/main/resources/camel-config.xml (original) +++ camel/branches/camel-2.8.x/examples/camel-example-cxf-tomcat/src/main/resources/camel-config.xml Tue Aug 9 12:44:22 2011 @@ -26,11 +26,7 @@ http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd http://camel.apache.org/schema/cxf http://camel.apache.org/schema/cxf/camel-cxf.xsd";> - - - - @@ -40,4 +36,4 @@ - \ No newline at end of file + Modified: camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring/CamelCXFProviderRouteConfig.xml URL: http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring/CamelCXFProviderRouteConfig.xml?rev=1155338&r1=1155337&r2=1155338&view=diff == --- camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring/CamelCXFProviderRouteConfig.xml (original) +++ camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring/CamelCXFProviderRouteConfig.xml Tue Aug 9 12:44:22 2011 @@ -32,8 +32,6 @@ --> - - Modified: camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring/CamelTransportSpringConfig.xml URL: http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring/CamelTransportSpringConfig.xml?rev=1155338&r1=1155337&r2=1155338&view=diff == --- camel/branches/camel-2.8.x/examples/camel-example-cxf/src/main/resources/META-INF/spring
svn commit: r1155331 - in /camel/branches/camel-2.8.x: ./ components/camel-cxf-transport/src/main/resources/META-INF/services/org/apache/camel/component/ components/camel-cxf/src/main/java/org/apache/
Author: ningjiang Date: Tue Aug 9 12:20:14 2011 New Revision: 1155331 URL: http://svn.apache.org/viewvc?rev=1155331&view=rev Log: Merged revisions 1155231,1155276,1155327 via svnmerge from https://svn.apache.org/repos/asf/camel/trunk r1155231 | ningjiang | 2011-08-09 14:56:01 +0800 (Tue, 09 Aug 2011) | 1 line CAMEL-4299 Fixed the NPE issue of camel-cxfbean r1155276 | ningjiang | 2011-08-09 17:20:44 +0800 (Tue, 09 Aug 2011) | 1 line CAMEL-4299 Fixed the cxfbean component auto load issue r1155327 | ningjiang | 2011-08-09 20:07:31 +0800 (Tue, 09 Aug 2011) | 1 line CAMEL-4299 Fixed the CS errors of CxfBeanEndpoint Removed: camel/branches/camel-2.8.x/components/camel-cxf-transport/src/main/resources/META-INF/services/org/apache/camel/component/cxfbean Modified: camel/branches/camel-2.8.x/ (props changed) camel/branches/camel-2.8.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanComponent.java camel/branches/camel-2.8.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java Propchange: camel/branches/camel-2.8.x/ -- --- svnmerge-integrated (original) +++ svnmerge-integrated Tue Aug 9 12:20:14 2011 @@ -1 +1 @@ -/camel/trunk:1-1148091,1149488,1153146,1153323,1155229 +/camel/trunk:1-1148091,1149488,1153146,1153323,1155229,1155231,1155233-1155276,1155278-1155291,1155293-1155318,1155320-1155327 Modified: camel/branches/camel-2.8.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanComponent.java URL: http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanComponent.java?rev=1155331&r1=1155330&r2=1155331&view=diff == --- camel/branches/camel-2.8.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanComponent.java (original) +++ camel/branches/camel-2.8.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanComponent.java Tue Aug 9 12:20:14 2011 @@ -64,23 +64,7 @@ public class CxfBeanComponent extends He // we invoke setProperties ourselves so the bus is set for CxfBeanEndpoint.init() return false; } - -@Override -protected void doStart() throws Exception { -super.doStart(); -for (CxfBeanEndpoint endpoint : endpoints.values()) { -endpoint.start(); -} -} -@Override -protected void doStop() throws Exception { -for (CxfBeanEndpoint endpoint : endpoints.values()) { -endpoint.stop(); -} -super.doStop(); -} - public CxfBeanEndpoint getEndpoint(String endpointUri) { return endpoints.get(endpointUri); } Modified: camel/branches/camel-2.8.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java URL: http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java?rev=1155331&r1=1155330&r2=1155331&view=diff == --- camel/branches/camel-2.8.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java (original) +++ camel/branches/camel-2.8.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java Tue Aug 9 12:20:14 2011 @@ -37,12 +37,12 @@ import org.apache.cxf.jaxws.JaxWsServerF import org.apache.cxf.transport.ConduitInitiatorManager; import org.apache.cxf.transport.DestinationFactoryManager; + /** * CXF Bean Endpoint is a {@link ProcessorEndpoint} which associated with * a {@link CxfBeanDestination}. It delegates the processing of Camel * Exchanges to the associated CxfBeanDestination. * - * @version */ public class CxfBeanEndpoint extends ProcessorEndpoint implements HeaderFilterStrategyAware { private static final String URI_PREFIX = "cxfbean"; @@ -82,7 +82,14 @@ public class CxfBeanEndpoint extends Pro } if (bus == null) { -bus = BusFactory.newInstance().createBus(); +ClassLoader oldCL = Thread.currentThread().getContextClassLoader(); +try { +// Using the class loader of BusFactory to load the Bus + Thread.currentThread().setContextClassLoader(BusFactory.class.getClassLoader()); +bus = BusFactory.newInstance().createBus(); +} finally { +Thread.currentThread().setContextClassLoader(oldCL); +} } if (isSetDefaultBus) {
svn commit: r1155327 - /camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java
Author: ningjiang Date: Tue Aug 9 12:07:31 2011 New Revision: 1155327 URL: http://svn.apache.org/viewvc?rev=1155327&view=rev Log: CAMEL-4299 Fixed the CS errors of CxfBeanEndpoint Modified: camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java Modified: camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java?rev=1155327&r1=1155326&r2=1155327&view=diff == --- camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java (original) +++ camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanEndpoint.java Tue Aug 9 12:07:31 2011 @@ -34,21 +34,17 @@ import org.apache.cxf.endpoint.Server; import org.apache.cxf.feature.LoggingFeature; import org.apache.cxf.jaxrs.JAXRSServerFactoryBean; import org.apache.cxf.jaxws.JaxWsServerFactoryBean; -import org.apache.cxf.phase.PhaseManager; import org.apache.cxf.transport.ConduitInitiatorManager; import org.apache.cxf.transport.DestinationFactoryManager; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; + /** * CXF Bean Endpoint is a {@link ProcessorEndpoint} which associated with * a {@link CxfBeanDestination}. It delegates the processing of Camel * Exchanges to the associated CxfBeanDestination. * - * @version */ public class CxfBeanEndpoint extends ProcessorEndpoint implements HeaderFilterStrategyAware { - private static final Logger LOG = LoggerFactory.getLogger(CxfBeanEndpoint.class); private static final String URI_PREFIX = "cxfbean"; private Server server; private Bus bus;
svn commit: r1155322 - in /camel/branches/camel-2.8.x: ./ components/camel-cxf/pom.xml
Author: ningjiang Date: Tue Aug 9 11:51:39 2011 New Revision: 1155322 URL: http://svn.apache.org/viewvc?rev=1155322&view=rev Log: Merged revisions 1155229 via svnmerge from https://svn.apache.org/repos/asf/camel/trunk r1155229 | ningjiang | 2011-08-09 14:55:10 +0800 (Tue, 09 Aug 2011) | 1 line CAMEL-4316 camel-cxf bundle should not ship the camel-cxf-transport packages Modified: camel/branches/camel-2.8.x/ (props changed) camel/branches/camel-2.8.x/components/camel-cxf/pom.xml Propchange: camel/branches/camel-2.8.x/ -- --- svnmerge-integrated (original) +++ svnmerge-integrated Tue Aug 9 11:51:39 2011 @@ -1 +1 @@ -/camel/trunk:1-1148091,1149488,1153146,1153323 +/camel/trunk:1-1148091,1149488,1153146,1153323,1155229 Modified: camel/branches/camel-2.8.x/components/camel-cxf/pom.xml URL: http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/components/camel-cxf/pom.xml?rev=1155322&r1=1155321&r2=1155322&view=diff == --- camel/branches/camel-2.8.x/components/camel-cxf/pom.xml (original) +++ camel/branches/camel-2.8.x/components/camel-cxf/pom.xml Tue Aug 9 11:51:39 2011 @@ -33,8 +33,15 @@ - !org.apache.camel.component.cxf.*, - !META-INF.cxf.camel, + !org.apache.camel.component.cxf, + !org.apache.camel.component.cxf.blueprint, + !org.apache.camel.component.cxf.converter, + !org.apache.camel.component.cxf.cxfbean, + !org.apache.camel.component.cxf.feature, + !org.apache.camel.component.cxf.interceptors, + !org.apache.camel.component.cxf.jaxrs, + !org.apache.camel.component.cxf.spring, + !org.apache.camel.component.cxf.util, javax.activation*;version="[0.0,2)", javax.annotation*;version="[0.0,2)", javax.jws*;version="[0.0,3)", @@ -56,7 +63,15 @@ - org.apache.camel.component.cxf.*;${camel.osgi.version};-split-package:=merge-first + org.apache.camel.component.cxf;${camel.osgi.version}, + org.apache.camel.component.cxf.blueprint;${camel.osgi.version}, + org.apache.camel.component.cxf.converter;${camel.osgi.version}, + org.apache.camel.component.cxf.cxfbean;${camel.osgi.version}, + org.apache.camel.component.cxf.feature;${camel.osgi.version}, + org.apache.camel.component.cxf.interceptors;${camel.osgi.version}, + org.apache.camel.component.cxf.jaxrs;${camel.osgi.version}, + org.apache.camel.component.cxf.spring;${camel.osgi.version}, + org.apache.camel.component.cxf.util;${camel.osgi.version} true
svn commit: r1155319 - in /camel/trunk: parent/pom.xml platforms/karaf/features/pom.xml platforms/karaf/features/src/main/resources/features.xml
Author: jbonofre Date: Tue Aug 9 11:44:07 2011 New Revision: 1155319 URL: http://svn.apache.org/viewvc?rev=1155319&view=rev Log: [CAMEL-4313] Upgrade to XStream 1.4 Modified: camel/trunk/parent/pom.xml camel/trunk/platforms/karaf/features/pom.xml camel/trunk/platforms/karaf/features/src/main/resources/features.xml Modified: camel/trunk/parent/pom.xml URL: http://svn.apache.org/viewvc/camel/trunk/parent/pom.xml?rev=1155319&r1=1155318&r2=1155319&view=diff == --- camel/trunk/parent/pom.xml (original) +++ camel/trunk/parent/pom.xml Tue Aug 9 11:44:07 2011 @@ -153,7 +153,7 @@ 1.7 4.1.1 3.5 -1.3.1 +1.4 1.4.5 2.9.1 2.7.1 Modified: camel/trunk/platforms/karaf/features/pom.xml URL: http://svn.apache.org/viewvc/camel/trunk/platforms/karaf/features/pom.xml?rev=1155319&r1=1155318&r2=1155319&view=diff == --- camel/trunk/platforms/karaf/features/pom.xml (original) +++ camel/trunk/platforms/karaf/features/pom.xml Tue Aug 9 11:44:07 2011 @@ -100,6 +100,7 @@ 2.1.2_1 4.7_1 2.1.0_1 + 2.3.0_1-SNAPSHOT 3.0.3_1 2.0.8_4 1.1.7_3 @@ -137,7 +138,7 @@ 1.4.5_1 1.2_3 1.1.4c_3 - 1.3_3 + 1.4_1-SNAPSHOT 0.9.4_3 ${woodstox-version} 3.1.1 Modified: camel/trunk/platforms/karaf/features/src/main/resources/features.xml URL: http://svn.apache.org/viewvc/camel/trunk/platforms/karaf/features/src/main/resources/features.xml?rev=1155319&r1=1155318&r2=1155319&view=diff == --- camel/trunk/platforms/karaf/features/src/main/resources/features.xml (original) +++ camel/trunk/platforms/karaf/features/src/main/resources/features.xml Tue Aug 9 11:44:07 2011 @@ -704,6 +704,7 @@ mvn:org.apache.servicemix.bundles/org.apache.servicemix.bundles.joda-time/${jodatime-bundle-version} mvn:org.apache.servicemix.bundles/org.apache.servicemix.bundles.jdom/${jdom-bundle-version} mvn:org.apache.servicemix.bundles/org.apache.servicemix.bundles.dom4j/${dom4j-bundle-version} +mvn:org.apache.servicemix.bundles/org.apache.servicemix.bundles.kxml2/${kxml2-bundle-version} mvn:org.apache.servicemix.bundles/org.apache.servicemix.bundles.xstream/${xstream-bundle-version} mvn:org.apache.camel/camel-xstream/${pom.version}
[CONF] Apache Camel > Camel 2.9.0 Release
Camel 2.9.0 Release Page edited by Claus Ibsen Changes (2) ... * Fixed issue with [Bindy] unmarshalling in key value mode when using @OneToMany bindings, may cause inconsistency for multiple threaded unmarshalling * Removed dependency on Spring JARs in the following components: [Validation], [XSLT], [Velocity], [Freemarker], [Flatpack], [StringTemplate], [iBatis], [Jing], [Msv], [XQuery], and [Test] * Using [pollEnrich|Content Enricher] with a file/ftp endpoint will now only poll on demand, beforehand the polling could be started when the route started. h3. New [Enterprise Integration Patterns] ... * The {{org.apache.camel.component.ResourceBasedComponent}} class from {{camel-spring}} has been deleted. Use {{DefaultComponent}} instead. * The {{org.apache.camel.component.ResourceBasedEndpoint}} class from {{camel-spring}} has been moved to {{camel-core}}, and its dependency on Spring JARs has been removed. Use the new APIs on {{ResourceBasedEndpoint}} to load resources. * Changed the method {{beforePoll}} slightly in the {{org.apache.camel.PollingConsumerPollingStrategy}} class. h2. Known Issues ... Full Content Camel 2.9.0 release (currently in progress) New and Noteworthy Welcome to the 2.9.0 release which approx XXX issues resolved (new features, improvements and bug fixes such as...) Reduced the API in thread pool management for Camel component developers. See Threading Model for more details. Fixed issue with Properties component may cache duplicates and thus take up unnecessary memory in the cache Fixed issue with Tracer out exchanges when using Asynchronous Processing by the Asynchronous Routing Engine Fixed issue with Components or Endpoints not being registered in JMX when using POJO Producing, POJO Consuming or other Camel bean annotations. The Bean component now supports specifying parameter values to use directly in the method syntax. See more details at Bean Binding. For example to invoke a bean with body as first parameter, and a boolean true as second you can now do: .to("bean:myBean?method=myMethod(body, true)") Fixed issue which could cause DefaultUnitOfWork to throw a java.util.EmptyStackException under heavy load Improved labels of all model definitions which appear in Tracer output Fixed issue with MDC logging not remembering old values, for example when using a ProducerTemplate from within routes to send new messages. Reduced dependency for camel-core to not require commons-management JAR anymore Added blueprint support of cxfrs endpoint. Camel no longer depend on using Spring JARs for having Camel enlisted in JMX. Introduced a set of Camel JMX annotations in org.apache.camel.management that can be used to easily instrument Camel Components, EIPs, custom Processors, Beans etc. for being managed in JMX. Using the Spring JMX annotations is still supported (you would need camel-spring on the classpath). Fixed issue when invoking a Bean and that bean is using a @Bean in its method signature, causing the @Bean to not invoke its intended method Updated the Aggregator2 to allow for manually completing all exchange groups by sending a message containing the header Exchange.AGGREGATION_COMPLETE_ALL_GROUPS set to true. Fixed issue with Bindy unmarshalling in key value mode when using @OneToMany bindings, may cause inconsistency for multiple threaded unmarshalling Removed dependency on Spring JARs in the following components: Validation, XSLT, Velocity, FreeMarker, Flatpack, StringTemplate, iBATIS, Jing, MSV, XQuery, and Test Using pollEnrich with a file/ftp endpoint will now only poll on demand, beforehand the polling could be started when the route started. New Enterprise Integration Patterns New Components DSL Changes New Annotations New Data Formats New Languages New Examples New Tutorials API breaking The class ExecutorServiceStrategy has been renamed to ExecutorServiceManager and have a reduced API. Spring config stays the same but java api for ThreadPoolProfile and ExecutorService creation has changed. See Threading Model The org.apache.camel.component.ResourceBasedComponent class from camel-spring has been deleted. Use DefaultComponent instead. The org.apache.camel.component.ResourceBasedEndpoint class from camel-spring has been moved to camel-core, and its dependency on Spring JARs has been removed. Use the new APIs on ResourceBasedEndpoint to load resources. Changed the method beforePoll slightly in the org.apache.camel.PollingConsumerPollingStrategy class. Known Issues The Tracer may not output all details for some situations such as when using onCompletion or intercept etc. The project cannot fully build the site usi
svn commit: r1155292 - in /camel/trunk/camel-core/src: main/java/org/apache/camel/ main/java/org/apache/camel/impl/ test/java/org/apache/camel/component/file/
Author: davsclaus Date: Tue Aug 9 09:58:25 2011 New Revision: 1155292 URL: http://svn.apache.org/viewvc?rev=1155292&view=rev Log: CAMEL-4318: Scheduled poll consumer from pollEnrich should not be polling when route starts, but on demand Added: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FilePollEnrichNoWaitTest.java - copied, changed from r1155236, camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FilePollEnrichTest.java Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/PollingConsumerPollingStrategy.java camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FilePollEnrichTest.java Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/PollingConsumerPollingStrategy.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/PollingConsumerPollingStrategy.java?rev=1155292&r1=1155291&r2=1155292&view=diff == --- camel/trunk/camel-core/src/main/java/org/apache/camel/PollingConsumerPollingStrategy.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/PollingConsumerPollingStrategy.java Tue Aug 9 09:58:25 2011 @@ -36,9 +36,12 @@ public interface PollingConsumerPollingS /** * Callback invoked before the poll. * + * @param timeout the timeout * @throws Exception can be thrown if error occurred + * @return timeout to be used, this allows returning a higher timeout value + * to ensure at least one poll is being performed */ -void beforePoll() throws Exception; +long beforePoll(long timeout) throws Exception; /** * Callback invoked after the poll. Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java?rev=1155292&r1=1155291&r2=1155292&view=diff == --- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java Tue Aug 9 09:58:25 2011 @@ -65,7 +65,8 @@ public class EventDrivenPollingConsumer while (isRunAllowed()) { try { -beforePoll(); +beforePoll(0); +// take will block waiting for message return queue.take(); } catch (InterruptedException e) { handleInterruptedException(e); @@ -83,13 +84,9 @@ public class EventDrivenPollingConsumer throw new RejectedExecutionException(this + " is not started, but in state: " + getStatus().name()); } -// if the queue is empty and there is no wait then return null -if (timeout == 0 && queue.isEmpty()) { -return null; -} - try { -beforePoll(); +// use the timeout value returned from beforePoll +timeout = beforePoll(timeout); return queue.poll(timeout, TimeUnit.MILLISECONDS); } catch (InterruptedException e) { handleInterruptedException(e); @@ -115,15 +112,16 @@ public class EventDrivenPollingConsumer getInterruptedExceptionHandler().handleException(e); } -protected void beforePoll() { +protected long beforePoll(long timeout) { if (consumer instanceof PollingConsumerPollingStrategy) { PollingConsumerPollingStrategy strategy = (PollingConsumerPollingStrategy) consumer; try { -strategy.beforePoll(); +timeout = strategy.beforePoll(timeout); } catch (Exception e) { LOG.debug("Error occurred before polling " + consumer + ". This exception will be ignored.", e); } } +return timeout; } protected void afterPoll() { Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java?rev=1155292&r1=1155291&r2=1155292&view=diff == --- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java Tue Aug 9 09:58:25 2011 @@ -276,20 +276,28 @@ public abstract class ScheduledPollConsu @Override public void onInit() throws Exception { -// sta
svn commit: r1155277 - in /camel/trunk/tests/camel-itest-osgi/src/test: java/org/apache/camel/itest/osgi/cxf/blueprint/ resources/ resources/org/apache/camel/itest/osgi/cxf/ resources/org/apache/camel
Author: ningjiang Date: Tue Aug 9 09:21:28 2011 New Revision: 1155277 URL: http://svn.apache.org/viewvc?rev=1155277&view=rev Log: CAMEL-4315 Added OSGi tests for setting endpointName attribute of cxfEndpoint Modified: camel/trunk/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/cxf/blueprint/CxfBlueprintRouterTest.java camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/CxfBeanRouter.xml camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/blueprint/CxfBlueprintRouter.xml camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/camel-config.xml camel/trunk/tests/camel-itest-osgi/src/test/resources/report_incident.wsdl Modified: camel/trunk/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/cxf/blueprint/CxfBlueprintRouterTest.java URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/cxf/blueprint/CxfBlueprintRouterTest.java?rev=1155277&r1=1155276&r2=1155277&view=diff == --- camel/trunk/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/cxf/blueprint/CxfBlueprintRouterTest.java (original) +++ camel/trunk/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/cxf/blueprint/CxfBlueprintRouterTest.java Tue Aug 9 09:21:28 2011 @@ -42,7 +42,7 @@ import static org.ops4j.pax.swissbox.tin import static org.ops4j.pax.swissbox.tinybundles.core.TinyBundles.withBnd; @RunWith(JUnit4TestRunner.class) -@Ignore("This test will be failed with CXF 2.4.1, we need to use CXF 2.4.2") +//@Ignore("This test will be failed with CXF 2.4.1, we need to use CXF 2.4.2") public class CxfBlueprintRouterTest extends OSGiBlueprintTestSupport { private static Server server; @@ -108,6 +108,7 @@ public class CxfBlueprintRouterTest exte bundle(newBundle() .add("OSGI-INF/blueprint/test.xml", CxfBlueprintRouterTest.class.getResource("CxfBlueprintRouter.xml")) +.add("WSDL/report_incident.wsdl", CxfBlueprintRouterTest.class.getResource("/report_incident.wsdl")) .add(org.apache.camel.example.reportincident.InputReportIncident.class) .add(org.apache.camel.example.reportincident.OutputReportIncident.class) .add(org.apache.camel.example.reportincident.ReportIncidentEndpoint.class) Modified: camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/CxfBeanRouter.xml URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/CxfBeanRouter.xml?rev=1155277&r1=1155276&r2=1155277&view=diff == --- camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/CxfBeanRouter.xml (original) +++ camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/CxfBeanRouter.xml Tue Aug 9 09:21:28 2011 @@ -25,8 +25,6 @@ - - Modified: camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/blueprint/CxfBlueprintRouter.xml URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/blueprint/CxfBlueprintRouter.xml?rev=1155277&r1=1155276&r2=1155277&view=diff == --- camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/blueprint/CxfBlueprintRouter.xml (original) +++ camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/blueprint/CxfBlueprintRouter.xml Tue Aug 9 09:21:28 2011 @@ -32,6 +32,10 @@ serviceClass="org.apache.camel.example.reportincident.ReportIncidentEndpoint"/> http://localhost:9002/cxf"; +wsdlURL="WSDL/report_incident.wsdl" +endpointName="s:ReportIncidentPort" +serviceName="s:ReportIncidentEndpointService" + xmlns:s="http://reportincident.example.camel.apache.org"; serviceClass="org.apache.camel.example.reportincident.ReportIncidentEndpoint"/> http://camel.apache.org/schema/blueprint";> Modified: camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/camel-config.xml URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/camel-config.xml?rev=1155277&r1=1155276&r2=1155277&view=diff == --- camel/trunk/tests/camel-itest-osgi/src/test/resources/org/apache/camel/itest/osgi/cxf/camel-config.xml (
svn commit: r1155276 - in /camel/trunk/components: camel-cxf-transport/src/main/resources/META-INF/services/org/apache/camel/component/cxfbean camel-cxf/src/main/java/org/apache/camel/component/cxf/cx
Author: ningjiang Date: Tue Aug 9 09:20:44 2011 New Revision: 1155276 URL: http://svn.apache.org/viewvc?rev=1155276&view=rev Log: CAMEL-4299 Fixed the cxfbean component auto load issue Removed: camel/trunk/components/camel-cxf-transport/src/main/resources/META-INF/services/org/apache/camel/component/cxfbean Modified: camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanComponent.java Modified: camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanComponent.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanComponent.java?rev=1155276&r1=1155275&r2=1155276&view=diff == --- camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanComponent.java (original) +++ camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/cxfbean/CxfBeanComponent.java Tue Aug 9 09:20:44 2011 @@ -64,23 +64,7 @@ public class CxfBeanComponent extends He // we invoke setProperties ourselves so the bus is set for CxfBeanEndpoint.init() return false; } - -@Override -protected void doStart() throws Exception { -super.doStart(); -for (CxfBeanEndpoint endpoint : endpoints.values()) { -endpoint.start(); -} -} -@Override -protected void doStop() throws Exception { -for (CxfBeanEndpoint endpoint : endpoints.values()) { -endpoint.stop(); -} -super.doStop(); -} - public CxfBeanEndpoint getEndpoint(String endpointUri) { return endpoints.get(endpointUri); }