Add @Override annotation
authorkkolinko <kkolinko@13f79535-47bb-0310-9956-ffa450edef68>
Mon, 4 Jul 2011 14:05:43 +0000 (14:05 +0000)
committerkkolinko <kkolinko@13f79535-47bb-0310-9956-ffa450edef68>
Mon, 4 Jul 2011 14:05:43 +0000 (14:05 +0000)
git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@1142674 13f79535-47bb-0310-9956-ffa450edef68

java/org/apache/catalina/tribes/group/RpcMessage.java
java/org/apache/catalina/tribes/group/interceptors/MessageDispatch15Interceptor.java
java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
java/org/apache/catalina/tribes/group/interceptors/NonBlockingCoordinator.java

index 6c6d6f8..54fe1ad 100644 (file)
@@ -52,6 +52,7 @@ public class RpcMessage implements Externalizable {
         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 Externalizable {
         message = (Serializable)in.readObject();
     }
 
+    @Override
     public void writeExternal(ObjectOutput out) throws IOException {
         out.writeBoolean(reply);
         out.writeInt(uuid.length);
index 0a41a8d..205f644 100644 (file)
@@ -66,6 +66,7 @@ public class MessageDispatch15Interceptor extends MessageDispatchInterceptor {
     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);
             }
index bada1dd..55079a6 100644 (file)
@@ -167,7 +167,8 @@ public class MessageDispatchInterceptor extends ChannelInterceptorBase implement
 
         super.stop(svc);
     }
-    
+
+    @Override
     public void run() {
         while ( run ) {
             LinkObject link = removeFromQueue();
index 4111986..dbfd1fa 100644 (file)
@@ -804,11 +804,13 @@ public class NonBlockingCoordinator extends ChannelInterceptorBase {
             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 extends ChannelInterceptorBase {
             }
         }
         
+        @Override
         public ChannelInterceptor getInterceptor() {
             return interceptor;
         }