Author: borges
Date: 2012-01-23 07:00:14 -0500 (Mon, 23 Jan 2012)
New Revision: 12041
Modified:
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageCacheImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageSubscriptionImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/journal/LargeServerMessageImpl.java
Log:
reduce visibility of classes and method
Modified:
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageCacheImpl.java
===================================================================
---
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageCacheImpl.java 2012-01-23
11:51:17 UTC (rev 12040)
+++
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageCacheImpl.java 2012-01-23
12:00:14 UTC (rev 12041)
@@ -27,7 +27,7 @@
*
*
*/
-public class PageCacheImpl implements PageCache
+class PageCacheImpl implements PageCache
{
// Constants -----------------------------------------------------
@@ -81,7 +81,7 @@
lock.readLock().unlock();
}
}
-
+
public long getPageId()
{
return page.getPageId();
Modified:
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageSubscriptionImpl.java
===================================================================
---
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageSubscriptionImpl.java 2012-01-23
11:51:17 UTC (rev 12040)
+++
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageSubscriptionImpl.java 2012-01-23
12:00:14 UTC (rev 12041)
@@ -300,7 +300,7 @@
tx.commit();
}
-
+
/* (non-Javadoc)
* @see java.lang.Object#toString()
*/
@@ -496,9 +496,7 @@
getPageInfo(position).incrementPendingTX();
}
- /* (non-Javadoc)
- * @see
org.hornetq.core.paging.cursor.PageCursor#returnElement(org.hornetq.core.paging.cursor.PagePosition)
- */
+ @Override
public void redeliver(final PagePosition position)
{
synchronized (redeliveries)
@@ -647,14 +645,14 @@
Collections.sort(recoveredACK);
boolean first = true;
-
+
long txDeleteCursorOnReload = -1;
for (PagePosition pos : recoveredACK)
{
lastAckedPosition = pos;
PageCursorInfo pageInfo = getPageInfo(pos);
-
+
if (pageInfo == null)
{
log.warn("Couldn't find page cache for page " + pos +
", removing it from the journal");
@@ -674,11 +672,11 @@
pageInfo.confirmed.addAndGet(pos.getMessageNr());
}
}
-
+
pageInfo.addACK(pos);
}
}
-
+
if (txDeleteCursorOnReload >= 0)
{
store.commit(txDeleteCursorOnReload);
@@ -1104,9 +1102,7 @@
}
}
- /* (non-Javadoc)
- * @see java.util.Iterator#next()
- */
+ @Override
public synchronized PagedReference next()
{
@@ -1132,10 +1128,7 @@
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.paging.cursor.PageCursor#moveNext()
- */
- public PagedReference moveNext() throws Exception
+ private PagedReference moveNext() throws Exception
{
synchronized (PageSubscriptionImpl.this)
{
Modified:
trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/journal/LargeServerMessageImpl.java
===================================================================
---
trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/journal/LargeServerMessageImpl.java 2012-01-23
11:51:17 UTC (rev 12040)
+++
trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/journal/LargeServerMessageImpl.java 2012-01-23
12:00:14 UTC (rev 12041)
@@ -457,7 +457,7 @@
// Inner classes -------------------------------------------------
- class DecodingContext implements BodyEncoder
+ private class DecodingContext implements BodyEncoder
{
private SequentialFile cFile;
Show replies by date