svn commit: r1792164 - in /tomcat/trunk: java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptorMBean.java webapps/docs/changelog.xml

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

svn commit: r1792164 - in /tomcat/trunk: java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptorMBean.java webapps/docs/changelog.xml

kfujino
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: [hidden email]
For additional commands, e-mail: [hidden email]

Loading...