[hornetq-commits] JBoss hornetq SVN: r12102 - branches/Branch_2_2_AS7/src/main/org/hornetq/core/persistence.

[do-not-reply at jboss.org]

Author: jbertram
Date: 2012-02-09 17:16:31 -0500 (Thu, 09 Feb 2012)
New Revision: 12102

Modified:
   branches/Branch_2_2_AS7/src/main/org/hornetq/core/persistence/StorageManager.java
Log:
[HORNETQ-847] createQueue not idempotent

Modified: branches/Branch_2_2_AS7/src/main/org/hornetq/core/persistence/StorageManager.java
===================================================================
--- branches/Branch_2_2_AS7/src/main/org/hornetq/core/persistence/StorageManager.java	2012-02-09 22:15:24 UTC (rev 12101)
+++ branches/Branch_2_2_AS7/src/main/org/hornetq/core/persistence/StorageManager.java	2012-02-09 22:16:31 UTC (rev 12102)
@@ -193,6 +193,10 @@
    void commit(long txID, boolean lineUpContext) throws Exception;
 
    void rollback(long txID) throws Exception;
+   
+   void rollbackBindings(long txID) throws Exception;
+   
+   void commitBindings(long txID) throws Exception;
 
    void storePageTransaction(long txID, PageTransactionInfo pageTransaction) throws Exception;
    
@@ -220,7 +224,7 @@
 
    // Bindings related operations
 
-   void addQueueBinding(Binding binding) throws Exception;
+   void addQueueBinding(long tx, Binding binding) throws Exception;
 
    void deleteQueueBinding(long queueBindingID) throws Exception;