Author: markt
Date: Wed Jan 6 17:00:24 2016
New Revision: 1723373
URL: http://svn.apache.org/viewvc?rev=1723373&view=rev
Log:
Remove deprecated code
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
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=1723373&r1=1723372&r2=1723373&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
Wed Jan 6 17:00:24 2016
@@ -40,7 +40,7 @@ import org.apache.juli.logging.LogFactor
* <code>Channel.SEND_OPTIONS_ASYNCHRONOUS</code> flag to be set, if it is, it
* will queue the message for delivery and immediately return to the sender.
*/
-public class MessageDispatchInterceptor extends ChannelInterceptorBase
implements Runnable {
+public class MessageDispatchInterceptor extends ChannelInterceptorBase {
private static final Log log =
LogFactory.getLog(MessageDispatchInterceptor.class);
protected static final StringManager sm =
@@ -250,22 +250,6 @@ public class MessageDispatchInterceptor
}
- /**
- * Deprecated. Unused. Will be removed in 9.0.x
- */
- @Deprecated
- @Override
- public void run() {
- while (run) {
- LinkObject link = removeFromQueue();
- if ( link == null ) continue; //should not happen unless we exceed
wait time
- while ( link != null && run ) {
- link = sendAsyncData(link);
- }
- }
- }
-
-
protected LinkObject sendAsyncData(LinkObject link) {
ChannelMessage msg = link.data();
Member[] destination = link.getDestination();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
