vitalif
/
openesb-components
mirror of https://github.com/vitalif/openesb-components
1
0
Fork 0
Code Issues Releases Wiki Activity

Ensure autocommit=true in db binding

master
Vitaliy Filippov 2015-12-21 17:47:12 +03:00
parent 71407f2d44
commit 647dbc8522
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/InboundMessageProcessor.java
View File

@ -431,6 +431,7 @@ public class InboundMessageProcessor implements Runnable, MessageExchangeReplyLi
if (connection != null) { if (connection != null) {
if (epb.isClustered()) { if (epb.isClustered()) {
connection.commit(); connection.commit();
connection.setAutoCommit(true);
} }
connection.close(); connection.close();
} }

6
ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/OutboundMessageProcessor.java
View File

@ -1015,8 +1015,6 @@ public class OutboundMessageProcessor implements Runnable {
if (transaction != null) if (transaction != null)
resumeThreadTx(transaction); resumeThreadTx(transaction);
connection.setAutoCommit(true);
/* PP: Glassfish does not return a XADataSource and always returns /* PP: Glassfish does not return a XADataSource and always returns
* a DataSource30 object which does not implement getXAResource() method * a DataSource30 object which does not implement getXAResource() method
xaconnection = getXADatabaseConnection(epb); xaconnection = getXADatabaseConnection(epb);
@ -1292,7 +1290,6 @@ public class OutboundMessageProcessor implements Runnable {
MessageExchange.JTA_TRANSACTION_PROPERTY_NAME); MessageExchange.JTA_TRANSACTION_PROPERTY_NAME);
if (transaction != null) if (transaction != null)
resumeThreadTx(transaction); resumeThreadTx(transaction);
connection.setAutoCommit(true);
cs = executeOutboundProc(inMsg, epb, meta, jndiName, connection); cs = executeOutboundProc(inMsg, epb, meta, jndiName, connection);
final JDBCNormalizer normalizer = final JDBCNormalizer normalizer =
new JDBCNormalizer(); new JDBCNormalizer();
@ -1534,8 +1531,6 @@ public class OutboundMessageProcessor implements Runnable {
String jndiName = (String)jndiConn[0]; String jndiName = (String)jndiConn[0];
connection = (Connection)jndiConn[1]; connection = (Connection)jndiConn[1];
if (transaction != null)
connection.setAutoCommit(true);
// writeMessage(inMsg, destinationAddress, false); // writeMessage(inMsg, destinationAddress, false);
if (meta.getJDBCOperationInput().getOperationType(). if (meta.getJDBCOperationInput().getOperationType().
equalsIgnoreCase( equalsIgnoreCase(
@ -1927,6 +1922,7 @@ public class OutboundMessageProcessor implements Runnable {
"DBBC_E00627"); "DBBC_E00627");
throw e; throw e;
} }
connection.setAutoCommit(true);
return new Object[] { jndiName, connection }; return new Object[] { jndiName, connection };
} }