我有一个监听特定主题的 MDB。
我已经配置了带有 JBoss 的 XA 数据源...
我已经设置了 persistance.xml。
<persistence-unit name="jpa" transaction-type="JTA">
<provider>org.hibernate.ejb.HibernatePersistence</provider>
<jta-data-source>java:jdbc/BKS_DataSource</jta-data-source>
<class>com.jms.mdb.SampleData</class>
<properties>
<property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect"/>
<property name="hibernate.hbm2ddl.auto" value="update"/>
<property name="hibernate.show_sql" value="true"/>
<!--
<property name="hibernate.format_sql" value="true"/>
-->
</properties>
</persistence-unit>
每当我收到东西时,我只需在MDB中执行此代码。
@PersistenceContext
EntityManager em = null;
public void onMessage(Message message) {
try {
LoggingEvent event = (LoggingEvent)((ObjectMessage)message).getObject();
System.out.println("Received something11");
SampleData s= new SampleData();
s.setMessage(event.getLoggerName());
em.persist(s);
System.out.println("Persisted");
//Create.main(null);
} catch (JMSException e) {
e.printStackTrace();
}
}
基本上我需要执行两阶段提交事务...因此我想知道我应该如何执行XA事务...另外,我只想在Java EE 5上执行它。
MessageDrivenContext
的setRollbackOnly
方法。 - Behrang