[JCA] - AS400JDBCDataSource - getting started with two transactions
by Esther Williams
Esther Williams [http://community.jboss.org/people/esther_williams] created the discussion
"AS400JDBCDataSource - getting started with two transactions"
To view the discussion, visit: http://community.jboss.org/message/542386#542386
--------------------------------------------------------------
Hi,
This is the discussion started by Chris Weddell but hopefully without formatting issues.
*I am trying to get started with XA using JBOSS connected to two datasources (seperate applications) on the same AS400 (DB2) database.*
I have two datasources (see below) and have the following code...
**package
**
**
*
*
com.misys.equation.xa.test;
**import
**
**
*
*
java.sql.Connection;
**import
**
**
*
*
java.sql.Statement;
**import
**
**
*
*
javax.naming.InitialContext;
**import
**
**
*
*
javax.sql.DataSource;
**import
**
**
*
*
javax.transaction.UserTransaction;
**public
**
**
*
*
*class* Esther{
*public* *static* *void* main(String[] args){
UserTransaction utx;
*try*{
InitialContext initialContext =
*new* InitialContext();
utx = (UserTransaction) initialContext.lookup(
"UserTransaction");DataSource dataSource1 = (DataSource) initialContext.lookup(
"EQ-EQ4");DataSource dataSource2 = (DataSource) initialContext.lookup(
"EQ-EQ5");
// begin atrannie
utx.begin();
// ..
Connection connection1 = dataSource1.getConnection();
Statement statement1 = connection1.createStatement();
statement1.execute(
"INSERT INTO KFILEQ4/JVPF (JVHRC, JVHRD) VALUES('E01', 'EEE')");statement1.close();
connection1.close();
Connection connection2 = dataSource2.getConnection();
Statement statement2 = connection2.createStatement();
statement2.execute(
"INSERT INTO KFILEQ4/JVPF (JVHRC, JVHRD) VALUES('E02', 'EEE')");statement2.close();
connection2.close();
// unfortunately the following line fails
utx.commit();
System.
+out+.println(utx.getStatus());}
*catch* (Exception e){
e.printStackTrace();
}
}
}
unfortunately I get the following error when i execute the commit....
*14:53:50,076 INFO [STDOUT] Wed Apr 14 14:53:50:076 BST 2010 as400: XAResource B603382C-XA:RMID#49153 (30120272) : xa_end.*
*14:53:50,076 INFO [STDOUT] Wed Apr 14 14:53:50:076 BST 2010 as400: XAResource B603382C-XA:RMID#49153 (30120272) : xa error class = 0, return code = 0.*
*14:53:50,076 INFO [STDOUT] Wed Apr 14 14:53:50:076 BST 2010 as400: XAResource B603382C-XA:RMID#49153 (30120272) : xa_commit.*
*14:53:50,092 INFO [STDOUT] Wed Apr 14 14:53:50:092 BST 2010 as400: XAResource B603382C-XA:RMID#49153 (30120272) : xa error class = 9,* return code = -6.
14:53:50,092 ERROR [STDERR]
javax.transaction.RollbackException: [com.arjuna.ats.internal.jta.transaction.arjunacore.commitwhenaborted] [com.arjuna.ats.internal.jta.transaction.arjunacore.commitwhenaborted] Could not commit transaction.
14:53:50,092 ERROR [STDERR] at com.arjuna.ats.internal.jta.transaction.arjunacore.TransactionImple.commitAndDisassociate(
TransactionImple.java:1426)
14:53:50,092 ERROR [STDERR] at com.arjuna.ats.internal.jta.transaction.arjunacore.BaseTransaction.commit(
BaseTransaction.java:135)
14:53:50,092 ERROR [STDERR] at com.arjuna.ats.jbossatx.BaseTransactionManagerDelegate.commit(
BaseTransactionManagerDelegate.java:75)
14:53:50,092 ERROR [STDERR] at org.jboss.tm.usertx.client.ServerVMClientUserTransaction.commit(
ServerVMClientUserTransaction.java:162)
14:53:50,092 ERROR [STDERR] at com.misys.equation.ui.services.ServiceDirectory.startXATransaction(
ServiceDirectory.java:1156)
14:53:50,092 ERROR [STDERR] at sun.reflect.NativeMethodAccessorImpl.invoke0(
Native Method)
14:53:50,092 ERROR [STDERR] at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
14:53:50,092 ERROR [STDERR] at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
14:53:50,092 ERROR [STDERR] at java.lang.reflect.Method.invoke(Unknown Source)
14:53:50,092 ERROR [STDERR] at org.apache.axis.providers.java.RPCProvider.invokeMethod(
RPCProvider.java:397)
14:53:50,092 ERROR [STDERR] at org.apache.axis.providers.java.RPCProvider.processMessage(
RPCProvider.java:186)
14:53:50,092 ERROR [STDERR] at org.apache.axis.providers.java.JavaProvider.invoke(
JavaProvider.java:323)
14:53:50,092 ERROR [STDERR] at org.apache.axis.strategies.InvocationStrategy.visit(
InvocationStrategy.java:32)
14:53:50,092 ERROR [STDERR] at org.apache.axis.SimpleChain.doVisiting(
SimpleChain.java:118)
14:53:50,092 ERROR [STDERR] at org.apache.axis.SimpleChain.invoke(
SimpleChain.java:83)
14:53:50,092 ERROR [STDERR] at org.apache.axis.handlers.soap.SOAPService.invoke(
SOAPService.java:454)
14:53:50,092 ERROR [STDERR] at org.apache.axis.server.AxisServer.invoke(
AxisServer.java:281)
14:53:50,092 ERROR [STDERR] at org.apache.axis.transport.http.AxisServlet.doPost(
AxisServlet.java:699)
14:53:50,092 ERROR [STDERR] at javax.servlet.http.HttpServlet.service(
HttpServlet.java:637)
14:53:50,092 ERROR [STDERR] at org.apache.axis.transport.http.AxisServletBase.service(
AxisServletBase.java:327)
14:53:50,092 ERROR [STDERR] at javax.servlet.http.HttpServlet.service(
HttpServlet.java:717)
14:53:50,092 ERROR [STDERR] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(
ApplicationFilterChain.java:290)
14:53:50,092 ERROR [STDERR] at org.apache.catalina.core.ApplicationFilterChain.doFilter(
ApplicationFilterChain.java:206)
14:53:50,092 ERROR [STDERR] at org.jboss.web.tomcat.filters.ReplyHeaderFilter.doFilter(
ReplyHeaderFilter.java:96)
14:53:50,092 ERROR [STDERR] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(
ApplicationFilterChain.java:235)
14:53:50,092 ERROR [STDERR] at org.apache.catalina.core.ApplicationFilterChain.doFilter(
ApplicationFilterChain.java:206)
14:53:50,092 ERROR [STDERR] at org.apache.catalina.core.StandardWrapperValve.invoke(
StandardWrapperValve.java:235)
14:53:50,092 ERROR [STDERR] at org.apache.catalina.core.StandardContextValve.invoke(
StandardContextValve.java:191)
14:53:50,092 ERROR [STDERR] at org.jboss.web.tomcat.security.SecurityAssociationValve.invoke(
SecurityAssociationValve.java:190)
14:53:50,092 ERROR [STDERR] at org.jboss.web.tomcat.security.JaccContextValve.invoke(
JaccContextValve.java:92)
14:53:50,092 ERROR [STDERR] at org.jboss.web.tomcat.security.SecurityContextEstablishmentValve.process(
SecurityContextEstablishmentValve.java:126)
14:53:50,092 ERROR [STDERR] at org.jboss.web.tomcat.security.SecurityContextEstablishmentValve.invoke(
SecurityContextEstablishmentValve.java:70)
14:53:50,092 ERROR [STDERR] at org.apache.catalina.core.StandardHostValve.invoke(
StandardHostValve.java:127)
14:53:50,092 ERROR [STDERR] at org.apache.catalina.valves.ErrorReportValve.invoke(
ErrorReportValve.java:102)
14:53:50,092 ERROR [STDERR] at org.jboss.web.tomcat.service.jca.CachedConnectionValve.invoke(
CachedConnectionValve.java:158)
14:53:50,092 ERROR [STDERR] at org.apache.catalina.core.StandardEngineValve.invoke(
StandardEngineValve.java:109)
14:53:50,092 ERROR [STDERR] at org.apache.catalina.connector.CoyoteAdapter.service(
CoyoteAdapter.java:330)
14:53:50,092 ERROR [STDERR] at org.apache.coyote.http11.Http11Processor.process(
Http11Processor.java:829)
14:53:50,092 ERROR [STDERR] at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(
Http11Protocol.java:601)
14:53:50,092 ERROR [STDERR] at org.apache.tomcat.util.net.JIoEndpoint$Worker.run(
JIoEndpoint.java:447)
14:53:50,092 ERROR http://community.jboss.org/message/537429/l537429/STDERR http://community.jboss.org/message/537429#537429/STDERR at java.lang.Thread.run(Unknown Source)
*Now when i run the following code I don't get a problem....*
**package
**
**
*
*
com.misys.equation.xa.test;
**import
**
**
*
*
java.io.Serializable;
**import
**
**
*
*
java.sql.Connection;
**import
**
**
*
*
java.sql.SQLException;
**import
**
**
*
*
java.sql.Statement;
**import
**
**
*
*
java.util.Arrays;
**import
**
**
*
*
java.util.Random;
**import
**
**
*
*
javax.sql.XAConnection;
**import
**
**
*
*
javax.transaction.xa.XAException;
**import
**
**
*
*
javax.transaction.xa.XAResource;
**import
**
**
*
*
javax.transaction.xa.Xid;
**import
**
**
*
*
com.ibm.as400.access.AS400JDBCXADataSource;
**import
**
**
*
*
com.ibm.as400.access.AS400JDBCXAResource;
**import
**
**
*
*
com.misys.equation.common.utilities.Toolbox;
**public
**
**
*
*
*class* Esther2{
// This attribute is used to store cvs version information.
*public* *static* *final* String +_revision+ = "$Id: FileProcessor.java,v 1.6 2009/09/16 16:13:27 esther.williams Exp $";String
user1 = "whatever";String
password1 = "itmaybe";String
system1 = "machineA";String
user2 = "whatever";String
password2 = "itmaybe";String
system2 = "machineA";String
library = "*LIBL";AS400JDBCXADataSource
xaDataSource1 = *null*;XAConnection
xaConnection1 = *null*;XAResource
xaResource1 = *null*;XidImpl
xid = *null*;Connection
connection1 = *null*;Statement
statement1 = *null*;AS400JDBCXADataSource
xaDataSource2 = *null*;XAConnection
xaConnection2 = *null*;XAResource
xaResource2 = *null*;AS400JDBCXAResource
a;
// private XidImpl xid2 = null;
Connection
connection2 = *null*;Statement
statement2 = *null*;
*private* Esther2(){
}
*public* *static* *void* main(String[] args){
System.
+out+.println("Proceeding with test...");Esther2 test =
*new* Esther2();test.test();
}
*private* *void* test(){
*try*{
xaDataSource1 = *new* AS400JDBCXADataSource();
xaDataSource1.setServerName(system1);
xaDataSource1.setUser(user1);
xaDataSource1.setPassword(password1);
xaDataSource1.setLibraries(library);
xaDataSource1.setNaming("system");
xaDataSource1.setTranslateBinary(*false*);
xaDataSource1.setTrace(*true*);
xaDataSource2 = *new* AS400JDBCXADataSource();
xaDataSource2.setServerName(system2);
xaDataSource2.setUser(user2);
xaDataSource2.setPassword(password2);
xaDataSource2.setLibraries(library);
xaDataSource2.setNaming("system");
xaDataSource2.setTranslateBinary(*false*);
xaDataSource2.setTrace(*true*);
xaConnection1 = xaDataSource1.getXAConnection();
xaConnection2 = xaDataSource2.getXAConnection();
xaResource1 = xaConnection1.getXAResource();
xaResource2 = xaConnection2.getXAResource();
xid = *new* XidImpl(*new* *byte*[] { 0x0d }, *new* *byte*[] { 0x0b });
xaResource1.start(xid, XAResource.+TMNOFLAGS+);
// Need to decide whether to join based on whether the resources have the same resource manager
// if the are the same then the prepares, commits and rollbacks should only be executed on
// the first resource
*if* (xaResource1.isSameRM(xaResource2)){
xaResource2.start(xid, XAResource.+TMJOIN+);}
*else*{
xaResource2.start(xid, XAResource.+TMNOFLAGS+);}
// Do some SQL on connection 1
connection1 = xaConnection1.getConnection();
statement1 = connection1.createStatement();
statement1.executeUpdate("INSERT INTO KFILEQ4/JVPF (JVHRC, JVHRD) VALUES('X01', 'X01D')");
// Do some SQL on connection 2
connection2 = xaConnection2.getConnection();
statement2 = connection2.createStatement();
statement2.executeUpdate("INSERT INTO KFILEQ4/JVPF (JVHRC, JVHRD) VALUES('X02', 'X02D')");
// tell the resources that we have successfully finished doing the work,
// need to consider what to do if the SQL had gone wrong!
xaResource1.end(xid, XAResource.+TMSUCCESS+);
xaResource2.end(xid, XAResource.+TMSUCCESS+);
*if* (xaResource1.isSameRM(xaResource2)){
// only need to prepare on the first resource
*int* ret1 = xaResource1.prepare(xid);
// int ret2 = xaResource2.prepare(xid);
// only need to commit on the first resource
xaResource1.commit(xid, *false*);
// xaResource2.commit(xid, false);
}
*else*{
*int* ret1 = xaResource1.prepare(xid);
*int* ret2 = xaResource2.prepare(xid);
xaResource1.commit(xid, *false*);
xaResource2.commit(xid, *false*);}
}
*catch* (XAException e){
e.printStackTrace();
}
*catch* (SQLException e){
e.printStackTrace();
}
*finally*{
*try*{
statement1.close();
statement2.close();
connection1.close();
connection2.close();
xaConnection1.close();
xaConnection2.close();}
*catch* (Exception e2){
// *TODO*: handle exception
}
}
}
*public* *static* *class* XidImpl *implements* Serializable, Xid{
*private* *static* *final* *long* +serialVersionUID+ = 1L;
*private* *static* Random +random+ = *new* Random();
*private* *final* *int* formatId = 876;
*private* *final* *byte*[] globalTransactionId;
*private* *final* *byte*[] branchQualifier;
*private* *transient* String cachedToString;
*private* *transient* *int* cachedHashCode;
*public* XidImpl(){
globalTransactionId = *new* *byte*[10];
+random+.nextBytes(globalTransactionId);
branchQualifier = *new* *byte*[10];
+random+.nextBytes(branchQualifier);}
*public* XidImpl(*byte*[] globalTransactionId, *byte*[] branchQualifier){
*this*.globalTransactionId = globalTransactionId;
*this*.branchQualifier = branchQualifier;}
*public* *int* getFormatId(){
*return* formatId;}
*public* *byte*[] getGlobalTransactionId(){
*return* globalTransactionId;}
*public* *byte*[] getBranchQualifier(){
*return* branchQualifier;}
@Override
*public* *boolean* equals(Object object){
*if* (object == *this*)
*return* *true*;
*if* (object == *null* || object *instanceof* Xid == *false*)
*return* *false*;
Xid other = (Xid) object;
*return* (formatId == other.getFormatId() && Arrays.+equals+(globalTransactionId, other.getGlobalTransactionId()) && Arrays.+equals+(
branchQualifier, other.getBranchQualifier()));}
@Override
*public* *int* hashCode(){
*if* (cachedHashCode == 0){
cachedHashCode = formatId;
*for* (*int* j = 0; j < globalTransactionId.length; ++j)
cachedHashCode += globalTransactionId[j];}
*return* cachedHashCode;}
@Override
*public* String toString(){
*if* (cachedToString == *null*){
StringBuffer buffer =
*new* StringBuffer();buffer.append(
"XidImpl[FormatId=").append(getFormatId());buffer.append(
" GlobalId=x'").append(Toolbox.+cvtBytesToHexString+(getGlobalTransactionId()));buffer.append(
"' BranchQual=x'").append(Toolbox.+cvtBytesToHexString+(getBranchQualifier()));buffer.append(
"']");
cachedToString = buffer.toString();}
*return* cachedToString;}
}
}
*Note there is an extra "end" for the secound resource and a "prepare" that i don't see logged in the jboss example.*
*Any ideas?*
<?xml version="1.0" encoding="UTF-8" ?>
*-* <datasources>
*-* <xa-datasource>
** <jndi-name>*EQ-EQ5*</jndi-name>
** <use-java-context>*false*</use-java-context>
** <xa-datasource-class>*com.ibm.as400.access.AS400JDBCXADataSource*</xa-datasource-class>
** <xa-datasource-property name="*User*">*WHATEVER*</xa-datasource-property>
** <xa-datasource-property name="*Password*">*ITMAYBE*</xa-datasource-property>
** <xa-datasource-property name="*ServerName*">*MACHINEA*</xa-datasource-property>
** <xa-datasource-property name="*Libraries*">**LIBL*</xa-datasource-property>
** <xa-datasource-property name="*Naming*">*system*</xa-datasource-property>
** <track-connection-by-tx>*true*</track-connection-by-tx>
** <prepared-statement-cache-size>*100*</prepared-statement-cache-size>
** <isSameRM-override-value>*false*</isSameRM-override-value>
** <no-tx-separate-pools />
** <new-connection-sql />
** <check-valid-connection-sql />
*-* <!-- pooling parameters
** -->
** <min-pool-size>*1*</min-pool-size>
** <max-pool-size>*50*</max-pool-size>
** <blocking-timeout-millis>*50000*</blocking-timeout-millis>
** <idle-timeout-minutes>*5*</idle-timeout-minutes>
*-* <metadata>
** <type-mapping>*DB2/400*</type-mapping>
** </metadata>
** </xa-datasource>
** </datasources>
** <?xml version="1.0" encoding="UTF-8" ?>
*-* <datasources>
*-* <xa-datasource>
** <jndi-name>*EQ-EQ4*</jndi-name>
** <use-java-context>*false*</use-java-context>
** <xa-datasource-class>*com.ibm.as400.access.AS400JDBCXADataSource*</xa-datasource-class>
** <xa-datasource-property name="*User*">*WHATEVER*</xa-datasource-property>
** <xa-datasource-property name="*Password*">*ITMAYBE*</xa-datasource-property>
** <xa-datasource-property name="*ServerName*">*MACHINEA*</xa-datasource-property>
** <xa-datasource-property name="*Libraries*">**LIBL*</xa-datasource-property>
** <xa-datasource-property name="*Naming*">*system*</xa-datasource-property>
** <track-connection-by-tx>*true*</track-connection-by-tx>
** <prepared-statement-cache-size>*100*</prepared-statement-cache-size>
** <isSameRM-override-value>*false*</isSameRM-override-value>
** <no-tx-separate-pools />
** <new-connection-sql />
** <check-valid-connection-sql />
*-* <!-- pooling parameters
** -->
** <min-pool-size>*1*</min-pool-size>
** <max-pool-size>*50*</max-pool-size>
** <blocking-timeout-millis>*50000*</blocking-timeout-millis>
** <idle-timeout-minutes>*5*</idle-timeout-minutes>
*-* <metadata>
** <type-mapping>*DB2/400*</type-mapping>
** </metadata>
** </xa-datasource>
** </datasources>
--------------------------------------------------------------
Reply to this message by going to Community
[http://community.jboss.org/message/542386#542386]
Start a new discussion in JCA at Community
[http://community.jboss.org/choose-container!input.jspa?contentType=1&cont...]
16 years, 2 months
[JBoss Messaging] - JMSXDeliveryCount in message selector and QueueBrowser
by andreas_back
andreas_back [http://community.jboss.org/people/andreas_back] created the discussion
"JMSXDeliveryCount in message selector and QueueBrowser"
To view the discussion, visit: http://community.jboss.org/message/542379#542379
--------------------------------------------------------------
Hello!
A long running application is ported from JBoss MQ (under JBoss 3.2.4) to JBoss Messaging (under JBoss 5.1.0). The queue is used to distribute SOA-like jobs to a cluster of service-units.
1. The service-units shall only accept messages that have not been delivered before:
(JMS_JBOSS_REDELIVERY_COUNT is null or JMS_JBOSS_REDELIVERY_COUNT < 2)
in JBoss MQ under JBoss 3.4.2.
(JMSXDeliveryCount is null or JMSXDeliveryCount < 2)
has not shown any effect in JBoss Messaging.
2. Via a swing admin tool the content of the queue can be observed (by the use of QueueBrowser) and the "delivery_count" shall be read.
With JBoss MQ under JBoss 3.4.2 this was no problem. tm.getJMSRedelivered() did the job. But this method now throws an exception
under JBoss Messaging.
Under JBoss Messaging (and JBoss 5.1.0) tm.getStringProperty("JMSXDeliveryCount") always returns null when used with QueueBrowser.
The QueueBrowser returns JBossTextMessage objects and not the TextMessageProxy, that is returned by the receive method of the MessageConsumer.
Any advice
* how to select by a message selector only messages that have not been delivered before
* and how to read the "delivery_count"
in JBoss Messaging is very welcome!
Greetings
Andreas
--------------------------------------------------------------
Reply to this message by going to Community
[http://community.jboss.org/message/542379#542379]
Start a new discussion in JBoss Messaging at Community
[http://community.jboss.org/choose-container!input.jspa?contentType=1&cont...]
16 years, 2 months
Re: [jboss-user] [JBoss AOP] - frozen class creating JMS Session
by Mark Gargan
Mark Gargan [http://community.jboss.org/people/MarkGargan] replied to the discussion
"frozen class creating JMS Session"
To view the discussion, visit: http://community.jboss.org/message/542368#542368
--------------------------------------------------------------
Hey Kabir,
We encountered the same problem this morning, basically it's what you mentioned below, the mechanism
org.jboss.aop.advice + <FullClassName>_ + <methodName>_ + <methodHash>
perhaps has been changed to this. but in the version of
PerVmAdvice that we were using, jboss-aop-client-5.0.0.GA.jar that comes with the jboss
downloadable from the redhat site it's
ClassLoader cl = SecurityActions.getClassLoader(aspect.getClass());
String name = "org.jboss.aop.advice." + aspect.getClass().getName() + "_z_" + adviceName + "_" + System.identityHashCode(cl);
which doesn't cater for situations where the method is overloaded as the adviceName defaults to the methodName and the hashCode fo the classloader
will be the same. The above redeliver method appears in the ClientSessionDelegate class which implements the SessionDelegate interface within the jboss-messaging module.
The SessionDelegate interface has three method signatures overloaded redeliver, createTextMessage and createObjectMessage.
I renamed the overloaded methods (they are all delegated to from the JBossSession class), refactored the ClientSessionDelegate class, rebuilt the jar
and placed in our app and the problem didn't re-occur.
I've attached a copy of the jar with the amended classes, JBossSession, ClientSessionDelegate and SessionDelegate.
I didn't go through the process of resigned the classes in the MANIFEST.MF just in case.
Mark.
--------------------------------------------------------------
Reply to this message by going to Community
[http://community.jboss.org/message/542368#542368]
Start a new discussion in JBoss AOP at Community
[http://community.jboss.org/choose-container!input.jspa?contentType=1&cont...]
16 years, 2 months