public class org.apache.activemq.plugin.StatisticsBroker extends org.apache.activemq.broker.BrokerFilter { private static org.slf4j.Logger LOG; static final java.lang.String STATS_PREFIX; static final java.lang.String STATS_DESTINATION_PREFIX; static final java.lang.String STATS_BROKER_PREFIX; static final java.lang.String STATS_BROKER_RESET_HEADER; static final java.lang.String STATS_SUBSCRIPTION_PREFIX; static final java.lang.String STATS_DENOTE_END_LIST; static final java.lang.String STATS_FIRST_MESSAGE_TIMESTAMP; private static final org.apache.activemq.util.IdGenerator ID_GENERATOR; private final org.apache.activemq.util.LongSequenceGenerator messageIdGenerator; protected final org.apache.activemq.command.ProducerId advisoryProducerId; protected org.apache.activemq.broker.jmx.BrokerViewMBean brokerView; public void (org.apache.activemq.broker.Broker) { org.apache.activemq.command.ProducerId v, v; org.apache.activemq.broker.Broker v; org.apache.activemq.util.LongSequenceGenerator v; org.apache.activemq.util.IdGenerator v; java.lang.String v; org.apache.activemq.plugin.StatisticsBroker v; v := @this: org.apache.activemq.plugin.StatisticsBroker; v := @parameter: org.apache.activemq.broker.Broker; specialinvoke v.(org.apache.activemq.broker.Broker)>(v); v = new org.apache.activemq.util.LongSequenceGenerator; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.command.ProducerId; specialinvoke v.()>(); v. = v; v = v.; v = ; v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v, v, v, v, v; org.apache.activemq.command.Message v; byte v; java.util.Map v, v, v, v, v, v, v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.management.TimeStatisticImpl v, v, v, v, v, v; org.apache.activemq.broker.region.Destination v; long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.jmx.BrokerViewMBean v, v, v; org.apache.activemq.usage.StoreUsage v, v, v; org.apache.activemq.usage.MemoryUsage v, v, v, v, v, v; org.apache.activemq.command.ActiveMQDestination v, v, v, v; javax.management.ObjectName[] v, v; int v, v, v, v, v; org.apache.activemq.management.SizeStatisticImpl v, v; org.apache.activemq.command.BrokerId v, v; java.lang.Object v, v, v, v, v, v; org.apache.activemq.usage.TempUsage v, v, v; org.apache.activemq.broker.BrokerService v; java.util.Set v; org.apache.activemq.management.PollCountStatisticImpl v, v; org.apache.activemq.broker.ProducerBrokerExchange v; java.util.ArrayList v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.ActiveMQMapMessage v, v, v; java.io.File v; org.apache.activemq.management.CountStatisticImpl v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.net.URI v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.DestinationStatistics v, v; double v, v, v, v; java.util.Iterator v; org.apache.activemq.plugin.StatisticsBroker v; v := @this: org.apache.activemq.plugin.StatisticsBroker; v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange; v := @parameter: org.apache.activemq.command.Message; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.("ActiveMQ.Statistics"); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.("ActiveMQ.Statistics.Destination"); v = virtualinvoke v.("ActiveMQ.Statistics.Broker"); v = virtualinvoke v.("ActiveMQ.Statistics.Subscription"); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = "ActiveMQ.Statistics.Destination"; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.("."); if v == 0 goto label; v = virtualinvoke v.(1); label: v = virtualinvoke v.("ActiveMQ.Statistics.Destination.List.End.With.Null", ""); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.("ActiveMQ.Statistics.Destination.List.End.With.Null"); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: v = v; v = virtualinvoke v.(); v = staticinvoke (v, v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.("ActiveMQ.Statistics.Destination.Include.First.Message.Timestamp"); if v == 0 goto label; v = new java.util.ArrayList; specialinvoke v.(int)>(1); goto label; label: v = null; label: v = v; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == null goto label; v = new org.apache.activemq.command.ActiveMQMapMessage; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.("brokerName", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("brokerId", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("destinationName", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("size", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("enqueueCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("dequeueCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("dispatchCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("expiredCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("inflightCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("messagesCached", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("averageMessageSize", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("memoryPercentUsage", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("memoryUsage", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("memoryLimit", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("averageEnqueueTime", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("maxEnqueueTime", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("minEnqueueTime", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("consumerCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("producerCount", v); if v == 0 goto label; v = v instanceof org.apache.activemq.broker.region.Queue; if v == 0 goto label; virtualinvoke v.(v, 1); goto label; label: v = v instanceof org.apache.activemq.broker.region.Topic; if v == 0 goto label; virtualinvoke v.(v, 1); label: v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(0); v = virtualinvoke v.(); virtualinvoke v.("firstMessageTimestamp", v); interfaceinvoke v.(); label: v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: if v == 0 goto label; v = new org.apache.activemq.command.ActiveMQMapMessage; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: if v == 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.("ActiveMQ.Statistics.Broker.Reset"); if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(); label: v = new org.apache.activemq.command.ActiveMQMapMessage; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("brokerName", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("brokerId", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("size", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("enqueueCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("dequeueCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("dispatchCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("expiredCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("inflightCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("averageMessageSize", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("messagesCached", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("memoryPercentUsage", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("memoryUsage", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("memoryLimit", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("storePercentUsage", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("storeUsage", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("storeLimit", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("tempPercentUsage", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("tempUsage", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("tempLimit", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("averageEnqueueTime", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("maxEnqueueTime", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("minEnqueueTime", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("consumerCount", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("producerCount", v); v = virtualinvoke v.(); v = interfaceinvoke v.("tcp"); if v == null goto label; v = v; goto label; label: v = ""; label: virtualinvoke v.("openwire", v); v = virtualinvoke v.(); v = interfaceinvoke v.("stomp"); if v == null goto label; v = v; goto label; label: v = ""; label: virtualinvoke v.("stomp", v); v = virtualinvoke v.(); v = interfaceinvoke v.("ssl"); if v == null goto label; v = v; goto label; label: v = ""; label: virtualinvoke v.("ssl", v); v = virtualinvoke v.(); v = interfaceinvoke v.("stomp+ssl"); if v == null goto label; v = v; goto label; label: v = ""; label: virtualinvoke v.("stomp+ssl", v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = ""; label: virtualinvoke v.("vm", v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = ""; label: virtualinvoke v.("dataDirectory", v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: specialinvoke v.(v, v); goto label; label: specialinvoke v.(v, v); label: return; } org.apache.activemq.broker.jmx.BrokerViewMBean getBrokerView() throws java.lang.Exception { org.apache.activemq.broker.BrokerService v, v; javax.management.ObjectName v; org.apache.activemq.broker.jmx.BrokerViewMBean v, v; org.apache.activemq.broker.jmx.ManagementContext v; java.lang.Object v; org.apache.activemq.plugin.StatisticsBroker v; v := @this: org.apache.activemq.plugin.StatisticsBroker; v = v.; if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, class "Lorg/apache/activemq/broker/jmx/BrokerViewMBean;", 1); v. = v; label: v = v.; return v; } public void start() throws java.lang.Exception { org.slf4j.Logger v; org.apache.activemq.plugin.StatisticsBroker v; v := @this: org.apache.activemq.plugin.StatisticsBroker; specialinvoke v.(); v = ; interfaceinvoke v.("Starting StatisticsBroker"); return; } public void stop() throws java.lang.Exception { org.apache.activemq.plugin.StatisticsBroker v; v := @this: org.apache.activemq.plugin.StatisticsBroker; specialinvoke v.(); return; } protected void sendSubStats(org.apache.activemq.broker.ConnectionContext, javax.management.ObjectName[], org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception { org.apache.activemq.broker.BrokerService v; org.apache.activemq.command.ActiveMQMapMessage v; javax.management.ObjectName v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.jmx.ManagementContext v; int v, v; java.lang.Object v; javax.management.ObjectName[] v; org.apache.activemq.plugin.StatisticsBroker v; v := @this: org.apache.activemq.plugin.StatisticsBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: javax.management.ObjectName[]; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = 0; label: v = lengthof v; if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, class "Lorg/apache/activemq/broker/jmx/SubscriptionViewMBean;", 1); v = virtualinvoke v.(v); virtualinvoke v.(v, v, v); v = v + 1; goto label; label: return; } protected org.apache.activemq.command.ActiveMQMapMessage prepareSubscriptionMessage(org.apache.activemq.broker.jmx.SubscriptionViewMBean) throws javax.jms.JMSException { long v, v, v, v; org.apache.activemq.broker.jmx.SubscriptionViewMBean v; org.apache.activemq.broker.Broker v; int v, v, v; java.lang.String v, v, v, v, v, v; boolean v, v, v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.command.ActiveMQMapMessage v; org.apache.activemq.command.BrokerId v; org.apache.activemq.plugin.StatisticsBroker v; v := @this: org.apache.activemq.plugin.StatisticsBroker; v := @parameter: org.apache.activemq.broker.jmx.SubscriptionViewMBean; v = virtualinvoke v.(); v = virtualinvoke v.(); v = new org.apache.activemq.command.ActiveMQMapMessage; specialinvoke v.()>(); v = interfaceinvoke v.(); virtualinvoke v.("brokerName", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("brokerId", v); v = interfaceinvoke v.(); virtualinvoke v.("destinationName", v); v = interfaceinvoke v.(); virtualinvoke v.("clientId", v); v = interfaceinvoke v.(); virtualinvoke v.("connectionId", v); v = interfaceinvoke v.(); virtualinvoke v.("sessionId", v); v = interfaceinvoke v.(); virtualinvoke v.("selector", v); v = interfaceinvoke v.(); virtualinvoke v.("enqueueCounter", v); v = interfaceinvoke v.(); virtualinvoke v.("dequeueCounter", v); v = interfaceinvoke v.(); virtualinvoke v.("dispatchedCounter", v); v = interfaceinvoke v.(); virtualinvoke v.("dispatchedQueueSize", v); v = interfaceinvoke v.(); virtualinvoke v.("prefetchSize", v); v = interfaceinvoke v.(); virtualinvoke v.("maximumPendingMessageLimit", v); v = interfaceinvoke v.(); virtualinvoke v.("exclusive", v); v = interfaceinvoke v.(); virtualinvoke v.("retroactive", v); v = interfaceinvoke v.(); virtualinvoke v.("slowConsumer", v); return v; } protected void sendStats(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQMapMessage, org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception { java.lang.Throwable v; long v, v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.state.ProducerState v; boolean v; org.apache.activemq.command.ActiveMQMapMessage v; org.apache.activemq.command.MessageId v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ProducerId v, v; org.apache.activemq.util.LongSequenceGenerator v; org.apache.activemq.command.ProducerInfo v; org.apache.activemq.broker.ProducerBrokerExchange v; org.apache.activemq.plugin.StatisticsBroker v; v := @this: org.apache.activemq.plugin.StatisticsBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ActiveMQMapMessage; v := @parameter: org.apache.activemq.command.ActiveMQDestination; virtualinvoke v.(0); v = staticinvoke (); virtualinvoke v.(v); virtualinvoke v.(4); virtualinvoke v.("Advisory"); v = new org.apache.activemq.command.MessageId; v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.ProducerId,long)>(v, v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(0); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.activemq.broker.ProducerBrokerExchange; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(1); v = new org.apache.activemq.state.ProducerState; v = new org.apache.activemq.command.ProducerInfo; specialinvoke v.()>(); specialinvoke v.(org.apache.activemq.command.ProducerInfo)>(v); virtualinvoke v.(v); label: virtualinvoke v.(0); v = v.; interfaceinvoke v.(v, v); label: virtualinvoke v.(v); goto label; label: v := @caughtexception; virtualinvoke v.(v); throw v; label: return; catch java.lang.Throwable from label to label with label; } static void () { org.apache.activemq.util.IdGenerator v; org.slf4j.Logger v; v = staticinvoke (class "Lorg/apache/activemq/plugin/StatisticsBroker;"); = v; v = new org.apache.activemq.util.IdGenerator; specialinvoke v.()>(); = v; return; } }