svn commit: r1142674 - in /tomcat/trunk/java/org/apache/catalina/tribes/group: RpcMessage.java interceptors/MessageDispatch15Interceptor.java interceptors/MessageDispatchInterceptor.java interceptors/NonBlockingCoordinator.java

[kkolinko]

Author: kkolinko
Date: Mon Jul  4 14:05:43 2011
New Revision: 1142674

URL: http://svn.apache.org/viewvc?rev=1142674&view=rev
Log:
Add @Override annotation

Modified:
    tomcat/trunk/java/org/apache/catalina/tribes/group/RpcMessage.java
    
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatch15Interceptor.java
    
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
    
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/NonBlockingCoordinator.java

Modified: tomcat/trunk/java/org/apache/catalina/tribes/group/RpcMessage.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/RpcMessage.java?rev=1142674&r1=1142673&r2=1142674&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/group/RpcMessage.java 
(original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/group/RpcMessage.java Mon Jul  
4 14:05:43 2011
@@ -52,6 +52,7 @@ public class RpcMessage implements Exter
         this.message = message;
     }
 
+    @Override
     public void readExternal(ObjectInput in) throws 
IOException,ClassNotFoundException {
         reply = in.readBoolean();
         int length = in.readInt();
@@ -63,6 +64,7 @@ public class RpcMessage implements Exter
         message = (Serializable)in.readObject();
     }
 
+    @Override
     public void writeExternal(ObjectOutput out) throws IOException {
         out.writeBoolean(reply);
         out.writeInt(uuid.length);

Modified: 
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatch15Interceptor.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatch15Interceptor.java?rev=1142674&r1=1142673&r2=1142674&view=diff
==============================================================================
--- 
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatch15Interceptor.java
 (original)
+++ 
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatch15Interceptor.java
 Mon Jul  4 14:05:43 2011
@@ -66,6 +66,7 @@ public class MessageDispatch15Intercepto
     public boolean addToQueue(ChannelMessage msg, Member[] destination, 
InterceptorPayload payload) {
         final LinkObject obj = new LinkObject(msg,destination,payload);
         Runnable r = new Runnable() {
+            @Override
             public void run() {
                 sendAsyncData(obj);
             }

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=1142674&r1=1142673&r2=1142674&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
 Mon Jul  4 14:05:43 2011
@@ -167,7 +167,8 @@ public class MessageDispatchInterceptor 
 
         super.stop(svc);
     }
-    
+
+    @Override
     public void run() {
         while ( run ) {
             LinkObject link = removeFromQueue();

Modified: 
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/NonBlockingCoordinator.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/NonBlockingCoordinator.java?rev=1142674&r1=1142673&r2=1142674&view=diff
==============================================================================
--- 
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/NonBlockingCoordinator.java
 (original)
+++ 
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/NonBlockingCoordinator.java
 Mon Jul  4 14:05:43 2011
@@ -804,11 +804,13 @@ public class NonBlockingCoordinator exte
             this.view = ((NonBlockingCoordinator)interceptor).view;
             this.suggestedView = 
((NonBlockingCoordinator)interceptor).suggestedView;
         }
-        
+
+        @Override
         public int getEventType() {
             return type;
         }
-        
+
+        @Override
         public String getEventTypeDesc() {
             switch (type) {
                 case  EVT_START: return "EVT_START:"+info;
@@ -828,6 +830,7 @@ public class NonBlockingCoordinator exte
             }
         }
         
+        @Override
         public ChannelInterceptor getInterceptor() {
             return interceptor;
         }



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