[hornetq-commits] JBoss hornetq SVN: r8220 - trunk/src/main/org/hornetq/core/server/impl.

[do-not-reply at jboss.org]

Author: timfox
Date: 2009-11-05 02:56:15 -0500 (Thu, 05 Nov 2009)
New Revision: 8220

Modified:
   trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java
Log:
minor reformat

Modified: trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java	2009-11-05 07:52:32 UTC (rev 8219)
+++ trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java	2009-11-05 07:56:15 UTC (rev 8220)
@@ -93,7 +93,7 @@
    private boolean started;
 
    private volatile LargeMessageDeliverer largeMessageDeliverer = null;
-  
+
    private boolean largeMessageInDelivery;
 
    /**
@@ -143,7 +143,7 @@
 
       this.binding = binding;
 
-      this.messageQueue = binding.getQueue();
+      messageQueue = binding.getQueue();
 
       this.executor = executor;
 
@@ -159,7 +159,7 @@
 
       this.managementService = managementService;
 
-      this.minLargeMessageSize = session.getMinLargeMessageSize();
+      minLargeMessageSize = session.getMinLargeMessageSize();
 
       this.updateDeliveries = updateDeliveries;
 
@@ -349,7 +349,7 @@
             forcedDeliveryMessage.setDestination(messageQueue.getName());
 
             final SessionReceiveMessage packet = new SessionReceiveMessage(id, forcedDeliveryMessage, 0);
-            
+
             channel.send(packet);
          }
       });
@@ -515,7 +515,7 @@
 
    // Private --------------------------------------------------------------------------------------
 
-   private void promptDelivery(boolean asyncDelivery)
+   private void promptDelivery(final boolean asyncDelivery)
    {
       lock.lock();
       try
@@ -747,9 +747,6 @@
          }
       }
 
-      /**
-       * 
-       */
       public void finish() throws Exception
       {
          lock.lock();
@@ -758,7 +755,7 @@
             if (largeMessage == null)
             {
                // handleClose could be calling close while handleDeliver is also calling finish.
-               // As a result one of them could get here after the largeMessage is already gone. 
+               // As a result one of them could get here after the largeMessage is already gone.
                // On that case we just ignore this call
                return;
             }
@@ -786,7 +783,7 @@
          }
       }
 
-      private SessionReceiveContinuationMessage createChunkSend(LargeMessageEncodingContext context)
+      private SessionReceiveContinuationMessage createChunkSend(final LargeMessageEncodingContext context)
       {
          SessionReceiveContinuationMessage chunk;
 
@@ -844,7 +841,7 @@
 
          while (iterator.hasNext())
          {
-            MessageReference ref = (MessageReference)iterator.next();
+            MessageReference ref = iterator.next();
             try
             {
                HandleStatus status = handle(ref);