Author: borges Date: 2011-09-13 10:42:49 -0400 (Tue, 13 Sep 2011) New Revision: 11342 Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/PageCursorProvider.java branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java Log: Delete unused code. Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/PageCursorProvider.java =================================================================== --- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/PageCursorProvider.java 2011-09-13 14:13:22 UTC (rev 11341) +++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/PageCursorProvider.java 2011-09-13 14:42:49 UTC (rev 11342) @@ -15,7 +15,6 @@ import org.hornetq.core.filter.Filter; import org.hornetq.core.paging.PagedMessage; -import org.hornetq.core.paging.PagingStore; /** * The provider of Cursor for a given Address @@ -43,8 +42,6 @@ void addPageCache(PageCache cache); - PagingStore getAssociatedStore(); - /** * * @param queueId The cursorID should be the same as the queueId associated for persistance Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java =================================================================== --- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java 2011-09-13 14:13:22 UTC (rev 11341) +++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java 2011-09-13 14:42:49 UTC (rev 11342) @@ -80,11 +80,6 @@ // Public -------------------------------------------------------- - public PagingStore getAssociatedStore() - { - return pagingStore; - } - public synchronized PageSubscription createSubscription(long cursorID, Filter filter, boolean persistent) { PageSubscription activeCursor = activeCursors.get(cursorID); Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java =================================================================== --- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java 2011-09-13 14:13:22 UTC (rev 11341) +++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java 2011-09-13 14:42:49 UTC (rev 11342) @@ -104,9 +104,6 @@ private final ConcurrentMap<Long, LargeServerMessage> largeMessages = new ConcurrentHashMap<Long, LargeServerMessage>(); - // Used on tests, to simulate failures on delete pages - private boolean deletePages = true; - private boolean started; // Constructors -------------------------------------------------- @@ -349,12 +346,6 @@ } - /** Used on tests only. To simulate missing page deletes*/ - public void setDeletePages(final boolean deletePages) - { - this.deletePages = deletePages; - } - /** * @param journalInformation */ @@ -736,10 +727,7 @@ { if (packet.isDelete()) { - if (deletePages) - { - page.delete(null); - } + page.delete(null); } else {