Author: markt
Date: Tue Jul 5 19:20:12 2016
New Revision: 1751535
URL: http://svn.apache.org/viewvc?rev=1751535&view=rev
Log:
Align 9.0.x and 8.5.x.
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/StaticMembershipInterceptor.java
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java?rev=1751535&r1=1751534&r2=1751535&view=diff
==============================================================================
---
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
(original)
+++
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
Tue Jul 5 19:20:12 2016
@@ -93,8 +93,8 @@ public class MessageDispatchInterceptor
}
- public boolean addToQueue(ChannelMessage msg, Member[] destination,
- InterceptorPayload payload) {
+ public boolean addToQueue(final ChannelMessage msg, final Member[]
destination,
+ final InterceptorPayload payload) {
Runnable r = new Runnable() {
@Override
public void run() {
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/StaticMembershipInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/StaticMembershipInterceptor.java?rev=1751535&r1=1751534&r2=1751535&view=diff
==============================================================================
---
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/StaticMembershipInterceptor.java
(original)
+++
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/StaticMembershipInterceptor.java
Tue Jul 5 19:20:12 2016
@@ -155,7 +155,7 @@ public class StaticMembershipInterceptor
if ( (Channel.SND_RX_SEQ&svc)==Channel.SND_RX_SEQ )
super.start(Channel.SND_RX_SEQ);
if ( (Channel.SND_TX_SEQ&svc)==Channel.SND_TX_SEQ )
super.start(Channel.SND_TX_SEQ);
final ChannelInterceptorBase base = this;
- for (Member member : members) {
+ for (final Member member : members) {
Thread t = new Thread() {
@Override
public void run() {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
