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
{