[hornetq-commits] JBoss hornetq SVN: r12041 - in trunk/hornetq-core/src/main/java/org/hornetq/core: persistence/impl/journal and 1 other directory.

[do-not-reply at jboss.org]

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;