From 4b30f60e7b46ea6ce594b7d549c07502349226ae Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?JB=20Onofr=C3=A9?= Date: Thu, 25 Sep 2025 15:04:19 +0200 Subject: [PATCH] AMQ-9775: Add the maxBrowsePageSize attribute to the JMX destination MBean --- .../apache/activemq/broker/jmx/DestinationView.java | 11 ++++++++++- .../activemq/broker/jmx/DestinationViewMBean.java | 13 +++++++++++++ 2 files changed, 23 insertions(+), 1 deletion(-) diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java index 2386d4ba106..c18a283edba 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java @@ -31,7 +31,6 @@ import jakarta.jms.MessageProducer; import jakarta.jms.Session; import java.util.function.Function; -import java.util.function.Supplier; import javax.management.MalformedObjectNameException; import javax.management.ObjectName; import javax.management.openmbean.CompositeData; @@ -524,6 +523,16 @@ public void setMaxPageSize(int pageSize) { destination.setMaxPageSize(pageSize); } + @Override + public int getMaxBrowsePageSize() { + return destination.getMaxBrowsePageSize(); + } + + @Override + public void setMaxBrowsePageSize(int browsePageSize) { + destination.setMaxBrowsePageSize(browsePageSize); + } + @Override public boolean isUseCache() { return destination.isUseCache(); diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationViewMBean.java b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationViewMBean.java index 1100bd3a984..c6c4151f8b3 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationViewMBean.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationViewMBean.java @@ -417,6 +417,19 @@ public String sendTextMessageWithProperties(@MBeanInfo("properties") String prop */ public void setMaxPageSize(@MBeanInfo("pageSize") int pageSize); + /** + * @return the maximum number of message to be paged into the + * destination for browsing + */ + @MBeanInfo("Maximum number of messages to be paged in for browsing") + public int getMaxBrowsePageSize(); + + /** + * @param browsePageSize + * Set the maximum number of messages to page in the destination for browsing + */ + public void setMaxBrowsePageSize(@MBeanInfo("browsePageSize") int browsePageSize); + /** * @return true if caching is allowed of for the destination */