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()