Author: kfujino Date: Fri Apr 21 06:03:32 2017 New Revision: 1792164 URL: http://svn.apache.org/viewvc?rev=1792164&view=rev Log: Add MBean for MessageDispatchInterceptor.
Added: tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptorMBean.java (with props) Modified: tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java tomcat/trunk/webapps/docs/changelog.xml 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=1792164&r1=1792163&r2=1792164&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 Fri Apr 21 06:03:32 2017 @@ -40,7 +40,8 @@ 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 { +public class MessageDispatchInterceptor extends ChannelInterceptorBase + implements MessageDispatchInterceptorMBean { private static final Log log = LogFactory.getLog(MessageDispatchInterceptor.class); protected static final StringManager sm = @@ -144,7 +145,7 @@ public class MessageDispatchInterceptor this.useDeepClone = useDeepClone; } - + @Override public long getMaxQueueSize() { return maxQueueSize; } @@ -154,7 +155,7 @@ public class MessageDispatchInterceptor return useDeepClone; } - + @Override public long getCurrentSize() { return currentSize.get(); } @@ -170,16 +171,17 @@ public class MessageDispatchInterceptor return value; } - + @Override public long getKeepAliveTime() { return keepAliveTime; } - + @Override public int getMaxSpareThreads() { return maxSpareThreads; } + @Override public int getMaxThreads() { return maxThreads; } @@ -199,7 +201,7 @@ public class MessageDispatchInterceptor this.maxThreads = maxThreads; } - + @Override public boolean isAlwaysSend() { return alwaysSend; } Added: tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptorMBean.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptorMBean.java?rev=1792164&view=auto ============================================================================== --- tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptorMBean.java (added) +++ tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptorMBean.java Fri Apr 21 06:03:32 2017 @@ -0,0 +1,37 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.catalina.tribes.group.interceptors; + +public interface MessageDispatchInterceptorMBean { + + public int getOptionFlag(); + + public boolean isAlwaysSend(); + + public void setAlwaysSend(boolean alwaysSend); + + public long getMaxQueueSize(); + + public long getCurrentSize(); + + public long getKeepAliveTime(); + + public int getMaxSpareThreads(); + + public int getMaxThreads(); + +} Propchange: tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptorMBean.java ------------------------------------------------------------------------------ svn:eol-style = native Modified: tomcat/trunk/webapps/docs/changelog.xml URL: http://svn.apache.org/viewvc/tomcat/trunk/webapps/docs/changelog.xml?rev=1792164&r1=1792163&r2=1792164&view=diff ============================================================================== --- tomcat/trunk/webapps/docs/changelog.xml (original) +++ tomcat/trunk/webapps/docs/changelog.xml Fri Apr 21 06:03:32 2017 @@ -85,8 +85,9 @@ <add> Add JMX support for <code>Channel Interceptors</code>.ãThe Interceptors that implement jmx support are <code>TcpFailureDetector</code>, - <code>ThroughputInterceptor</code>, <code>TcpPingInterceptor</code> and - <code>StaticMembershipInterceptor</code>. (kfujino) + <code>ThroughputInterceptor</code>, <code>TcpPingInterceptor</code>, + <code>StaticMembershipInterceptor</code> and + <code>MessageDispatchInterceptor</code>. (kfujino) </add> </changelog> </subsection> --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org For additional commands, e-mail: dev-h...@tomcat.apache.org