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);