(activemq) branch main updated: [AMQ-9623] Update ConnectionView to include WireFormatInfo

[mattrpav]

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 bb4c8aac66 [AMQ-9623] Update ConnectionView to include WireFormatInfo
bb4c8aac66 is described below

commit bb4c8aac66c79ab46e5cabf332cbf6f63ba61307
Author: Matt Pavlovich <mattr...@apache.org>
AuthorDate: Fri Nov 15 10:14:59 2024 -0600

    [AMQ-9623] Update ConnectionView to include WireFormatInfo
---
 .../main/java/org/apache/activemq/broker/jmx/ConnectionView.java | 9 +++++++++
 .../java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java | 7 +++++++
 2 files changed, 16 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 48beb6ce53..593c4f999e 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
@@ -22,6 +22,7 @@ import java.util.Set;
 import javax.management.ObjectName;
 
 import org.apache.activemq.broker.Connection;
+import org.apache.activemq.broker.TransportConnection;
 import org.apache.activemq.util.IOExceptionSupport;
 
 public class ConnectionView implements ConnectionViewMBean {
@@ -196,4 +197,12 @@ public class ConnectionView implements ConnectionViewMBean 
{
     public long getConnectedTimestamp() {
         return connection.getConnectedTimestamp();
     }
+
+    @Override
+    public String getWireFormatInfo() {
+        if(connection instanceof TransportConnection) {
+            return 
((TransportConnection)connection).getRemoteWireFormatInfo().toString();
+        }
+        return "WireFormatInfo not available";
+    }
 }
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 1013a8e8ba..77eb188f5d 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
@@ -139,4 +139,11 @@ public interface ConnectionViewMBean extends Service {
      */
     @MBeanInfo("Time in ms since epoch when connection was established.")
     long getConnectedTimestamp();
+
+    /**
+     * @return the WireFormatInfo information
+     */
+    @MBeanInfo("WireFormatInfo for the connection")
+    public String getWireFormatInfo();
+
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@activemq.apache.org
For additional commands, e-mail: commits-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact