svn commit: r381645 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java

[ra...@apache.org]

Author: rajdavies
Date: Tue Feb 28 04:55:57 2006
New Revision: 381645

URL: http://svn.apache.org/viewcvs?rev=381645&view=rev
Log:
Added support for browsing Topics

Added:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java

Added: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java?rev=381645&view=auto
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java (added)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java Tue Feb 28 04:55:57 2006
@@ -0,0 +1,87 @@
+/**
+ * 
+ * Copyright 2005-2006 The Apache Software Foundation
+ * 
+ * Licensed 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 javax.management.openmbean.CompositeData;
+import javax.management.openmbean.CompositeDataSupport;
+import javax.management.openmbean.CompositeType;
+import javax.management.openmbean.OpenDataException;
+import javax.management.openmbean.TabularData;
+import javax.management.openmbean.TabularDataSupport;
+import javax.management.openmbean.TabularType;
+import org.apache.activemq.broker.jmx.OpenTypeSupport.OpenTypeFactory;
+import org.apache.activemq.broker.region.Destination;
+import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.Message;
+
+public class DestinationView {
+    protected final Destination destination;
+
+    public DestinationView(Destination destination){
+        this.destination=destination;
+    }
+
+    public void gc(){
+        destination.gc();
+    }
+
+    public void resetStatistics(){
+        destination.getDestinationStatistics().reset();
+    }
+
+    public long getEnqueueCount(){
+        return destination.getDestinationStatistics().getEnqueues().getCount();
+    }
+
+    public long getDequeueCount(){
+        return destination.getDestinationStatistics().getDequeues().getCount();
+    }
+
+    public long getConsumerCount(){
+        return destination.getDestinationStatistics().getConsumers().getCount();
+    }
+
+    public long getMessages(){
+        return destination.getDestinationStatistics().getMessages().getCount();
+    }
+
+    public long getMessagesCached(){
+        return destination.getDestinationStatistics().getMessagesCached().getCount();
+    }
+
+    public CompositeData[] browse() throws OpenDataException{
+        Message[] messages=destination.browse();
+        CompositeData c[]=new CompositeData[messages.length];
+        for(int i=0;i<c.length;i++){
+            try{
+                c[i]=OpenTypeSupport.convert(messages[i]);
+            }catch(Throwable e){
+                e.printStackTrace();
+            }
+        }
+        return c;
+    }
+
+    public TabularData browseAsTable() throws OpenDataException{
+        OpenTypeFactory factory=OpenTypeSupport.getFactory(ActiveMQMessage.class);
+        Message[] messages=destination.browse();
+        CompositeType ct=factory.getCompositeType();
+        TabularType tt=new TabularType("MessageList","MessageList",ct,new String[] { "JMSMessageID" });
+        TabularDataSupport rc=new TabularDataSupport(tt);
+        for(int i=0;i<messages.length;i++){
+            rc.put(new CompositeDataSupport(ct,factory.getFields(messages[i])));
+        }
+        return rc;
+    }
+}