svn commit: r1390931 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java

[gt...@apache.org]

Author: gtully
Date: Thu Sep 27 10:28:20 2012
New Revision: 1390931

URL: http://svn.apache.org/viewvc?rev=1390931&view=rev
Log:
fix typo

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java?rev=1390931&r1=1390930&r2=1390931&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java Thu Sep 27 10:28:20 2012
@@ -24,7 +24,7 @@ import java.util.concurrent.locks.Reentr
  */
 public class MutexTransport extends TransportFilter {
 
-    private final ReentrantLock wreiteLock = new ReentrantLock();
+    private final ReentrantLock writeLock = new ReentrantLock();
     private boolean syncOnCommand;
 
     public MutexTransport(Transport next) {
@@ -40,11 +40,11 @@ public class MutexTransport extends Tran
     @Override
     public void onCommand(Object command) {
         if (syncOnCommand) {
-            wreiteLock.lock();
+            writeLock.lock();
             try {
                 transportListener.onCommand(command);
             } finally {
-                wreiteLock.unlock();
+                writeLock.unlock();
             }
         } else {
             transportListener.onCommand(command);
@@ -53,41 +53,41 @@ public class MutexTransport extends Tran
 
     @Override
     public FutureResponse asyncRequest(Object command, ResponseCallback responseCallback) throws IOException {
-        wreiteLock.lock();
+        writeLock.lock();
         try {
             return next.asyncRequest(command, null);
         } finally {
-            wreiteLock.unlock();
+            writeLock.unlock();
         }
     }
 
     @Override
     public void oneway(Object command) throws IOException {
-        wreiteLock.lock();
+        writeLock.lock();
         try {
             next.oneway(command);
         } finally {
-            wreiteLock.unlock();
+            writeLock.unlock();
         }
     }
 
     @Override
     public Object request(Object command) throws IOException {
-        wreiteLock.lock();
+        writeLock.lock();
         try {
             return next.request(command);
         } finally {
-            wreiteLock.unlock();
+            writeLock.unlock();
         }
     }
 
     @Override
     public Object request(Object command, int timeout) throws IOException {
-        wreiteLock.lock();
+        writeLock.lock();
         try {
             return next.request(command, timeout);
         } finally {
-            wreiteLock.unlock();
+            writeLock.unlock();
         }
     }