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

[do-not-reply at jboss.org]

Author: timfox
Date: 2009-11-05 02:31:28 -0500 (Thu, 05 Nov 2009)
New Revision: 8218

Modified:
   trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java
Log:
removed unnecessary volatile modifiers that were there before

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:25:01 UTC (rev 8217)
+++ trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java	2009-11-05 07:31:28 UTC (rev 8218)
@@ -93,8 +93,7 @@
    private boolean started;
 
    private volatile LargeMessageDeliverer largeMessageDeliverer = null;
-
-   // Note, this does not need to be volatile since it is only accessed when the lock is held
+  
    private boolean largeMessageInDelivery;
 
    /**
@@ -624,17 +623,14 @@
    {
       private final long sizePendingLargeMessage;
 
-      /** The current message being processed
-       *  Note, this does not need to be volatile since it is only accessed when the lock is held
-       */
       private LargeServerMessage largeMessage;
 
       private final MessageReference ref;
 
-      private volatile boolean sentInitialPacket = false;
+      private boolean sentInitialPacket = false;
 
       /** The current position on the message being processed */
-      private volatile long positionPendingLargeMessage;
+      private long positionPendingLargeMessage;
 
       private LargeMessageEncodingContext context;