Author: clebert.suconic Date: 2011-10-21 15:26:04 -0400 (Fri, 21 Oct 2011) New Revision: 11579 Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/remoting/impl/netty/NettyConnection.java Log: format only (no changes) Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/remoting/impl/netty/NettyConnection.java =================================================================== --- branches/Branch_2_2_EAP/src/main/org/hornetq/core/remoting/impl/netty/NettyConnection.java 2011-10-21 19:24:40 UTC (rev 11578) +++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/remoting/impl/netty/NettyConnection.java 2011-10-21 19:26:04 UTC (rev 11579) @@ -62,7 +62,7 @@ private final Semaphore writeLock = new Semaphore(1); - private Set<ReadyListener> readyListeners = new ConcurrentHashSet<ReadyListener>(); + private final Set<ReadyListener> readyListeners = new ConcurrentHashSet<ReadyListener>(); // Static -------------------------------------------------------- @@ -70,8 +70,8 @@ public NettyConnection(final Channel channel, final ConnectionLifeCycleListener listener, - boolean batchingEnabled, - boolean directDeliver) + final boolean batchingEnabled, + final boolean directDeliver) { this(null, channel, listener, batchingEnabled, directDeliver); } @@ -79,8 +79,8 @@ public NettyConnection(final Acceptor acceptor, final Channel channel, final ConnectionLifeCycleListener listener, - boolean batchingEnabled, - boolean directDeliver) + final boolean batchingEnabled, + final boolean directDeliver) { this.channel = channel; @@ -160,7 +160,7 @@ { channel.write(batchBuffer.channelBuffer()); - batchBuffer = HornetQBuffers.dynamicBuffer(BATCHING_BUFFER_SIZE); + batchBuffer = HornetQBuffers.dynamicBuffer(NettyConnection.BATCHING_BUFFER_SIZE); } } finally @@ -188,14 +188,14 @@ { // Lazily create batch buffer - batchBuffer = HornetQBuffers.dynamicBuffer(BATCHING_BUFFER_SIZE); + batchBuffer = HornetQBuffers.dynamicBuffer(NettyConnection.BATCHING_BUFFER_SIZE); } if (batchBuffer != null) { batchBuffer.writeBytes(buffer, 0, buffer.writerIndex()); - if (batchBuffer.writerIndex() >= BATCHING_BUFFER_SIZE || !batched || flush) + if (batchBuffer.writerIndex() >= NettyConnection.BATCHING_BUFFER_SIZE || !batched || flush) { // If the batch buffer is full or it's flush param or not batched then flush the buffer @@ -214,7 +214,7 @@ { // Create a new buffer - batchBuffer = HornetQBuffers.dynamicBuffer(BATCHING_BUFFER_SIZE); + batchBuffer = HornetQBuffers.dynamicBuffer(NettyConnection.BATCHING_BUFFER_SIZE); } }