public class org.apache.activemq.broker.jmx.ManagedRegionBroker extends org.apache.activemq.broker.region.RegionBroker { private static final org.slf4j.Logger LOG; private final org.apache.activemq.broker.jmx.ManagementContext managementContext; private final javax.management.ObjectName brokerObjectName; private final java.util.Map topics; private final java.util.Map queues; private final java.util.Map temporaryQueues; private final java.util.Map temporaryTopics; private final java.util.Map queueSubscribers; private final java.util.Map topicSubscribers; private final java.util.Map durableTopicSubscribers; private final java.util.Map inactiveDurableTopicSubscribers; private final java.util.Map temporaryQueueSubscribers; private final java.util.Map temporaryTopicSubscribers; private final java.util.Map queueProducers; private final java.util.Map topicProducers; private final java.util.Map temporaryQueueProducers; private final java.util.Map temporaryTopicProducers; private final java.util.Map dynamicDestinationProducers; private final java.util.Map subscriptionKeys; private final java.util.Map subscriptionMap; private final java.util.Set registeredMBeans; private org.apache.activemq.broker.Broker contextBroker; private final java.util.concurrent.ExecutorService asyncInvokeService; private final long mbeanTimeout; public void (org.apache.activemq.broker.BrokerService, org.apache.activemq.broker.jmx.ManagementContext, javax.management.ObjectName, org.apache.activemq.thread.TaskRunnerFactory, org.apache.activemq.usage.SystemUsage, org.apache.activemq.broker.region.DestinationFactory, org.apache.activemq.broker.region.DestinationInterceptor, org.apache.activemq.thread.Scheduler, java.util.concurrent.ThreadPoolExecutor) throws java.io.IOException { org.apache.activemq.broker.jmx.ManagementContext v; byte v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.DestinationFactory v; org.apache.activemq.broker.BrokerService v; java.util.concurrent.ConcurrentHashMap v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; javax.management.ObjectName v; org.apache.activemq.thread.TaskRunnerFactory v; java.util.concurrent.ThreadPoolExecutor v, v; long v, v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.region.DestinationInterceptor v; java.util.concurrent.ConcurrentHashMap$KeySetView v; org.apache.activemq.thread.Scheduler v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.broker.BrokerService; v := @parameter: org.apache.activemq.broker.jmx.ManagementContext; v := @parameter: javax.management.ObjectName; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.broker.region.DestinationFactory; v := @parameter: org.apache.activemq.broker.region.DestinationInterceptor; v := @parameter: org.apache.activemq.thread.Scheduler; v := @parameter: java.util.concurrent.ThreadPoolExecutor; specialinvoke v.(org.apache.activemq.broker.BrokerService,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.usage.SystemUsage,org.apache.activemq.broker.region.DestinationFactory,org.apache.activemq.broker.region.DestinationInterceptor,org.apache.activemq.thread.Scheduler,java.util.concurrent.ThreadPoolExecutor)>(v, v, v, v, v, v, v); v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = staticinvoke (); v. = v; v. = v; v. = v; v = virtualinvoke v.(); v. = v; v = v.; v = v cmp 0L; if v <= 0 goto label; v = v; goto label; label: v = null; label: v. = v; return; } public void start() throws java.lang.Exception { org.apache.activemq.broker.jmx.ManagedRegionBroker v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; specialinvoke v.(); virtualinvoke v.(); return; } protected void doStop(org.apache.activemq.util.ServiceStopper) { org.slf4j.Logger v; java.util.Iterator v; java.util.Set v, v; java.lang.Exception v; org.apache.activemq.util.ServiceStopper v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.ManagementContext v; java.lang.Object v; javax.management.InstanceNotFoundException v; boolean v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.util.ServiceStopper; specialinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("The MBean {} is no longer registered with JMX", v); goto label; label: v := @caughtexception; virtualinvoke v.(v, v); goto label; label: v = v.; interfaceinvoke v.(); return; catch javax.management.InstanceNotFoundException from label to label with label; catch java.lang.Exception from label to label with label; } protected org.apache.activemq.broker.region.Region createQueueRegion(org.apache.activemq.usage.SystemUsage, org.apache.activemq.thread.TaskRunnerFactory, org.apache.activemq.broker.region.DestinationFactory) { org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.ManagedQueueRegion v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.DestinationFactory v; org.apache.activemq.broker.region.DestinationStatistics v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; v := @parameter: org.apache.activemq.broker.region.DestinationFactory; v = new org.apache.activemq.broker.jmx.ManagedQueueRegion; v = v.; specialinvoke v.(org.apache.activemq.broker.jmx.ManagedRegionBroker,org.apache.activemq.broker.region.DestinationStatistics,org.apache.activemq.usage.SystemUsage,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.broker.region.DestinationFactory)>(v, v, v, v, v); return v; } protected org.apache.activemq.broker.region.Region createTempQueueRegion(org.apache.activemq.usage.SystemUsage, org.apache.activemq.thread.TaskRunnerFactory, org.apache.activemq.broker.region.DestinationFactory) { org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.ManagedTempQueueRegion v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.DestinationFactory v; org.apache.activemq.broker.region.DestinationStatistics v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; v := @parameter: org.apache.activemq.broker.region.DestinationFactory; v = new org.apache.activemq.broker.jmx.ManagedTempQueueRegion; v = v.; specialinvoke v.(org.apache.activemq.broker.jmx.ManagedRegionBroker,org.apache.activemq.broker.region.DestinationStatistics,org.apache.activemq.usage.SystemUsage,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.broker.region.DestinationFactory)>(v, v, v, v, v); return v; } protected org.apache.activemq.broker.region.Region createTempTopicRegion(org.apache.activemq.usage.SystemUsage, org.apache.activemq.thread.TaskRunnerFactory, org.apache.activemq.broker.region.DestinationFactory) { org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.ManagedTempTopicRegion v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.DestinationFactory v; org.apache.activemq.broker.region.DestinationStatistics v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; v := @parameter: org.apache.activemq.broker.region.DestinationFactory; v = new org.apache.activemq.broker.jmx.ManagedTempTopicRegion; v = v.; specialinvoke v.(org.apache.activemq.broker.jmx.ManagedRegionBroker,org.apache.activemq.broker.region.DestinationStatistics,org.apache.activemq.usage.SystemUsage,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.broker.region.DestinationFactory)>(v, v, v, v, v); return v; } protected org.apache.activemq.broker.region.Region createTopicRegion(org.apache.activemq.usage.SystemUsage, org.apache.activemq.thread.TaskRunnerFactory, org.apache.activemq.broker.region.DestinationFactory) { org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.jmx.ManagedTopicRegion v; org.apache.activemq.broker.region.DestinationFactory v; org.apache.activemq.broker.region.DestinationStatistics v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; v := @parameter: org.apache.activemq.broker.region.DestinationFactory; v = new org.apache.activemq.broker.jmx.ManagedTopicRegion; v = v.; specialinvoke v.(org.apache.activemq.broker.jmx.ManagedRegionBroker,org.apache.activemq.broker.region.DestinationStatistics,org.apache.activemq.usage.SystemUsage,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.broker.region.DestinationFactory)>(v, v, v, v, v); return v; } public void register(org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.broker.region.Destination) { org.apache.activemq.broker.jmx.TopicView v; org.slf4j.Logger v, v; javax.management.ObjectName v, v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.jmx.DestinationView v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.QueueView v; boolean v, v; org.apache.activemq.broker.region.Destination v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: org.apache.activemq.broker.region.Destination; label: v = v.; v = staticinvoke (v, v); v = v instanceof org.apache.activemq.broker.region.Queue; if v == 0 goto label; v = new org.apache.activemq.broker.jmx.QueueView; specialinvoke v.(org.apache.activemq.broker.jmx.ManagedRegionBroker,org.apache.activemq.broker.region.Queue)>(v, v); v = v; goto label; label: v = v instanceof org.apache.activemq.broker.region.Topic; if v == 0 goto label; v = new org.apache.activemq.broker.jmx.TopicView; specialinvoke v.(org.apache.activemq.broker.jmx.ManagedRegionBroker,org.apache.activemq.broker.region.Topic)>(v, v); v = v; goto label; label: v = null; v = ; interfaceinvoke v.("JMX View is not supported for custom destination {}", v); label: if v == null goto label; virtualinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to register destination {}", v, v); label: return; catch java.lang.Exception from label to label with label; } public void unregister(org.apache.activemq.command.ActiveMQDestination) { org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.slf4j.Logger v; javax.management.ObjectName v, v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.command.ActiveMQDestination; label: v = v.; v = staticinvoke (v, v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to unregister {}", v, v); label: return; catch java.lang.Exception from label to label with label; } public javax.management.ObjectName registerSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription) { org.apache.activemq.util.SubscriptionKey v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.broker.ConnectionContext v; java.util.Map v; boolean v, v, v, v; org.apache.activemq.broker.BrokerService v, v; org.apache.activemq.broker.jmx.DurableSubscriptionView v; javax.management.ObjectName v, v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v, v, v, v, v, v, v; org.apache.activemq.command.SubscriptionInfo v; org.slf4j.Logger v; org.apache.activemq.broker.jmx.TopicSubscriptionView v; org.apache.activemq.broker.jmx.SubscriptionView v, v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v = virtualinvoke v.(); v = new org.apache.activemq.util.SubscriptionKey; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); label: v = v.; v = interfaceinvoke v.(); v = staticinvoke (v, v, v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.("OFFLINE"); if v == 0 goto label; v = new org.apache.activemq.command.SubscriptionInfo; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = null; label: v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.broker.jmx.DurableSubscriptionView; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.broker.jmx.ManagedRegionBroker,org.apache.activemq.broker.BrokerService,java.lang.String,java.lang.String,org.apache.activemq.broker.region.Subscription)>(v, v, v, v, v); v = v; goto label; label: v = v instanceof org.apache.activemq.broker.region.TopicSubscription; if v == 0 goto label; v = new org.apache.activemq.broker.jmx.TopicSubscriptionView; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,org.apache.activemq.broker.region.TopicSubscription)>(v, v, v); v = v; goto label; label: v = new org.apache.activemq.broker.jmx.SubscriptionView; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,org.apache.activemq.broker.region.Subscription)>(v, v, v); v = v; label: v = interfaceinvoke v.(); virtualinvoke v.(v, v, v, v); label: v = v.; interfaceinvoke v.(v, v); label: return v; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to register subscription {}", v, v); return null; catch java.lang.Exception from label to label with label; } public void addConnection(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConnectionInfo) throws java.lang.Exception { org.apache.activemq.broker.BrokerService v, v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.Broker v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.ConnectionInfo v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConnectionInfo; specialinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); virtualinvoke v.(); v = v.; v = interfaceinvoke v.(); virtualinvoke v.(); return; } public void removeConnection(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConnectionInfo, java.lang.Throwable) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.ConnectionInfo v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConnectionInfo; v := @parameter: java.lang.Throwable; specialinvoke v.(v, v, v); v = v.; v = interfaceinvoke v.(); virtualinvoke v.(); return; } public org.apache.activemq.broker.region.Subscription addConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo) throws java.lang.Exception { org.apache.activemq.broker.region.Subscription v; org.apache.activemq.util.SubscriptionKey v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.ConnectionContext v, v; java.util.Map v; java.lang.Object v; java.lang.String v, v; org.apache.activemq.command.ConsumerInfo v, v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = specialinvoke v.(v, v); v = new org.apache.activemq.util.SubscriptionKey; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = v.; v = interfaceinvoke v.(v); if v == null goto label; virtualinvoke v.(v, v); label: return v; } public void removeConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo) throws java.lang.Exception { org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.ConnectionContext v; java.util.Map v, v, v; org.apache.activemq.command.ConsumerInfo v, v; boolean v, v, v, v; java.util.Iterator v, v; java.util.Set v, v; java.lang.Object v, v, v, v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = specialinvoke v.(v); v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(v); virtualinvoke v.(v, 1); goto label; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); virtualinvoke v.(v, 1); goto label; label: specialinvoke v.(v, v); return; } private java.util.Set findSubscriptions(org.apache.activemq.command.ConsumerInfo) { org.apache.activemq.command.ConsumerId v, v; java.util.HashSet v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; int v, v; java.lang.String v; org.apache.activemq.command.ConsumerInfo v; boolean v; org.slf4j.Logger v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v, v, v, v; org.apache.activemq.command.ActiveMQDestination[] v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = new java.util.HashSet; specialinvoke v.()>(); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); specialinvoke v.(v, v, v); v = v + 1; goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Error finding subscription {}: {}", v, v); label: return v; catch java.lang.Exception from label to label with label; } private void addSubscriptionToList(java.util.Set, org.apache.activemq.command.ConsumerId, org.apache.activemq.command.ActiveMQDestination) throws javax.jms.JMSException { org.apache.activemq.broker.jmx.ManagedRegionBroker v; java.util.Map v; java.util.Set v; org.apache.activemq.broker.region.Region v; java.lang.Object v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: java.util.Set; v := @parameter: org.apache.activemq.command.ConsumerId; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; interfaceinvoke v.(v); label: return; } public void addProducer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ProducerInfo) throws java.lang.Exception { org.apache.activemq.broker.BrokerService v; javax.management.ObjectName v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.jmx.ProducerView v; org.apache.activemq.command.ProducerInfo v; java.lang.String v, v, v; boolean v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ProducerInfo; specialinvoke v.(v, v); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v, v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = null; label: v = new org.apache.activemq.broker.jmx.ProducerView; specialinvoke v.(org.apache.activemq.command.ProducerInfo,java.lang.String,java.lang.String,org.apache.activemq.broker.jmx.ManagedRegionBroker)>(v, v, v, v); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); return; } public void removeProducer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ProducerInfo) throws java.lang.Exception { org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.ProducerInfo v; java.lang.String v; javax.management.ObjectName v, v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ProducerInfo; v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v, v); virtualinvoke v.(v); specialinvoke v.(v, v); return; } public void send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message) throws java.lang.Exception { org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.state.ProducerState v, v, v; java.util.Map v; java.lang.String v; javax.management.ObjectName v, v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.command.ProducerId v; org.apache.activemq.command.ProducerInfo v, v; java.lang.Object v; org.apache.activemq.broker.ProducerBrokerExchange v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange; v := @parameter: org.apache.activemq.command.Message; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; virtualinvoke v.(v); label: specialinvoke v.(v, v); return; } public void unregisterSubscription(org.apache.activemq.broker.region.Subscription) { org.slf4j.Logger v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.util.SubscriptionKey v; java.lang.Exception v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.jmx.ManagementContext v; java.util.Map v, v, v; java.lang.Object v, v; java.lang.String v, v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: org.apache.activemq.broker.region.Subscription; v = v.; v = interfaceinvoke v.(v); if v == null goto label; label: v = new org.apache.activemq.util.SubscriptionKey; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = v.; interfaceinvoke v.(v); v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to unregister subscription {}", v, v); label: return; catch java.lang.Exception from label to label with label; } protected void registerDestination(javax.management.ObjectName, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.broker.jmx.DestinationView) throws java.lang.Exception { java.lang.Throwable v; javax.management.ObjectInstance v; long v; org.apache.activemq.broker.jmx.DestinationView v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.ManagementContext v; java.util.Map v, v, v, v; java.util.concurrent.ExecutorService v; boolean v, v, v; org.slf4j.Logger v, v; java.util.Set v; javax.management.ObjectName v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: javax.management.ObjectName; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: org.apache.activemq.broker.jmx.DestinationView; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); goto label; label: v = v.; interfaceinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); goto label; label: v = v.; interfaceinvoke v.(v, v); label: v = v.; v = v.; v = v.; v = staticinvoke (v, v, v, v, v); if v == null goto label; v = v.; interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to register MBean {}", v); v = ; interfaceinvoke v.("Failure reason: ", v); label: return; catch java.lang.Throwable from label to label with label; } protected void unregisterDestination(javax.management.ObjectName) throws java.lang.Exception { java.lang.Throwable v, v; org.apache.activemq.broker.jmx.DestinationView v, v, v, v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.ManagementContext v, v; java.util.Map v, v, v, v; boolean v, v; org.slf4j.Logger v, v, v, v; java.util.Set v, v; javax.management.ObjectName v, v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: javax.management.ObjectName; v = v.; v = specialinvoke v.(v, v, null); v = v.; v = specialinvoke v.(v, v, v); v = v.; v = specialinvoke v.(v, v, v); v = v.; v = specialinvoke v.(v, v, v); v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; label: v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to unregister MBean {}", v); v = ; interfaceinvoke v.("Failure reason: ", v); label: if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; label: v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to unregister slow consumer strategy MBean {}", v); v = ; interfaceinvoke v.("Failure reason: ", v); label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } protected void registerProducer(javax.management.ObjectName, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.broker.jmx.ProducerView) throws java.lang.Exception { java.lang.Throwable v; javax.management.ObjectInstance v; long v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.ManagementContext v; org.apache.activemq.broker.jmx.ProducerView v; java.util.Map v, v, v, v, v; java.util.concurrent.ExecutorService v; boolean v, v, v; org.slf4j.Logger v, v; java.util.Set v; javax.management.ObjectName v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: javax.management.ObjectName; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: org.apache.activemq.broker.jmx.ProducerView; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); goto label; label: v = v.; interfaceinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); goto label; label: v = v.; interfaceinvoke v.(v, v); goto label; label: v = v.; interfaceinvoke v.(v, v); label: v = v.; v = v.; v = v.; v = staticinvoke (v, v, v, v, v); if v == null goto label; v = v.; interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to register MBean {}", v); v = ; interfaceinvoke v.("Failure reason: ", v); label: return; catch java.lang.Throwable from label to label with label; } protected void unregisterProducer(javax.management.ObjectName) throws java.lang.Exception { java.lang.Throwable v; org.slf4j.Logger v, v; java.util.Set v; javax.management.ObjectName v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.ManagementContext v; java.util.Map v, v, v, v, v; boolean v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: javax.management.ObjectName; v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; label: v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to unregister MBean {}", v); v = ; interfaceinvoke v.("Failure reason: ", v); label: return; catch java.lang.Throwable from label to label with label; } private org.apache.activemq.broker.jmx.DestinationView removeAndRemember(java.util.Map, javax.management.ObjectName, org.apache.activemq.broker.jmx.DestinationView) { org.apache.activemq.broker.jmx.DestinationView v, v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; java.util.Map v; java.lang.Object v; javax.management.ObjectName v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: java.util.Map; v := @parameter: javax.management.ObjectName; v := @parameter: org.apache.activemq.broker.jmx.DestinationView; v = interfaceinvoke v.(v); if v == null goto label; if v != null goto label; v = v; label: if v == null goto label; v = v; goto label; label: v = v; label: return v; } protected void registerSubscription(javax.management.ObjectName, org.apache.activemq.command.ConsumerInfo, org.apache.activemq.util.SubscriptionKey, org.apache.activemq.broker.jmx.SubscriptionView) throws java.lang.Exception { java.lang.Throwable v, v; javax.management.ObjectInstance v; org.apache.activemq.util.SubscriptionKey v; long v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.ManagementContext v, v; java.util.Map v, v, v, v, v, v, v; java.util.concurrent.ExecutorService v; org.apache.activemq.command.ConsumerInfo v; boolean v, v, v, v; org.slf4j.Logger v, v, v; java.util.Set v, v; org.apache.activemq.broker.jmx.SubscriptionView v; javax.management.ObjectName v; org.apache.activemq.command.ActiveMQDestination v; java.lang.Object v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: javax.management.ObjectName; v := @parameter: org.apache.activemq.command.ConsumerInfo; v := @parameter: org.apache.activemq.util.SubscriptionKey; v := @parameter: org.apache.activemq.broker.jmx.SubscriptionView; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); goto label; label: v = v.; interfaceinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unable to unregister inactive durable subscriber {}", v, v); goto label; label: v = v.; interfaceinvoke v.(v, v); label: v = v.; v = v.; v = v.; v = staticinvoke (v, v, v, v, v); if v == null goto label; v = v.; interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to register MBean {}", v); v = ; interfaceinvoke v.("Failure reason: ", v); label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } protected void unregisterSubscription(javax.management.ObjectName, boolean) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.util.SubscriptionKey v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; org.apache.activemq.broker.jmx.ManagementContext v; java.util.Map v, v, 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.SubscriptionInfo v; org.slf4j.Logger v, v; java.util.Set v; javax.management.ObjectName v; org.apache.activemq.command.ActiveMQTopic v; java.lang.Object v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v := @parameter: javax.management.ObjectName; v := @parameter: boolean; v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; label: v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to unregister MBean {}", v); v = ; interfaceinvoke v.("Failure reason: ", v); label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = new org.apache.activemq.util.SubscriptionKey; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); if v == 0 goto label; v = new org.apache.activemq.command.SubscriptionInfo; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = new org.apache.activemq.command.ActiveMQTopic; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; goto label; label: v = null; label: virtualinvoke v.(v, v, v); label: return; catch java.lang.Throwable from label to label with label; } protected void buildExistingSubscriptions() throws java.lang.Exception { org.apache.activemq.util.SubscriptionKey v; java.util.HashMap v; org.apache.activemq.broker.jmx.ManagedRegionBroker v; int v, v; org.apache.activemq.broker.region.DestinationFactory v, v; boolean v, v, v, v; org.apache.activemq.command.SubscriptionInfo v; org.slf4j.Logger v; java.util.Iterator v, v; java.util.Set v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.SubscriptionInfo[] v; java.lang.Object v, v, v, v; v := @this: org.apache.activemq.broker.jmx.ManagedRegionBroker; v = new java.util.HashMap; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(v); if v == null goto label; v = 0; label: v = lengthof v; if v >= v goto label; v = v[v]; v = new org.apache.activemq.util.SubscriptionKey; specialinvoke v.(org.apache.activemq.command.SubscriptionInfo)>(v); v = specialinvoke v.(v); if v != 0 goto label; v = ; interfaceinvoke v.("Restoring durable subscription MBean {}", v); interfaceinvoke v.(v, v); label: v = v + 1; goto label; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.