How to use camel-jpa in fuse esb (4.1.0.0)

[muellerc]

Hey folks,

I want to use the camel-jpa component as a poller component (consume entries from the database). I create the JPA Entity class, the RouteBuilder and all the things. My RouteBuilder looks like:

public void configure() throws Exception {

   from("jpa:org.sample.Event?persistenceUnit=event")

   .to("jbi:endpoint:http://sample.org/EventFilter/endpoint");

}

My bundle-context.xml looks like:

Exception in thread "SpringOsgiExtenderThread-70" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'camelContext:beanPostProcessor': Cannot resolve reference to bean 'camelContext' while setting bean property 'camelContext'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'camelContext': Invocation of init method failed; nested exception is org.springframework.beans.factory.CannotLoadBeanClassException: Cannot find class for bean with name 'transactionTemplate' defined in URL bundle://174.0:0/META-INF/spring/bundle-context.xml; nested exception is java.lang.ClassNotFoundException: org.springframework.transaction.support.TransactionTemplate not found from bundle

        at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveReference(BeanDefinitionValueResolver.java:275)

        at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveValueIfNecessary(BeanDefinitionValueResolver.java:104)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyPropertyValues(AbstractAutowireCapableBeanFactory.java:1245)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1010)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:472)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory$1.run(AbstractAutowireCapableBeanFactory.java:409)

        at java.security.AccessController.doPrivileged(Native Method)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:380)

        at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:264)

        at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)

        at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:261)

        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:185)

        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:164)

        at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:880)

        at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.registerBeanPostProcessors(AbstractDelegatedExecutionApplicationContext.java:547)

        at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.registerBeanPostProcessors(AbstractDelegatedExecutionApplicationContext.java:482)

        at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$4.run(AbstractDelegatedExecutionApplicationContext.java:324)

        at org.springframework.osgi.util.internal.PrivilegedUtils.executeWithCustomTCCL(PrivilegedUtils.java:85)

        at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.completeRefresh(AbstractDelegatedExecutionApplicationContext.java:308)

        at org.springframework.osgi.extender.internal.dependencies.startup.DependencyWaiterApplicationContextExecutor$CompleteRefreshTask.run(DependencyWaiterApplicationContextExecutor.java:138)

        at java.lang.Thread.run(Thread.java:613)

Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'camelContext': Invocation of init method failed; nested exception is org.springframework.beans.factory.CannotLoadBeanClassException: Cannot find class for bean with name 'transactionTemplate' defined in URL bundle://174.0:0/META-INF/spring/bundle-context.xml; nested exception is java.lang.ClassNotFoundException: org.springframework.transaction.support.TransactionTemplate not found from bundle

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1338)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:473)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory$1.run(AbstractAutowireCapableBeanFactory.java:409)

        at java.security.AccessController.doPrivileged(Native Method)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:380)

        at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:264)

        at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)

        at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:261)

        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:185)

        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:164)

        at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveReference(BeanDefinitionValueResolver.java:269)

        ... 20 more

Caused by: org.springframework.beans.factory.CannotLoadBeanClassException: Cannot find class for bean with name 'transactionTemplate' defined in URL bundle://174.0:0/META-INF/spring/bundle-context.xml; nested exception is java.lang.ClassNotFoundException: org.springframework.transaction.support.TransactionTemplate not found from bundle

But the bundle is active

smx@root:osgi> list

...

Spring Transaction (2.5.6)

...

and I have configured the dependency in my pom.xml as follows

Any idee what is wrong?

Thank you for your help,

Christian

[joe.luo]

I have not done the camel-jpa component in ESB 4 myself. But I know that you will need "osgi" namespace for "camelContext", i.e.

<osgi:camelContext xmlns="http://activemq.apache.org/camel/schema/spring">

...

Here attached is a sample camel context xml file from "examples\camel-osgi\src\main\resources\META-INF\spring" directory and you might find it helpful.

[davsclaus]

Hi

Yeah you need a million .jars on the classpath and installed as OSGi bundles.

I do not know if there is a SMX JPA feature you can use to install the required .jars in a single cmd line.

Here is the mvn dependency:list from my laptop, for the camel-jpa component itself. We use openjpa to test it within Camel itself.

Maybe it can help you find the needed .jars:

The following files have been resolved:

    ant:ant:jar:1.6.5:test

    aopalliance:aopalliance:jar:1.0:compile

    com.sun.xml.bind:jaxb-impl:jar:2.1.6:compile

    commons-collections:commons-collections:jar:3.2.1:test

    commons-dbcp:commons-dbcp:jar:1.2.2:test

    commons-lang:commons-lang:jar:2.1:test

    commons-logging:commons-logging:jar:1.1.1:compile

    commons-logging:commons-logging-api:jar:1.1:compile

    commons-pool:commons-pool:jar:1.4:test

    hsqldb:hsqldb:jar:1.8.0.7:test

    javax.activation:activation:jar:1.1:compile

    javax.xml.bind:jaxb-api:jar:2.1:compile

    javax.xml.stream:stax-api:jar:1.0-2:compile

    junit:junit:jar:3.8.2:test

    log4j:log4j:jar:1.2.14:test

    net.sourceforge.serp:serp:jar:1.13.1:test

    org.apache.camel:camel-core:jar:1.6.1-SNAPSHOT:compile

    org.apache.camel:camel-core:test-jar:tests:1.6.1-SNAPSHOT:test

    org.apache.camel:camel-spring:jar:1.6.1-SNAPSHOT:compile

    org.apache.derby:derby:jar:10.4.2.0:test

    org.apache.geronimo.specs:geronimo-jms_1.1_spec:jar:1.1.1:test

    org.apache.geronimo.specs:geronimo-jpa_3.0_spec:jar:1.1.1:compile

    org.apache.geronimo.specs:geronimo-jta_1.1_spec:jar:1.1.1:test

    org.apache.openjpa:openjpa-jdbc:jar:1.2.0:test

    org.apache.openjpa:openjpa-kernel:jar:1.2.0:test

    org.apache.openjpa:openjpa-lib:jar:1.2.0:test

    org.apache.openjpa:openjpa-persistence:jar:1.2.0:test

    org.apache.openjpa:openjpa-persistence-jdbc:jar:1.2.0:test

    org.springframework:spring-aop:jar:2.5.6:compile

    org.springframework:spring-beans:jar:2.5.6:compile

    org.springframework:spring-context:jar:2.5.6:compile

    org.springframework:spring-core:jar:2.5.6:compile

    org.springframework:spring-jdbc:jar:2.5.6:compile

    org.springframework:spring-orm:jar:2.5.6:compile

    org.springframework:spring-tx:jar:2.5.6:compile

    postgresql:postgresql:jar:8.1-407.jdbc3:test

[davsclaus]

About the OSGi namespace. I kinda recall that it is not needed as SMX is clever to understand this.

Might need to check with G. Nodet or William Jiang.

[muellerc]

Hi all,

I found the feature 'camel-jpa'. After I installed this feature

smx@root:features> install camel-jpa

the following additional OSGI bundles are installed in FUSE ESB:

geronimo-activation_1.1_spec (1.0.2)

geronimo-jaxws_2.1_spec (1.0)

geronimo-el_1.0_spec (1.0.1)

spring-web (2.5.5)

Spring JDBC (2.5.6)

Commons Lang (2.4)

geronimo-jpa_3.0_spec (1.1.1)

Apache ServiceMix Bundles: openjpa-persistence-1.2.0 (1.2.0.fuse)

Apache ServiceMix Bundles: commons-dbcp-1.2.2 (1.2.2.3)

Apache ServiceMix Bundles: oscache-2.4 (2.4.0.fuse)

Apache ServiceMix Bundles: ibatis-sqlmap-2.3.4.726 (2.3.4.726_1)

Spring ORM (2.5.6)

camel-jpa (1.6.0.fuse)

But if I install my component (I renamed it)

smx@root:osgi> install -s mvn:de.ps4b.rfid/jpa-event-reader

I receive a

smx@root:osgi> Exception in thread "SpringOsgiExtenderThread-78" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'camelContext:beanPostProcessor': Cannot resolve reference to bean 'camelContext' while setting bean property 'camelContext'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'camelContext': Invocation of init method failed; nested exception is org.springframework.beans.factory.CannotLoadBeanClassException: Cannot find class for bean with name 'entityManagerFactory' defined in URL bundle://211.0:0/META-INF/spring/bundle-context.xml; nested exception is java.lang.ClassNotFoundException: org.springframework.orm.jpa.LocalEntityManagerFactoryBean not found from bundle

        at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveReference(BeanDefinitionValueResolver.java:275)

...

Even though the Spring ORM bundle is active

Spring ORM (2.5.6)

and export the package 'org.springframework.orm.jpa'

smx@root:osgi> headers 208

Spring ORM (208)

-

---

Created-By = 10.0-b23 (Sun Microsystems Inc.)

Implementation-Title = Spring Framework

Ant-Version = Apache Ant 1.7.0

Export-Package = ...,org.springframework.orm.jpa;version="2.5.6";uses:="javax.persistence,...

So, I think the problem is in my OSGI bundle, because my bundle does't import the package 'org.springframework.orm.jpa'. I'm right?

Now, my question is, how can I explicitly import this package im in my OSGI bundle MANIFEST.MF file? I use the Felix maven-bundle-plugin and added this package in my pom.xml as follows:

<Import-Package>org.springframework.orm.jpa,</Import-Package>

But without an effect. The Import-Package declaration looks like

Import-Package: de.ps4b.rfid.jpa,javax.persistence;version="3.0",org.a

pache.camel.builder;version="1.6.0.fuse",org.apache.camel.component.j

pa,org.apache.camel.model;version="1.6.0.fuse",org.slf4j,org.springfr

amework.beans.factory;version="2.5",org.springframework.util;version=

"2.5"

Any idea?

Thanks,

Christian

[muellerc]

Hi all,

I solved my last problem. I must declare all packages, which should be added to the Import-Package definition from the MANIFEST.MF file:

                              <Import-Package>

                                   de.ps4b.rfid.jpa,

                                   javax.persistence,

                                   org.apache.camel.builder,

                                   org.apache.camel.component.jpa,

                                   org.apache.camel.model,

                                   org.slf4j,

                                   org.springframework.beans.factory,

                                   org.springframework.util,

                                   org.springframework.orm.jpa,

                                   *

                              </Import-Package>

Ok, now I have the problem, that the class 'javax.persistence.EntityManagerFactory' is not found:

smx@root:osgi> Exception in thread "SpringOsgiExtenderThread-80" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'entityManagerFactory' defined in URL bundle://211.0:0/META-INF/spring/bundle-context.xml: Initialization of bean failed; nested exception is java.lang.NoClassDefFoundError: javax/persistence/EntityManagerFactory

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:480)

The bundle is installed and active:

geronimo-jpa_3.0_spec (1.1.1)

and export the package:

smx@root:osgi> headers 203

geronimo-jpa_3.0_spec (203)

-

---

Tool = Bnd-0.0.227

Created-By = 1.5.0_13 (Apple Computer, Inc.)

Bnd-LastModified = 1201862281411

Implementation-Title = Apache Geronimo

Built-By = gnodet

Export-Package = javax.persistence.spi;uses:="javax.persistence,javax.sql";version="3.0",javax.persistence;uses:="javax.persistence.spi";version="3.0"

...

And in my OSGI bundle MANIFEST.MF file, I import the package:

Import-Package: de.ps4b.rfid.jpa,javax.persistence;version="3.0",...

Any idea?

Thank you,

Christian

[njiang]

It should be OK to use "http://activemq.apache.org/camel/schema/spring" in Fuse ESB 4.1.0.0.

Since camel-spring will register an osgi version handler with this namespace , if it detects the camel-osgi bundle.

[muellerc]

Hi folks,

it looks like it is a difficult problem or only a few peoples use the jpa route...

Like my last camel - fuse esb problem, first I will build a pure camel project to see if it's work without fuse esb (like the camel etl sample: http://camel.apache.org/etl-example.html)...

I will keep you informed...

Cheers,

Christian

[davsclaus]

Hi

Yeah OSGi can be a pain as well unless all the bundles are installed properly. I guess some features in SMX would be nice for JPA, so you can install jpa-openjpa, jpa-hibernate or which provider you want. However maintaining the feature scripts is also time consuming as there are many jars to keep updated.

There is also a camel-example-tracer that uses JPA. So you can also take a look at it.

[oisin]

David Greco was twittering about the pain of getting JPA to work with OSGi - there wasn't any Camel involved, but he has a blog article and some sample code on his website, which might be useful as a reference.

Edited by: oisin on May 13, 2009 8:19 AM

[muellerc]

Hi all,

I got it.

I attached a maven project which use the pure camel jpa (openjpa) and file route. It picks a file from the file system, use the jaxb type converter to convert the file in an event object and persist the event object via jpa in the database (mysql). A second route poll the database, read the event, convert the event object via jaxb and write the xml in a file.

I hope this sample also useful for other peoples...

Now, I try to build the sample as osgi bundle, so I can deploy it in fuse esb. I will keep you informed...

Cheers,

Christian

[muellerc]

Hey Oisin,

thanks for the link, but I don't get it working. Some dependency issues maven can't resolve...

After 2 hours spending in analysis, I skipped this sample...

Cheers,

Christian

[muellerc]

Hi all,

I don't get my sample jpa route working in fuse esb 4.1.0.0.

I changed it, so that the route read a database entry via jpa and put it in a activemq queue via jms.

I do the following steps:

1. run 'smx@root:features> install camel-jpa' which installed the bundles 'geronimo-jaxws_2.1_spec (1.0)', 'geronimo-el_1.0_spec (1.0.1)', 'spring-web (2.5.5)', 'Spring JDBC (2.5.6)', 'Commons Lang (2.4)', 'geronimo-jpa_3.0_spec (1.1.1)', 'Apache ServiceMix Bundles: openjpa-persistence-1.2.0 (1.2.0.fuse)', 'Apache ServiceMix Bundles: commons-dbcp-1.2.2 (1.2.2.3)', 'Apache ServiceMix Bundles: oscache-2.4 (2.4.0.fuse)', 'Apache ServiceMix Bundles: ibatis-sqlmap-2.3.4.726 (2.3.4.726_1)', 'Spring ORM (2.5.6)' and 'camel-jpa (1.6.0.fuse)'.

2. add 'http://repository.springsource.com/maven/bundles/external' to the 'org.ops4j.pax.url.mvn.repositories' in the file SERVICEMIX_HOME/etc/org.ops4j.pax.url.mvn.cfg

3. install the mysql database driver bundle:

smx@root:osgi> install -s mvn:com.mysql.jdbc/com.springsource.com.mysql.jdbc

4. verify the installation of the dependencies:

smx@root:osgi> list

...

geronimo-jaxws_2.1_spec (1.0)

geronimo-el_1.0_spec (1.0.1)

spring-web (2.5.5)

Spring JDBC (2.5.6)

Commons Lang (2.4)

geronimo-jpa_3.0_spec (1.1.1)

Apache ServiceMix Bundles: openjpa-persistence-1.2.0 (1.2.0.fuse)

Apache ServiceMix Bundles: commons-dbcp-1.2.2 (1.2.2.3)

Apache ServiceMix Bundles: oscache-2.4 (2.4.0.fuse)

Apache ServiceMix Bundles: ibatis-sqlmap-2.3.4.726 (2.3.4.726_1)

Spring ORM (2.5.6)

camel-jpa (1.6.0.fuse)

MySQL AB's JDBC Driver for MySQL (5.1.6)

5. install my camel-jpa-route:

smx@root:osgi> install mvn:de.ps4b.rfid/jpa-event-reader

Bundle ID: 202

6. start the route:

smx@root:osgi> start 202

smx@root:osgi> Exception in thread "SpringOsgiExtenderThread-70" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'entityManagerFactory' defined in URL bundle://202.0:0/META-INF/spring/bundle-context.xml: Initialization of bean failed; nested exception is java.lang.NoClassDefFoundError: javax/persistence/EntityManagerFactory

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:480)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory$1.run(AbstractAutowireCapableBeanFactory.java:409)

        at java.security.AccessController.doPrivileged(Native Method)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:380)

        at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:264)

        at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)

        at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:261)

        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:185)

        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:164)

        at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:423)

        at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:728)

        at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.access$1600(AbstractDelegatedExecutionApplicationContext.java:68)

        at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$4.run(AbstractDelegatedExecutionApplicationContext.java:343)

        at org.springframework.osgi.util.internal.PrivilegedUtils.executeWithCustomTCCL(PrivilegedUtils.java:85)

        at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.completeRefresh(AbstractDelegatedExecutionApplicationContext.java:308)

        at org.springframework.osgi.extender.internal.dependencies.startup.DependencyWaiterApplicationContextExecutor$CompleteRefreshTask.run(DependencyWaiterApplicationContextExecutor.java:138)

        at java.lang.Thread.run(Thread.java:613)

Caused by: java.lang.NoClassDefFoundError: javax/persistence/EntityManagerFactory

        at java.lang.Class.getDeclaredMethods0(Native Method)

        at java.lang.Class.privateGetDeclaredMethods(Class.java:2395)

        at java.lang.Class.getDeclaredMethods(Class.java:1763)

        at java.beans.Introspector$1.run(Introspector.java:1265)

        at java.security.AccessController.doPrivileged(Native Method)

        at java.beans.Introspector.getPublicDeclaredMethods(Introspector.java:1263)

        at java.beans.Introspector.getTargetMethodInfo(Introspector.java:1129)

        at java.beans.Introspector.getBeanInfo(Introspector.java:387)

        at java.beans.Introspector.getBeanInfo(Introspector.java:159)

        at java.beans.Introspector.getBeanInfo(Introspector.java:220)

        at java.beans.Introspector.(CachedIntrospectionResults.java:220)

        at org.springframework.beans.CachedIntrospectionResults.forClass(CachedIntrospectionResults.java:144)

        at org.springframework.beans.BeanWrapperImpl.getCachedIntrospectionResults(BeanWrapperImpl.java:252)

        at org.springframework.beans.BeanWrapperImpl.getPropertyDescriptorInternal(BeanWrapperImpl.java:282)

        at org.springframework.beans.BeanWrapperImpl.isWritableProperty(BeanWrapperImpl.java:333)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyPropertyValues(AbstractAutowireCapableBeanFactory.java:1247)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1010)

        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:472)

        ... 16 more

7. I checked the dependency to 'javax.persistence.EntityManagerFactory'. This package is Exported from the bundle ' geronimo-jpa_3.0_spec (1.1.1)' and imported from my bundle.

I added my simple project to the message. Maybe anyone can have a look at it.

Any idea and help is welcome,

Christian

Edited by: muellerc on Jun 7, 2009 9:36 PM

[muellerc]

Hello,

Has anyone a sample project which use the camel-jpa component inside FUSE ESB which you can post/attach here?

It looks for me, it is a feature where many people looking for (now 712 views on this post), but which is not easy to implement? :o(

Thank's in advance,

Christian

[muellerc]

Dear All,

after round about a month, we have no working sample/solution for the camel-jpa component running in Servicemix/FUSE.

A colleague of mine and author of the book 'Open-Source ESBs in Action',  Tijs Rademaker, also has no solution for this problem. He did some research with EclipseLink instead of OpenJPA.

The new version FUSE ESB 4.1.0.1 didn't solve this problem.

We think, we should raise a bug in the FUSE ESB JIRA. Do you agree with that?

Best regards,

Christian