Author: markt
Date: Mon Feb 18 22:54:44 2013
New Revision: 1447529

URL: http://svn.apache.org/r1447529
Log:
Use final.
Use imports.
Don't make log static

Modified:
    tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointBase.java

Modified: 
tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointBase.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointBase.java?rev=1447529&r1=1447528&r2=1447529&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointBase.java 
(original)
+++ tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointBase.java Mon 
Feb 18 22:54:44 2013
@@ -38,6 +38,8 @@ import javax.websocket.RemoteEndpoint;
 import javax.websocket.SendHandler;
 import javax.websocket.SendResult;
 
+import org.apache.juli.logging.Log;
+import org.apache.juli.logging.LogFactory;
 import org.apache.tomcat.util.res.StringManager;
 
 public abstract class WsRemoteEndpointBase implements RemoteEndpoint {
@@ -45,12 +47,10 @@ public abstract class WsRemoteEndpointBa
     private static final StringManager sm =
             StringManager.getManager(Constants.PACKAGE_NAME);
 
-    private static org.apache.juli.logging.Log log =
-            org.apache.juli.logging.LogFactory.getLog(
-                    WsRemoteEndpointBase.class);
+    private final Log log = LogFactory.getLog(WsRemoteEndpointBase.class);
 
     private boolean messagePartInProgress = false;
-    private Queue<MessagePart> messagePartQueue = new ArrayDeque<>();
+    private final Queue<MessagePart> messagePartQueue = new ArrayDeque<>();
     private final Object messagePartLock = new Object();
     private boolean dataMessageInProgress = false;
 
@@ -66,7 +66,7 @@ public abstract class WsRemoteEndpointBa
     private final ByteBuffer outputBuffer = ByteBuffer.allocate(8192);
     private final CharsetEncoder encoder = 
Charset.forName("UTF8").newEncoder();
     private final ByteBuffer encoderBuffer = ByteBuffer.allocate(8192);
-    private AtomicBoolean batchingAllowed = new AtomicBoolean(false);
+    private final AtomicBoolean batchingAllowed = new AtomicBoolean(false);
     private volatile long asyncSendTimeout = -1;
     private WsSession wsSession;
 



---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to