diff --git a/ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/InboundMessageProcessor.java b/ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/InboundMessageProcessor.java index df2059d2d..54d2747d8 100755 --- a/ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/InboundMessageProcessor.java +++ b/ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/InboundMessageProcessor.java @@ -854,9 +854,9 @@ public class InboundMessageProcessor implements Runnable, MessageExchangeReplyLi } } connection = getDatabaseConnection(jndiName); - if (isTransacted && exchange instanceof InOnly) { - connection.setAutoCommit(false); - } +// if (isTransacted && exchange instanceof InOnly) { + connection.setAutoCommit(true); +// } //final List records = epb.getProcessList(); final List records = (List)mMapInboundExchangesProcessRecords.get(messageId); for (final Iterator it = records.iterator(); it.hasNext();) { diff --git a/ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/OutboundMessageProcessor.java b/ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/OutboundMessageProcessor.java index 6da7485b2..9e645d38c 100755 --- a/ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/OutboundMessageProcessor.java +++ b/ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/OutboundMessageProcessor.java @@ -1123,7 +1123,7 @@ public class OutboundMessageProcessor implements Runnable { "DBBC_E00627"); throw new Exception(faultString, e); } - connection.setAutoCommit(false); + connection.setAutoCommit(true); /* PP: Glassfish does not return a XADataSource and always returns @@ -1435,7 +1435,7 @@ public class OutboundMessageProcessor implements Runnable { faultCode, faultDetail); throw new Exception(faultString, e); } - connection.setAutoCommit(false); + connection.setAutoCommit(true); cs = executeOutboundProc(inMsg, epb, meta, connection); final JDBCNormalizer normalizer = @@ -1714,7 +1714,7 @@ public class OutboundMessageProcessor implements Runnable { } if (transaction != null) - connection.setAutoCommit(false); + connection.setAutoCommit(true); // writeMessage(inMsg, destinationAddress, false); if (meta.getJDBCOperationInput().getOperationType(). equalsIgnoreCase(