[AMQ-9548] Add attributes to retrieve number of total, non-suppressed and temporary queues and topics

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

@@ -280,11 +280,41 @@ public ObjectName[] getTopics() {
         return safeGetBroker().getTopicsNonSuppressed();
     }
 
+    @Override
+    public int getTotalTopicsCount() {
+        return safeGetBroker().getTopicRegion().getDestinationMap().size();
+    }
+
+    @Override
+    public int getTotalNonSuppressedTopicsCount() {
+        return safeGetBroker().getTopicViews().size();
+    }
+
+    @Override
+    public int getTotalTemporaryTopicsCount() {
+        return safeGetBroker().getTempTopicRegion().getDestinationMap().size();
+    }
+
     @Override
     public ObjectName[] getQueues() {
         return safeGetBroker().getQueuesNonSuppressed();
     }
 
+    @Override
+    public int getTotalQueuesCount() {
+        return safeGetBroker().getQueueRegion().getDestinationMap().size();
+    }
+
+    @Override
+    public int getTotalNonSuppressedQueuesCount() {
+        return safeGetBroker().getQueueViews().size();
+    }
+
+    @Override
+    public int getTotalTemporaryQueuesCount() {
+        return safeGetBroker().getTempQueueRegion().getDestinationMap().size();
+    }
+
     @Override
     public String queryQueues(String filter, int page, int pageSize) throws IOException {
         return DestinationsViewFilter.create(filter)

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

@@ -179,9 +179,27 @@ public interface BrokerViewMBean extends Service {
     @MBeanInfo("Topics (broadcasted 'queues'); generally system information.")
     ObjectName[] getTopics();
 
+    @MBeanInfo("Total number of topics")
+    int getTotalTopicsCount();
+
+    @MBeanInfo("Total number of non suppressed topics")
+    int getTotalNonSuppressedTopicsCount();
+
+    @MBeanInfo("Total number of temporary topics")
+    int getTotalTemporaryTopicsCount();
+
     @MBeanInfo("Standard Queues containing AIE messages.")
     ObjectName[] getQueues();
 
+    @MBeanInfo("Total number of queues")
+    int getTotalQueuesCount();
+
+    @MBeanInfo("Total number of non suppressed queues")
+    int getTotalNonSuppressedQueuesCount();
+
+    @MBeanInfo("Total number of temporary queues")
+    int getTotalTemporaryQueuesCount();
+
     /**
      * Queue Query API, take a look at {@link DestinationsViewFilter} for more information
      */

activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/BrokerViewTest.java

@@ -0,0 +1,74 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.broker.jmx;
+
+import jakarta.jms.*;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.broker.BrokerRegistry;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.util.Wait;
+import org.junit.Test;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+
+public class BrokerViewTest {
+    @Test(timeout=120000)
+    public void testBrokerViewRetrieveQueuesAndTopicsCount() throws Exception {
+        BrokerService brokerService = new BrokerService();
+        brokerService.setPersistent(false);
+        brokerService.start();
+
+        ActiveMQConnectionFactory factory =  new ActiveMQConnectionFactory(BrokerRegistry.getInstance().findFirst().getVmConnectorURI());
+        Connection producerConnection = factory.createConnection();
+        producerConnection.start();
+        // Create non-suppressed queue
+        Session producerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Queue queue = producerSession.createQueue("testQueue");
+        MessageProducer producer = producerSession.createProducer(queue);
+        producer.send(producerSession.createTextMessage("testMessage"));
+        // Create temporary queue
+        Session tempProducerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Queue tempQueue = tempProducerSession.createTemporaryQueue();
+        MessageProducer tempProducer = tempProducerSession.createProducer(tempQueue);
+        tempProducer.send(tempProducerSession.createTextMessage("testMessage"));
+        Session tempProducerSession2 = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Queue tempQueue2 = tempProducerSession2.createTemporaryQueue();
+        MessageProducer tempProducer2 = tempProducerSession2.createProducer(tempQueue2);
+        tempProducer2.send(tempProducerSession2.createTextMessage("testMessage"));
+        // Create non-suppressed topic
+        Session topicProducerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Topic topic = topicProducerSession.createTopic("testTopic");
+        MessageProducer topicProducer = topicProducerSession.createProducer(topic);
+        topicProducer.send(topicProducerSession.createTextMessage("testMessage"));
+        // Create temporary topic
+        Session tempTopicProducerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Topic tempTopic = tempTopicProducerSession.createTemporaryTopic();
+        MessageProducer tempTopicProducer = tempTopicProducerSession.createProducer(tempTopic);
+        tempTopicProducer.send(tempTopicProducerSession.createTextMessage("testMessage"));
+
+        assertTrue(Wait.waitFor(() -> (brokerService.getAdminView()) != null));
+        final BrokerView view = brokerService.getAdminView();
+        assertEquals(view.getTotalTopicsCount(), 12);
+        assertEquals(view.getTotalNonSuppressedTopicsCount(), 12);
+        assertEquals(view.getTotalTemporaryTopicsCount(), 1);
+        assertEquals(view.getTotalQueuesCount(), 1);
+        assertEquals(view.getTotalNonSuppressedQueuesCount(), 1);
+        assertEquals(view.getTotalTemporaryQueuesCount(), 2);
+    }
+}