tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kkoli...@apache.org
Subject svn commit: r1142678 - /tomcat/trunk/java/org/apache/catalina/tribes/group/GroupChannel.java
Date Mon, 04 Jul 2011 14:08:42 GMT
Author: kkolinko
Date: Mon Jul  4 14:08:42 2011
New Revision: 1142678

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

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

Modified: tomcat/trunk/java/org/apache/catalina/tribes/group/GroupChannel.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/GroupChannel.java?rev=1142678&r1=1142677&r2=1142678&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/group/GroupChannel.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/group/GroupChannel.java Mon Jul  4 14:08:42
2011
@@ -126,6 +126,7 @@ public class GroupChannel extends Channe
      * <code>Channel -> A -> C -> B -> ChannelCoordinator</code><br>
      * @param interceptor ChannelInterceptorBase
      */
+    @Override
     public void addInterceptor(ChannelInterceptor interceptor) {
         if ( interceptors == null ) {
             interceptors = interceptor;
@@ -176,6 +177,7 @@ public class GroupChannel extends Channe
      * @throws ChannelException - if an error occurs processing the message
      * @see org.apache.catalina.tribes.Channel
      */
+    @Override
     public UniqueId send(Member[] destination, Serializable msg, int options) throws ChannelException
{
         return send(destination,msg,options,null);
     }
@@ -192,6 +194,7 @@ public class GroupChannel extends Channe
      * @throws ChannelException - if an error occurs processing the message
      * @see org.apache.catalina.tribes.Channel
      */
+    @Override
     public UniqueId send(Member[] destination, Serializable msg, int options, ErrorHandler
handler) throws ChannelException {
         if ( msg == null ) throw new ChannelException("Cant send a NULL message");
         XByteBuffer buffer = null;
@@ -448,6 +451,7 @@ public class GroupChannel extends Channe
      * Returns the channel receiver component
      * @return ChannelReceiver
      */
+    @Override
     public ChannelReceiver getChannelReceiver() {
         return coordinator.getClusterReceiver();
     }
@@ -456,6 +460,7 @@ public class GroupChannel extends Channe
      * Returns the channel sender component
      * @return ChannelSender
      */
+    @Override
     public ChannelSender getChannelSender() {
         return coordinator.getClusterSender();
     }
@@ -464,6 +469,7 @@ public class GroupChannel extends Channe
      * Returns the membership service component
      * @return MembershipService
      */
+    @Override
     public MembershipService getMembershipService() {
         return coordinator.getMembershipService();
     }
@@ -472,6 +478,7 @@ public class GroupChannel extends Channe
      * Sets the channel receiver component
      * @param clusterReceiver ChannelReceiver
      */
+    @Override
     public void setChannelReceiver(ChannelReceiver clusterReceiver) {
         coordinator.setClusterReceiver(clusterReceiver);
     }
@@ -480,6 +487,7 @@ public class GroupChannel extends Channe
      * Sets the channel sender component
      * @param clusterSender ChannelSender
      */
+    @Override
     public void setChannelSender(ChannelSender clusterSender) {
         coordinator.setClusterSender(clusterSender);
     }
@@ -488,6 +496,7 @@ public class GroupChannel extends Channe
      * Sets the membership component
      * @param membershipService MembershipService
      */
+    @Override
     public void setMembershipService(MembershipService membershipService) {
         coordinator.setMembershipService(membershipService);
     }
@@ -497,6 +506,7 @@ public class GroupChannel extends Channe
      * Membership listeners are uniquely identified using the equals(Object) method
      * @param membershipListener MembershipListener
      */
+    @Override
     public void addMembershipListener(MembershipListener membershipListener) {
         if (!this.membershipListeners.contains(membershipListener) )
             this.membershipListeners.add(membershipListener);
@@ -508,6 +518,7 @@ public class GroupChannel extends Channe
      * @param membershipListener MembershipListener
      */
 
+    @Override
     public void removeMembershipListener(MembershipListener membershipListener) {
         membershipListeners.remove(membershipListener);
     }
@@ -517,6 +528,7 @@ public class GroupChannel extends Channe
      * Channel listeners are uniquely identified using the equals(Object) method
      * @param channelListener ChannelListener
      */
+    @Override
     public void addChannelListener(ChannelListener channelListener) {
         if (!this.channelListeners.contains(channelListener) ) {
             this.channelListeners.add(channelListener);
@@ -531,6 +543,7 @@ public class GroupChannel extends Channe
      * Channel listeners are uniquely identified using the equals(Object) method
      * @param channelListener ChannelListener
      */
+    @Override
     public void removeChannelListener(ChannelListener channelListener) {
         channelListeners.remove(channelListener);
     }
@@ -539,6 +552,7 @@ public class GroupChannel extends Channe
      * Returns an iterator of all the interceptors in this stack
      * @return Iterator
      */
+    @Override
     public Iterator<ChannelInterceptor> getInterceptors() {
         return new InterceptorIterator(this.getNext(),this.coordinator);
     }
@@ -569,6 +583,7 @@ public class GroupChannel extends Channe
      * thread to invoke <code>Channel.heartbeat()</code> every <code>getHeartbeatSleeptime</code>
milliseconds
      * @param heartbeat boolean
      */
+    @Override
     public void setHeartbeat(boolean heartbeat) {
         this.heartbeat = heartbeat;
     }
@@ -614,10 +629,12 @@ public class GroupChannel extends Channe
             this.start = start;
         }
 
+        @Override
         public boolean hasNext() {
             return start!=null && start != end;
         }
 
+        @Override
         public ChannelInterceptor next() {
             ChannelInterceptor result = null;
             if ( hasNext() ) {
@@ -627,6 +644,7 @@ public class GroupChannel extends Channe
             return result;
         }
 
+        @Override
         public void remove() {
             //empty operation
         }



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


Mime
View raw message