You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by ay...@apache.org on 2012/05/02 15:33:49 UTC

svn commit: r1333040 - /cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/persistence/jdbc/RMTxStore.java

Author: ay
Date: Wed May  2 13:33:48 2012
New Revision: 1333040

URL: http://svn.apache.org/viewvc?rev=1333040&view=rev
Log:
forgot to delete some unnecessary lines for CXF-4276

Modified:
    cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/persistence/jdbc/RMTxStore.java

Modified: cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/persistence/jdbc/RMTxStore.java
URL: http://svn.apache.org/viewvc/cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/persistence/jdbc/RMTxStore.java?rev=1333040&r1=1333039&r2=1333040&view=diff
==============================================================================
--- cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/persistence/jdbc/RMTxStore.java (original)
+++ cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/persistence/jdbc/RMTxStore.java Wed May  2 13:33:48 2012
@@ -586,15 +586,6 @@ public class RMTxStore implements RMStor
                     new Object[] {outbound ? "outbound" : "inbound", nr, id, to});
         }
         PreparedStatement stmt = outbound ? createOutboundMessageStmt : createInboundMessageStmt;
-        if (null == stmt) {
-            stmt = connection.prepareStatement(MessageFormat.format(CREATE_MESSAGE_STMT_STR,
-                outbound ? OUTBOUND_MSGS_TABLE_NAME : INBOUND_MSGS_TABLE_NAME));
-            if (outbound) {
-                createOutboundMessageStmt = stmt;                    
-            } else {
-                createInboundMessageStmt = stmt;
-            }
-        }
         int i = 1;
         stmt.setString(i++, id);  
         stmt.setLong(i++, nr);