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;