From: kkolinko Date: Mon, 4 Jul 2011 14:08:42 +0000 (+0000) Subject: Add @Override annotation X-Git-Url: https://git.internetallee.de/?a=commitdiff_plain;h=b81f55578e73c5c4d43fe1403ba4b1c0b5381db1;p=tomcat7.0 Add @Override annotation git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@1142678 13f79535-47bb-0310-9956-ffa450edef68 --- diff --git a/java/org/apache/catalina/tribes/group/GroupChannel.java b/java/org/apache/catalina/tribes/group/GroupChannel.java index 935ad4a46..0e3271511 100644 --- a/java/org/apache/catalina/tribes/group/GroupChannel.java +++ b/java/org/apache/catalina/tribes/group/GroupChannel.java @@ -126,6 +126,7 @@ public class GroupChannel extends ChannelInterceptorBase implements ManagedChann * Channel -> A -> C -> B -> ChannelCoordinator
* @param interceptor ChannelInterceptorBase */ + @Override public void addInterceptor(ChannelInterceptor interceptor) { if ( interceptors == null ) { interceptors = interceptor; @@ -176,6 +177,7 @@ public class GroupChannel extends ChannelInterceptorBase implements ManagedChann * @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 ChannelInterceptorBase implements ManagedChann * @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 ChannelInterceptorBase implements ManagedChann * Returns the channel receiver component * @return ChannelReceiver */ + @Override public ChannelReceiver getChannelReceiver() { return coordinator.getClusterReceiver(); } @@ -456,6 +460,7 @@ public class GroupChannel extends ChannelInterceptorBase implements ManagedChann * Returns the channel sender component * @return ChannelSender */ + @Override public ChannelSender getChannelSender() { return coordinator.getClusterSender(); } @@ -464,6 +469,7 @@ public class GroupChannel extends ChannelInterceptorBase implements ManagedChann * Returns the membership service component * @return MembershipService */ + @Override public MembershipService getMembershipService() { return coordinator.getMembershipService(); } @@ -472,6 +478,7 @@ public class GroupChannel extends ChannelInterceptorBase implements ManagedChann * 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 ChannelInterceptorBase implements ManagedChann * 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 ChannelInterceptorBase implements ManagedChann * Sets the membership component * @param membershipService MembershipService */ + @Override public void setMembershipService(MembershipService membershipService) { coordinator.setMembershipService(membershipService); } @@ -497,6 +506,7 @@ public class GroupChannel extends ChannelInterceptorBase implements ManagedChann * 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 ChannelInterceptorBase implements ManagedChann * @param membershipListener MembershipListener */ + @Override public void removeMembershipListener(MembershipListener membershipListener) { membershipListeners.remove(membershipListener); } @@ -517,6 +528,7 @@ public class GroupChannel extends ChannelInterceptorBase implements ManagedChann * 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 ChannelInterceptorBase implements ManagedChann * 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 ChannelInterceptorBase implements ManagedChann * Returns an iterator of all the interceptors in this stack * @return Iterator */ + @Override public Iterator getInterceptors() { return new InterceptorIterator(this.getNext(),this.coordinator); } @@ -569,6 +583,7 @@ public class GroupChannel extends ChannelInterceptorBase implements ManagedChann * thread to invoke Channel.heartbeat() every getHeartbeatSleeptime milliseconds * @param heartbeat boolean */ + @Override public void setHeartbeat(boolean heartbeat) { this.heartbeat = heartbeat; } @@ -614,10 +629,12 @@ public class GroupChannel extends ChannelInterceptorBase implements ManagedChann 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 ChannelInterceptorBase implements ManagedChann return result; } + @Override public void remove() { //empty operation }