joinTransaction wurde für einen ressourcenlokalen EntityManager in ApacheCamel aufgerufen
-
24-12-2019 - |
Frage
Ich bin neu bei Apache Camel und teste Camel-JPA, um Tabellen abzufragen und Datensätze anzuzeigen
Es folgt die Hauptklasse
EntityManagerFactory entityManagerFactory = Persistence.createEntityManagerFactory("LoanServicePU");
CamelContext camelContext = new DefaultCamelContext();
JpaComponent jpa = new JpaComponent();
jpa.setEntityManagerFactory(entityManagerFactory);
JpaTransactionManager myTM=new JpaTransactionManager();
myTM.setEntityManagerFactory(entityManagerFactory);
jpa.setTransactionManager( myTM );
jpa.setCamelContext(camelContext);
camelContext.addRoutes(new JpaRouteBuilder());
camelContext.addComponent("jpa",jpa);
camelContext.start();
Thread.sleep(10000);
camelContext.stop();
System.out.println("Done");
Es folgt die Jparouter-Klasse
public void configure() throws Exception {
from("jpa://com.pns.ab.model.LoanRequest?consumeDelete=false;"
+ "consumer.delay=2000;maxMessagesPerPoll=1000;"
+ "consumer.namedQuery=selectLoanRequests").to("stream:out");
}
Ich habe persistence.xml und es unter META-INF konfiguriert. Tatsächlich starte ich in Eclipse das Java-Projekt und stelle dann die JPA-Facette ein
persistence.xml
<persistence version="2.1" xmlns="http://xmlns.jcp.org/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd">
<persistence-unit name="LoanServicePU" transaction-type="RESOURCE_LOCAL">
<provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
<class>com.pns.ab.model.LoanRequest</class>
<properties>
<property name="eclipselink.target-server" value="None"/>
<property name="javax.persistence.jdbc.driver" value="oracle.jdbc.OracleDriver"/>
<property name="javax.persistence.jdbc.url" value="jdbc:oracle:thin:@127.0.0.1:1521:xe"/>
<property name="javax.persistence.jdbc.user" value="vs"/>
<property name="javax.persistence.jdbc.password" value="vs"/>
<property name="eclipselink.logging.level" value="INFO"/>
</properties>
</persistence-unit>
</persistence>
Aber ich erhalte folgende Fehlermeldung:
[main] INFO org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.12.3 (CamelContext: camel-1) started in 1.426 seconds
[Camel (camel-1) thread #0 - jpa://com.pns.ab.model.LoanRequest] WARN org.apache.camel.component.jpa.JpaConsumer - Consumer Consumer[jpa://com.pns.ab.model.LoanRequest?consumeDelete=false%3Bconsumer.delay%3D2000&consumer.namedQuery=selectLoanRequests] failed polling endpoint: Endpoint[jpa://com.pns.ab.model.LoanRequest?consumeDelete=false%3Bconsumer.delay%3D2000&consumer.namedQuery=selectLoanRequests]. Will try again at next poll. Caused by: [javax.persistence.TransactionRequiredException - joinTransaction has been called on a resource-local EntityManager which is unable to register for a JTA transaction.]
javax.persistence.TransactionRequiredException: joinTransaction has been called on a resource-local EntityManager which is unable to register for a JTA transaction.
at org.eclipse.persistence.internal.jpa.transaction.EntityTransactionWrapper.registerIfRequired(EntityTransactionWrapper.java:91)
at org.eclipse.persistence.internal.jpa.EntityManagerImpl.joinTransaction(EntityManagerImpl.java:2081)
Lösung
Aus dem Protokoll
Ressourcenlokaler EntityManager, der sich nicht für eine JTA-Transaktion registrieren kann
Ich komme zu dem Schluss, dass die Kamelroute in einer JTA-Transaktionsumgebung bereitgestellt wird, aber in Ihrer persistence.xml
Sie können die Standardeinstellung verwenden transaction-type
welches ist RESOURCE_LOCAL
anstatt JTA
.
BEARBEITEN:
Mit folgendem Setup könnte ich es zum Laufen bringen:
Initialisieren Sie das nicht
EntityManagerFactory
UndTransactionManager
selbst, tun Sie einfach:final SimpleRegistry registry = new SimpleRegistry(); final CamelContext context = new DefaultCamelContext(registry); context.addRoutes(new JpaSetupRouteBuilder()); context.start();
In
persistence.xml
Benennen Sie Ihr umpersistence-unit
Zucamel
wie zum Beispiel:<!-- setting the transaction-type to RESOURCE_LOCAL is optional as this is the default --> <persistence-unit name="camel" transaction-type="RESOURCE_LOCAL">
Ja, ich weiß, das ist nicht sehr befriedigend.
BEARBEITEN:
Wenn Sie das nicht umbenennen möchten oder können persistence-unit
Zu camel
dann könnten Sie seinen Namen im URI mit festlegen persistenceUnit
Option wie:
from("jpa://com.pns.ab.model.LoanRequest?consumeDelete=false"
+ "&consumer.delay=2000;maxMessagesPerPoll=1000"
+ "&consumer.namedQuery=selectLoanRequests"
+ "&persistenceUnit=LoanServicePU")
.to("stream:out");
BEARBEITEN:
Oder verwenden Sie alternativ das Spring XML-Setup wie beschrieben Hier.