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;