svn commit: r1749254 - /tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java

[kfujino]

Author: kfujino
Date: Mon Jun 20 02:40:23 2016
New Revision: 1749254

URL: http://svn.apache.org/viewvc?rev=1749254&view=rev
Log:
No-functional change.
Fix code format.

Modified:
    tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java

Modified: tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java?rev=1749254&r1=1749253&r2=1749254&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java 
(original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java Mon Jun 
20 02:40:23 2016
@@ -35,7 +35,7 @@ import org.apache.juli.logging.LogFactor
 /**
  * A channel to handle RPC messaging
  */
-public class RpcChannel implements ChannelListener{
+public class RpcChannel implements ChannelListener {
     private static final Log log = LogFactory.getLog(RpcChannel.class);
     protected static final StringManager sm = 
StringManager.getManager(RpcChannel.class);
 
@@ -49,8 +49,7 @@ public class RpcChannel implements Chann
     private byte[] rpcId;
     private int replyMessageOptions = 0;
 
-    private final HashMap<RpcCollectorKey, RpcCollector> responseMap =
-            new HashMap<>();
+    private final HashMap<RpcCollectorKey, RpcCollector> responseMap = new 
HashMap<>();
 
     /**
      * Create an RPC channel. You can have several RPC channels attached to a 
group
@@ -100,7 +99,7 @@ public class RpcChannel implements Chann
             }
         } catch ( InterruptedException ix ) {
             Thread.currentThread().interrupt();
-        }finally {
+        } finally {
             responseMap.remove(key);
         }
         return collector.getResponses();
@@ -129,7 +128,7 @@ public class RpcChannel implements Chann
                     }
                 }//synchronized
             }//end if
-        } else{
+        } else {
             boolean finished = false;
             final ExtendedRpcCallback excallback = (callback instanceof 
ExtendedRpcCallback)?((ExtendedRpcCallback)callback) : null;
             boolean asyncReply = ((replyMessageOptions & 
Channel.SEND_OPTIONS_ASYNCHRONOUS) == Channel.SEND_OPTIONS_ASYNCHRONOUS);
@@ -159,7 +158,7 @@ public class RpcChannel implements Chann
                     channel.send(new Member[] {sender}, 
rmsg,replyMessageOptions & ~Channel.SEND_OPTIONS_SYNCHRONIZED_ACK);
                 }
                 finished = true;
-            }catch ( Exception x )  {
+            } catch ( Exception x )  {
                 if (excallback != null && !asyncReply) {
                     excallback.replyFailed(rmsg.message, reply, sender, x);
                 } else {
@@ -187,7 +186,7 @@ public class RpcChannel implements Chann
         if ( msg instanceof RpcMessage ) {
             RpcMessage rmsg = (RpcMessage)msg;
             return Arrays.equals(rmsg.rpcId,rpcId);
-        }else return false;
+        } else return false;
     }
 
     public Channel getChannel() {
@@ -239,7 +238,7 @@ public class RpcChannel implements Chann
             this.destcnt = destcnt;
         }
 
-        public void addResponse(Serializable message, Member sender){
+        public void addResponse(Serializable message, Member sender) {
             Response resp = new Response(sender,message);
             responses.add(resp);
         }



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org