[hornetq-commits] JBoss hornetq SVN: r11579 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/remoting/impl/netty.

[do-not-reply at jboss.org]

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