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

[do-not-reply at jboss.org]

Author: jbertram
Date: 2012-02-09 17:15:02 -0500 (Thu, 09 Feb 2012)
New Revision: 12100

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

Modified: branches/Branch_2_2_AS7/src/main/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java
===================================================================
--- branches/Branch_2_2_AS7/src/main/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java	2012-02-09 22:14:15 UTC (rev 12099)
+++ branches/Branch_2_2_AS7/src/main/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java	2012-02-09 22:15:02 UTC (rev 12100)
@@ -13,16 +13,6 @@
 
 package org.hornetq.core.persistence.impl.nullpm;
 
-import java.nio.ByteBuffer;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.Executor;
-import java.util.concurrent.atomic.AtomicLong;
-
-import javax.transaction.xa.Xid;
-
 import org.hornetq.api.core.Pair;
 import org.hornetq.api.core.SimpleString;
 import org.hornetq.core.journal.IOAsyncTask;
@@ -49,6 +39,15 @@
 import org.hornetq.core.transaction.ResourceManager;
 import org.hornetq.core.transaction.Transaction;
 
+import javax.transaction.xa.Xid;
+import java.nio.ByteBuffer;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.Executor;
+import java.util.concurrent.atomic.AtomicLong;
+
 /**
  * 
  * A NullStorageManager
@@ -140,10 +139,18 @@
    {
    }
 
-   public void storeReference(final long queueID, final long messageID, final boolean last) throws Exception
+   public void rollbackBindings(long txID) throws Exception
    {
    }
 
+   public void commitBindings(long txID) throws Exception
+   {
+   }
+
+    public void storeReference(final long queueID, final long messageID, final boolean last) throws Exception
+   {
+   }
+
    public void storeReferenceTransactional(final long txID, final long queueID, final long messageID) throws Exception
    {
    }
@@ -227,7 +234,11 @@
    {
    }
 
-   /* (non-Javadoc)
+   public void addQueueBinding(long tx, Binding binding) throws Exception
+   {
+   }
+
+    /* (non-Javadoc)
     * @see org.hornetq.core.persistence.StorageManager#createLargeMessageStorage(long, int, int)
     */
    public LargeServerMessage createLargeMessage()