Author: kfujino
Date: Mon Jun 20 02:43:05 2016
New Revision: 1749257
URL: http://svn.apache.org/viewvc?rev=1749257&view=rev
Log:
No-functional change.
Fix code format.
Modified:
tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
Modified:
tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
URL:
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java?rev=1749257&r1=1749256&r2=1749257&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
(original)
+++ tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
Mon Jun 20 02:43:05 2016
@@ -35,7 +35,7 @@ import org.apache.juli.logging.LogFactor
* A channel to handle RPC messaging
* @author Filip Hanik
*/
-public class RpcChannel implements ChannelListener{
+public class RpcChannel implements ChannelListener {
private static final Log log = LogFactory.getLog(RpcChannel.class);
public static final int FIRST_REPLY = 1;
@@ -98,7 +98,7 @@ public class RpcChannel implements Chann
}
} catch ( InterruptedException ix ) {
Thread.currentThread().interrupt();
- }finally {
+ } finally {
responseMap.remove(key);
}
return collector.getResponses();
@@ -127,7 +127,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);
@@ -157,7 +157,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 {
@@ -185,7 +185,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() {
@@ -255,7 +255,7 @@ public class RpcChannel implements Chann
this(key, options, destcnt, 0);
}
- 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
