This is an automated email from the ASF dual-hosted git repository.
mattrpav pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/main by this push:
new 9f374dfcb [AMQ-9301] Add additional fields to
o.a.activemq.broker.jmx.Connection
9f374dfcb is described below
commit 9f374dfcb50729693ae1ee55d58bfea27fef1c0a
Author: Matt Pavlovich <[email protected]>
AuthorDate: Tue Aug 22 16:26:00 2023 -0500
[AMQ-9301] Add additional fields to o.a.activemq.broker.jmx.Connection
---
.../org/apache/activemq/broker/jmx/ConnectionView.java | 15 +++++++++++++++
.../apache/activemq/broker/jmx/ConnectionViewMBean.java | 17 +++++++++++++++++
2 files changed, 32 insertions(+)
diff --git
a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
index 880790dfa..937b4c079 100644
---
a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
+++
b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
@@ -176,4 +176,19 @@ public class ConnectionView implements ConnectionViewMBean
{
public Long getOldestActiveTransactionDuration() {
return connection.getOldestActiveTransactionDuration();
}
+
+ @Override
+ public boolean isFaultTolerantConnection() {
+ return connection.isFaultTolerantConnection();
+ }
+
+ @Override
+ public boolean isManageable() {
+ return connection.isManageable();
+ }
+
+ @Override
+ public boolean isNetworkConnection() {
+ return connection.isNetworkConnection();
+ }
}
diff --git
a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
index cd1210ae1..a0e399a13 100644
---
a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
+++
b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
@@ -116,4 +116,21 @@ public interface ConnectionViewMBean extends Service {
@MBeanInfo("The age in ms of the oldest active transaction established on
this Connection.")
public Long getOldestActiveTransactionDuration();
+ /**
+ * @return true if the Connection is fault tolerant
+ */
+ @MBeanInfo("Connection is fault tolerant.")
+ boolean isFaultTolerantConnection();
+
+ /**
+ * @return true if the Connection is manageable
+ */
+ @MBeanInfo("Connection is manageable.")
+ boolean isManageable();
+
+ /**
+ * @return true if the Connection is a network connection
+ */
+ @MBeanInfo("Connection is a network connection.")
+ boolean isNetworkConnection();
}