Author: jbertram Date: 2012-02-09 17:17:52 -0500 (Thu, 09 Feb 2012) New Revision: 12104 Modified: branches/Branch_2_2_AS7/tests/src/org/hornetq/tests/unit/core/paging/impl/PagingStoreImplTest.java Log: [HORNETQ-847] createQueue not idempotent Modified: branches/Branch_2_2_AS7/tests/src/org/hornetq/tests/unit/core/paging/impl/PagingStoreImplTest.java =================================================================== --- branches/Branch_2_2_AS7/tests/src/org/hornetq/tests/unit/core/paging/impl/PagingStoreImplTest.java 2012-02-09 22:17:22 UTC (rev 12103) +++ branches/Branch_2_2_AS7/tests/src/org/hornetq/tests/unit/core/paging/impl/PagingStoreImplTest.java 2012-02-09 22:17:52 UTC (rev 12104) @@ -13,26 +13,7 @@ package org.hornetq.tests.unit.core.paging.impl; -import java.nio.ByteBuffer; -import java.util.ArrayList; -import java.util.Collection; -import java.util.Collections; -import java.util.List; -import java.util.Map; -import java.util.Set; -import java.util.concurrent.ConcurrentHashMap; -import java.util.concurrent.ConcurrentMap; -import java.util.concurrent.CountDownLatch; -import java.util.concurrent.Executor; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; -import java.util.concurrent.atomic.AtomicInteger; -import java.util.concurrent.atomic.AtomicLong; - -import javax.transaction.xa.Xid; - import junit.framework.Assert; - import org.hornetq.api.core.HornetQBuffer; import org.hornetq.api.core.HornetQBuffers; import org.hornetq.api.core.Pair; @@ -43,12 +24,7 @@ import org.hornetq.core.journal.SequentialFileFactory; import org.hornetq.core.journal.impl.NIOSequentialFileFactory; import org.hornetq.core.message.impl.MessageInternal; -import org.hornetq.core.paging.Page; -import org.hornetq.core.paging.PageTransactionInfo; -import org.hornetq.core.paging.PagedMessage; -import org.hornetq.core.paging.PagingManager; -import org.hornetq.core.paging.PagingStore; -import org.hornetq.core.paging.PagingStoreFactory; +import org.hornetq.core.paging.*; import org.hornetq.core.paging.cursor.PagePosition; import org.hornetq.core.paging.impl.PageTransactionInfoImpl; import org.hornetq.core.paging.impl.PagingStoreImpl; @@ -81,6 +57,13 @@ import org.hornetq.tests.util.UnitTestCase; import org.hornetq.utils.ExecutorFactory; +import javax.transaction.xa.Xid; +import java.nio.ByteBuffer; +import java.util.*; +import java.util.concurrent.*; +import java.util.concurrent.atomic.AtomicInteger; +import java.util.concurrent.atomic.AtomicLong; + /** * * @author <a href="mailto:clebert.suconic@jboss.com">Clebert Suconic</a> @@ -1254,7 +1237,15 @@ { } - /* (non-Javadoc) + public void rollbackBindings(long txID) throws Exception + { + } + + public void commitBindings(long txID) throws Exception + { + } + + /* (non-Javadoc) * @see org.hornetq.core.persistence.StorageManager#storeAcknowledge(long, long) */ public void storeAcknowledge(final long queueID, final long messageID) throws Exception @@ -1329,7 +1320,11 @@ { } - /* (non-Javadoc) + public void addQueueBinding(long tx, Binding binding) throws Exception + { + } + + /* (non-Javadoc) * @see org.hornetq.core.persistence.StorageManager#updateDeliveryCount(org.hornetq.core.server.MessageReference) */ public void updateDeliveryCount(final MessageReference ref) throws Exception