Skip to content

Commit 7795308

Browse files
authored
AMQ-9775: Add the maxBrowsePageSize attribute to the JMX destination MBean (#1500)
1 parent 899f353 commit 7795308

2 files changed

Lines changed: 12 additions & 1 deletion

File tree

activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,6 @@
3131
import jakarta.jms.MessageProducer;
3232
import jakarta.jms.Session;
3333
import java.util.function.Function;
34-
import java.util.function.Supplier;
3534
import javax.management.MalformedObjectNameException;
3635
import javax.management.ObjectName;
3736
import javax.management.openmbean.CompositeData;
@@ -524,6 +523,11 @@ public void setMaxPageSize(int pageSize) {
524523
destination.setMaxPageSize(pageSize);
525524
}
526525

526+
@Override
527+
public int getMaxBrowsePageSize() {
528+
return destination.getMaxBrowsePageSize();
529+
}
530+
527531
@Override
528532
public boolean isUseCache() {
529533
return destination.isUseCache();

activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationViewMBean.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -417,6 +417,13 @@ public String sendTextMessageWithProperties(@MBeanInfo("properties") String prop
417417
*/
418418
public void setMaxPageSize(@MBeanInfo("pageSize") int pageSize);
419419

420+
/**
421+
* @return the maximum number of message to be paged into the
422+
* destination for browsing
423+
*/
424+
@MBeanInfo("Maximum number of messages to be paged in for browsing")
425+
public int getMaxBrowsePageSize();
426+
420427
/**
421428
* @return true if caching is allowed of for the destination
422429
*/

0 commit comments

Comments
 (0)