[hornetq-commits] JBoss hornetq SVN: r11342 - in branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core: paging/cursor/impl and 1 other directories.

[do-not-reply at jboss.org]

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
          {