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 */