You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by kk...@apache.org on 2011/07/04 15:59:53 UTC
svn commit: r1142670 - in /tomcat/trunk/java/org/apache/catalina/tribes:
membership/MemberImpl.java transport/ReceiverBase.java
Author: kkolinko
Date: Mon Jul 4 13:59:53 2011
New Revision: 1142670
URL: http://svn.apache.org/viewvc?rev=1142670&view=rev
Log:
Add @Override annotation
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/membership/MemberImpl.java
tomcat/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java
Modified: tomcat/trunk/java/org/apache/catalina/tribes/membership/MemberImpl.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/membership/MemberImpl.java?rev=1142670&r1=1142669&r2=1142670&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/membership/MemberImpl.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/membership/MemberImpl.java Mon Jul 4 13:59:53 2011
@@ -142,12 +142,15 @@ public class MemberImpl implements Membe
setPayload(payload);
}
+ @Override
public boolean isReady() {
return SenderState.getSenderState(this).isReady();
}
+ @Override
public boolean isSuspect() {
return SenderState.getSenderState(this).isSuspect();
}
+ @Override
public boolean isFailing() {
return SenderState.getSenderState(this).isFailing();
}
@@ -423,6 +426,7 @@ public class MemberImpl implements Membe
* Return the name of this object
* @return a unique name to the cluster
*/
+ @Override
public String getName() {
return "tcp://"+getHostname()+":"+getPort();
}
@@ -431,6 +435,7 @@ public class MemberImpl implements Membe
* Return the listen port of this member
* @return - tcp listen port
*/
+ @Override
public int getPort() {
return this.port;
}
@@ -439,6 +444,7 @@ public class MemberImpl implements Membe
* Return the TCP listen host for this member
* @return IP address or host name
*/
+ @Override
public byte[] getHost() {
return host;
}
@@ -464,6 +470,7 @@ public class MemberImpl implements Membe
* broadcasting its membership to the cluster.
* @return nr of milliseconds since this member started.
*/
+ @Override
public long getMemberAliveTime() {
return memberAliveTime;
}
@@ -472,26 +479,32 @@ public class MemberImpl implements Membe
return serviceStartTime;
}
+ @Override
public byte[] getUniqueId() {
return uniqueId;
}
+ @Override
public byte[] getPayload() {
return payload;
}
+ @Override
public byte[] getCommand() {
return command;
}
+ @Override
public byte[] getDomain() {
return domain;
}
+ @Override
public int getSecurePort() {
return securePort;
}
+ @Override
public int getUdpPort() {
return udpPort;
}
@@ -619,6 +632,7 @@ public class MemberImpl implements Membe
this.dataPkg = null;
}
+ @Override
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
int length = in.readInt();
byte[] message = new byte[length];
@@ -627,6 +641,7 @@ public class MemberImpl implements Membe
}
+ @Override
public void writeExternal(ObjectOutput out) throws IOException {
byte[] data = this.getData();
out.writeInt(data.length);
Modified: tomcat/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java?rev=1142670&r1=1142669&r2=1142670&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java Mon Jul 4 13:59:53 2011
@@ -89,6 +89,7 @@ public abstract class ReceiverBase imple
public ReceiverBase() {
}
+ @Override
public void start() throws IOException {
if ( executor == null ) {
//executor = new ThreadPoolExecutor(minThreads,maxThreads,60,TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>());
@@ -97,6 +98,7 @@ public abstract class ReceiverBase imple
}
}
+ @Override
public void stop() {
if ( executor != null ) executor.shutdownNow();//ignore left overs
executor = null;
@@ -108,6 +110,7 @@ public abstract class ReceiverBase imple
* @return MessageListener
* TODO Implement this org.apache.catalina.tribes.ChannelReceiver method
*/
+ @Override
public MessageListener getMessageListener() {
return listener;
}
@@ -117,6 +120,7 @@ public abstract class ReceiverBase imple
* @return The port
* TODO Implement this org.apache.catalina.tribes.ChannelReceiver method
*/
+ @Override
public int getPort() {
return port;
}
@@ -144,6 +148,7 @@ public abstract class ReceiverBase imple
* @param listener MessageListener
* TODO Implement this org.apache.catalina.tribes.ChannelReceiver method
*/
+ @Override
public void setMessageListener(MessageListener listener) {
this.listener = listener;
}
@@ -274,6 +279,7 @@ public abstract class ReceiverBase imple
}
+ @Override
public void messageDataReceived(ChannelMessage data) {
if ( this.listener != null ) {
if ( listener.accept(data) ) listener.messageReceived(data);
@@ -320,6 +326,7 @@ public abstract class ReceiverBase imple
return this.host;
}
+ @Override
public String getHost() {
return getAddress();
}
@@ -406,6 +413,7 @@ public abstract class ReceiverBase imple
return useBufferPool;
}
+ @Override
public int getSecurePort() {
return securePort;
}
@@ -529,10 +537,12 @@ public abstract class ReceiverBase imple
this.executor = executor;
}
+ @Override
public void heartbeat() {
//empty operation
}
+ @Override
public int getUdpPort() {
return udpPort;
}
@@ -569,6 +579,7 @@ public abstract class ReceiverBase imple
this.namePrefix = namePrefix;
}
+ @Override
public Thread newThread(Runnable r) {
Thread t = new Thread(group, r, namePrefix + threadNumber.getAndIncrement());
t.setDaemon(daemon);
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org