[jboss-cvs] JBoss Messaging SVN: r3063 - trunk/src/main/org/jboss/messaging/core/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2007-08-28 00:15:15 -0400 (Tue, 28 Aug 2007)
New Revision: 3063

Modified:
   trunk/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java
Log:
Update for Oracle

Modified: trunk/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java	2007-08-28 03:04:47 UTC (rev 3062)
+++ trunk/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java	2007-08-28 04:15:15 UTC (rev 3063)
@@ -583,26 +583,23 @@
 	         		//Maybe we need to persist the message itself
 	         		Message m = ref.getMessage();
 
-                  if (!m.isPersisted())
+                  if (trace)
                   {
-                     if (trace)
-                     {
-                        log.trace("Storing message " + m);
-                     }
-                     try
-                     {
-                        storeMessage(m, psInsertMessage);
+                     log.trace("Storing message " + m);
+                  }
+                  try
+                  {
+                     storeMessage(m, psInsertMessage);
 
-                        rows = psInsertMessage.executeUpdate();
-                     }
-                     catch (SQLException e)
-                     {
-                        log.warn("An exception happened while storing message (probably a duplicated key)", e);
-                     }
-
-                     m.setPersisted(true);
+                     rows = psInsertMessage.executeUpdate();
                   }
-      				
+                  catch (SQLException e)
+                  {
+                     log.warn("An exception happened while storing message (probably a duplicated key)", e);
+                  }
+
+                  m.setPersisted(true);
+
                   if (trace) { log.trace("Inserted " + rows + " rows"); }
 	         	}