public class org.apache.activemq.broker.region.RegionBroker extends org.apache.activemq.broker.EmptyBroker { public static final java.lang.String ORIGINAL_EXPIRATION; private static final org.slf4j.Logger LOG; private static final org.apache.activemq.util.IdGenerator BROKER_ID_GENERATOR; protected final org.apache.activemq.broker.region.DestinationStatistics destinationStatistics; protected org.apache.activemq.broker.region.DestinationFactory destinationFactory; protected final java.util.Map connectionStates; private final org.apache.activemq.broker.region.Region queueRegion; private final org.apache.activemq.broker.region.Region topicRegion; private final org.apache.activemq.broker.region.Region tempQueueRegion; private final org.apache.activemq.broker.region.Region tempTopicRegion; protected final org.apache.activemq.broker.BrokerService brokerService; private boolean started; private boolean keepDurableSubsActive; private final java.util.concurrent.CopyOnWriteArrayList connections; private final java.util.Map destinationGate; private final java.util.Map destinations; private final java.util.Map brokerInfos; private final org.apache.activemq.util.LongSequenceGenerator sequenceGenerator; private org.apache.activemq.command.BrokerId brokerId; private java.lang.String brokerName; private final java.util.Map clientIdSet; private final org.apache.activemq.broker.region.DestinationInterceptor destinationInterceptor; private org.apache.activemq.broker.ConnectionContext adminConnectionContext; private final org.apache.activemq.thread.Scheduler scheduler; private final java.util.concurrent.ThreadPoolExecutor executor; private boolean allowTempAutoCreationOnSend; private final java.util.concurrent.locks.ReentrantReadWriteLock inactiveDestinationsPurgeLock; private final org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory; private final java.util.concurrent.atomic.AtomicBoolean purgeInactiveDestinationsTaskInProgress; private final java.lang.Runnable purgeInactiveDestinationsTask; private final java.lang.Runnable purgeInactiveDestinationsWork; public void (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) throws java.io.IOException { java.util.concurrent.ThreadPoolExecutor v; java.util.concurrent.atomic.AtomicBoolean v; java.util.HashMap v, v, v, v; long v; java.util.concurrent.locks.ReentrantReadWriteLock v; java.util.Map v; org.apache.activemq.broker.region.Region v, v, v, 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; org.apache.activemq.broker.region.RegionBroker$2 v; org.apache.activemq.broker.region.RegionBroker$1 v; java.lang.IllegalArgumentException v; org.apache.activemq.broker.region.DestinationInterceptor v; org.apache.activemq.util.LongSequenceGenerator v, v; org.apache.activemq.thread.Scheduler v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.broker.region.DestinationStatistics v; org.apache.activemq.broker.region.RegionBroker v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.BrokerService; 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.()>(); v = new org.apache.activemq.broker.region.DestinationStatistics; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (v); v. = v; v = new java.util.concurrent.CopyOnWriteArrayList; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.util.LongSequenceGenerator; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new org.apache.activemq.broker.region.RegionBroker$1; specialinvoke v.(org.apache.activemq.broker.region.RegionBroker)>(v); v. = v; v = new org.apache.activemq.broker.region.RegionBroker$2; specialinvoke v.(org.apache.activemq.broker.region.RegionBroker)>(v); v. = v; v. = v; v. = v; v. = v; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("null destinationFactory"); throw v; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v. = v; v = virtualinvoke v.(v, v, v); v. = v; v = virtualinvoke v.(v, v, v); v. = v; v. = v; v = virtualinvoke v.(v, v, v); v. = v; v = virtualinvoke v.(v, v, v); v. = v; v. = v; return; } public java.util.Map getDestinationMap() { java.util.Map v, v; org.apache.activemq.broker.region.Region v, v; java.util.HashMap v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = new java.util.HashMap; v = virtualinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(java.util.Map)>(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.(v); return v; } public java.util.Map getDestinationMap(org.apache.activemq.command.ActiveMQDestination) { java.lang.Throwable v; java.util.Map v, v; org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.command.ActiveMQDestination; label: v = virtualinvoke v.(v); v = interfaceinvoke v.(); label: return v; label: v := @caughtexception; v = staticinvoke (); return v; catch javax.jms.JMSException from label to label with label; } public java.util.Set getDestinations(org.apache.activemq.command.ActiveMQDestination) { java.lang.Throwable v; java.util.Set v, v; org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.command.ActiveMQDestination; label: v = virtualinvoke v.(v); v = interfaceinvoke v.(v); label: return v; label: v := @caughtexception; v = staticinvoke (); return v; catch javax.jms.JMSException from label to label with label; } public org.apache.activemq.broker.region.Region getQueueRegion() { org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = v.; return v; } public org.apache.activemq.broker.region.Region getTempQueueRegion() { org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = v.; return v; } public org.apache.activemq.broker.region.Region getTempTopicRegion() { org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = v.; return v; } public org.apache.activemq.broker.region.Region getTopicRegion() { org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; 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.region.TempTopicRegion 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; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; 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.region.TempTopicRegion; v = v.; specialinvoke v.(org.apache.activemq.broker.region.RegionBroker,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.thread.TaskRunnerFactory v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.DestinationFactory v; org.apache.activemq.broker.region.DestinationStatistics v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.broker.region.TempQueueRegion v; v := @this: org.apache.activemq.broker.region.RegionBroker; 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.region.TempQueueRegion; v = v.; specialinvoke v.(org.apache.activemq.broker.region.RegionBroker,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.thread.TaskRunnerFactory v; org.apache.activemq.broker.region.TopicRegion v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.DestinationFactory v; org.apache.activemq.broker.region.DestinationStatistics v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; 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.region.TopicRegion; v = v.; specialinvoke v.(org.apache.activemq.broker.region.RegionBroker,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 createQueueRegion(org.apache.activemq.usage.SystemUsage, org.apache.activemq.thread.TaskRunnerFactory, org.apache.activemq.broker.region.DestinationFactory) { 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; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.broker.region.QueueRegion v; v := @this: org.apache.activemq.broker.region.RegionBroker; 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.region.QueueRegion; v = v.; specialinvoke v.(org.apache.activemq.broker.region.RegionBroker,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 start() throws java.lang.Exception { org.apache.activemq.broker.BrokerService v; java.lang.Runnable v; org.apache.activemq.thread.Scheduler v; int v; org.apache.activemq.broker.region.Region v, v, v, v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v. = 1; v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); if v <= 0 goto label; v = v.; v = v.; virtualinvoke v.(v, v); label: return; } public void stop() throws java.lang.Exception { java.lang.Runnable v; org.apache.activemq.util.ServiceStopper v; java.util.Map v, v, v; org.apache.activemq.thread.Scheduler v; org.apache.activemq.broker.region.RegionBroker v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.broker.region.RegionBroker; v. = 0; v = v.; v = v.; virtualinvoke v.(v); v = new org.apache.activemq.util.ServiceStopper; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; virtualinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); return; } public org.apache.activemq.broker.region.policy.PolicyMap getDestinationPolicy() { org.apache.activemq.broker.BrokerService v, v; org.apache.activemq.broker.region.policy.PolicyMap v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = null; label: return v; } public org.apache.activemq.broker.ConnectionContext getConnectionContext(java.lang.String) { java.util.Map v; java.lang.Object v; java.lang.String v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); return v; } public void addConnection(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConnectionInfo) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.ConnectionInfo v; java.util.Map v, v, v, v; java.lang.String v, v, v, v, v, v; org.apache.activemq.broker.Connection v, v, v, v, v, v; boolean v, v; org.slf4j.Logger v, v; java.io.IOException v; javax.jms.InvalidClientIDException v, v; java.lang.Object v; org.apache.activemq.broker.region.RegionBroker v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConnectionInfo; v = virtualinvoke v.(); if v != null goto label; v = new javax.jms.InvalidClientIDException; specialinvoke v.(java.lang.String)>("No clientID specified for connection request"); throw v; label: v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); goto label; label: v = new javax.jms.InvalidClientIDException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Broker: \u - Client: \u already connected from \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; interfaceinvoke v.(v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); interfaceinvoke v.("Stealing link for clientId {} From Connection {}", v, v); v = v instanceof org.apache.activemq.broker.TransportConnection; if v == 0 goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Stealing link for clientId \u From Connection \u0001"); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); goto label; label: interfaceinvoke v.(); goto label; label: v = ; interfaceinvoke v.("No Connection found for {}", v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return; catch java.lang.Throwable from label to label with label; } public void removeConnection(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConnectionInfo, java.lang.Throwable) throws java.lang.Exception { java.lang.Throwable v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.ConnectionInfo v; java.util.Map v, v, v; java.lang.String v; org.apache.activemq.broker.Connection v; boolean v; org.apache.activemq.command.ConnectionId v, v; javax.jms.InvalidClientIDException v; java.lang.Object v; org.apache.activemq.broker.region.RegionBroker v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConnectionInfo; v := @parameter: java.lang.Throwable; v = virtualinvoke v.(); if v != null goto label; v = new javax.jms.InvalidClientIDException; specialinvoke v.(java.lang.String)>("No clientID specified for connection disconnect request"); throw v; label: v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(v); if v != v goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return; catch java.lang.Throwable from label to label with label; } protected boolean isEqual(org.apache.activemq.command.ConnectionId, org.apache.activemq.command.ConnectionId) { org.apache.activemq.command.ConnectionId v, v; org.apache.activemq.broker.region.RegionBroker v; boolean v, v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.command.ConnectionId; v := @parameter: org.apache.activemq.command.ConnectionId; if v == v goto label; if v == null goto label; v = virtualinvoke v.(v); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } public org.apache.activemq.broker.Connection[] getClients() throws java.lang.Exception { int v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.broker.Connection[] v; java.util.ArrayList v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = new java.util.ArrayList; v = v.; specialinvoke v.(java.util.Collection)>(v); v = virtualinvoke v.(); v = newarray (org.apache.activemq.broker.Connection)[v]; virtualinvoke v.(v); return v; } public org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, boolean) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; java.util.Map v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.Destination v; java.lang.Throwable v, v, v, v; org.apache.activemq.broker.region.Region v; java.lang.Object v, v, v, v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: boolean; v = v.; v = interfaceinvoke v.(v); if v == null goto label; return v; label: v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; exitmonitor v; label: return v; label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; label: v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; virtualinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; exitmonitor v; label: return v; label: v = v.; interfaceinvoke v.(v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = 1; v = virtualinvoke v.(); if v == 0 goto label; v = v; label: v = virtualinvoke v.(v); v = interfaceinvoke v.(v, v, v); v = v.; interfaceinvoke v.(v, v); label: v = v.; entermonitor v; label: v = v.; interfaceinvoke v.(v); v = v.; virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v := @caughtexception; v = v.; entermonitor v; label: v = v.; interfaceinvoke v.(v); v = v.; virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: throw v; label: return v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void removeDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, long) throws java.lang.Exception { long v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.ConnectionContext v; java.util.Map v, v; org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; boolean v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: long; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(v); interfaceinvoke v.(v, v, v); v = v.; interfaceinvoke v.(v); label: return; } public void addDestinationInfo(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.DestinationInfo) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.DestinationInfo v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.DestinationInfo; v = virtualinvoke v.(); virtualinvoke v.(v, v, 1); return; } public void removeDestinationInfo(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.DestinationInfo) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; long v; org.apache.activemq.command.DestinationInfo v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.DestinationInfo; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); return; } public org.apache.activemq.command.ActiveMQDestination[] getDestinations() throws java.lang.Exception { java.util.Map v; int v; java.util.Set v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.ActiveMQDestination[] v; java.util.ArrayList v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = new java.util.ArrayList; v = virtualinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = virtualinvoke v.(); v = newarray (org.apache.activemq.command.ActiveMQDestination)[v]; virtualinvoke v.(v); return v; } public void addProducer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ProducerInfo) throws java.lang.Exception { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; org.apache.activemq.command.ProducerInfo v; org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; boolean v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ProducerInfo; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v, v); v = virtualinvoke v.(v); interfaceinvoke v.(v, v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void removeProducer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ProducerInfo) throws java.lang.Exception { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; org.apache.activemq.command.ProducerInfo v; org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ProducerInfo; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(v); interfaceinvoke v.(v, v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public org.apache.activemq.broker.region.Subscription addConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.region.Subscription v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.broker.region.DestinationInterceptor v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = virtualinvoke v.(); v = v.; if v == null goto label; v = v.; interfaceinvoke v.(v, v, v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(v); v = interfaceinvoke v.(v, v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return v; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public void removeConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo) throws java.lang.Exception { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(v); interfaceinvoke v.(v, v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void removeSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.RemoveSubscriptionInfo) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.command.RemoveSubscriptionInfo v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.RemoveSubscriptionInfo; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; interfaceinvoke v.(v, v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message) throws java.lang.Exception { long v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.command.Message v; org.apache.activemq.broker.region.Region v, v, v; boolean v, v, v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.broker.ProducerBrokerExchange v; org.apache.activemq.broker.region.Destination v, v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange; v := @parameter: org.apache.activemq.command.Message; v = virtualinvoke v.(); v = staticinvoke (); virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v, v); v = virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(null); label: v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(null); virtualinvoke v.(null); label: return; } public void acknowledge(org.apache.activemq.broker.ConsumerBrokerExchange, org.apache.activemq.command.MessageAck) throws java.lang.Exception { org.apache.activemq.command.MessageAck v; org.apache.activemq.broker.ConsumerBrokerExchange v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.Region v, v, v; org.apache.activemq.broker.region.RegionBroker v; boolean v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConsumerBrokerExchange; v := @parameter: org.apache.activemq.command.MessageAck; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != null goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); label: v = virtualinvoke v.(); interfaceinvoke v.(v, v); return; } public org.apache.activemq.broker.region.Region getRegion(org.apache.activemq.command.ActiveMQDestination) throws javax.jms.JMSException { javax.jms.JMSException v; org.apache.activemq.command.ActiveMQDestination v; byte v; org.apache.activemq.broker.region.Region v, v, v, v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = virtualinvoke v.(); tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; default: goto label; }; label: v = v.; return v; label: v = v.; return v; label: v = v.; return v; label: v = v.; return v; label: v = virtualinvoke v.(v); throw v; } public org.apache.activemq.command.Response messagePull(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessagePull) throws java.lang.Exception { org.apache.activemq.command.Response v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.Region v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.MessagePull v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.MessagePull; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = interfaceinvoke v.(v, v); return v; } public org.apache.activemq.command.TransactionId[] getPreparedTransactions(org.apache.activemq.broker.ConnectionContext) throws java.lang.Exception { java.lang.IllegalAccessException v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v = new java.lang.IllegalAccessException; specialinvoke v.(java.lang.String)>("Transaction operation not implemented by this broker."); throw v; } public void beginTransaction(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.TransactionId) throws java.lang.Exception { java.lang.IllegalAccessException v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.TransactionId v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.TransactionId; v = new java.lang.IllegalAccessException; specialinvoke v.(java.lang.String)>("Transaction operation not implemented by this broker."); throw v; } public int prepareTransaction(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.TransactionId) throws java.lang.Exception { java.lang.IllegalAccessException v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.TransactionId v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.TransactionId; v = new java.lang.IllegalAccessException; specialinvoke v.(java.lang.String)>("Transaction operation not implemented by this broker."); throw v; } public void rollbackTransaction(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.TransactionId) throws java.lang.Exception { java.lang.IllegalAccessException v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.TransactionId v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.TransactionId; v = new java.lang.IllegalAccessException; specialinvoke v.(java.lang.String)>("Transaction operation not implemented by this broker."); throw v; } public void commitTransaction(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.TransactionId, boolean) throws java.lang.Exception { java.lang.IllegalAccessException v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.TransactionId v; boolean v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.TransactionId; v := @parameter: boolean; v = new java.lang.IllegalAccessException; specialinvoke v.(java.lang.String)>("Transaction operation not implemented by this broker."); throw v; } public void forgetTransaction(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.TransactionId) throws java.lang.Exception { java.lang.IllegalAccessException v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.TransactionId v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.TransactionId; v = new java.lang.IllegalAccessException; specialinvoke v.(java.lang.String)>("Transaction operation not implemented by this broker."); throw v; } public void gc() { org.apache.activemq.broker.region.Region v, v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); return; } public org.apache.activemq.command.BrokerId getBrokerId() { org.apache.activemq.command.BrokerId v, v, v; org.apache.activemq.util.IdGenerator v; java.lang.String v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = v.; if v != null goto label; v = new org.apache.activemq.command.BrokerId; v = ; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v. = v; label: v = v.; return v; } public void setBrokerId(org.apache.activemq.command.BrokerId) { org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.BrokerId v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.command.BrokerId; v. = v; return; } public java.lang.String getBrokerName() { java.util.Locale v; java.lang.String v, v, v, v; org.apache.activemq.broker.region.RegionBroker v; java.lang.Exception v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = v.; if v != null goto label; label: v = staticinvoke (); v = ; v = virtualinvoke v.(v); v. = v; label: goto label; label: v := @caughtexception; v. = "localhost"; label: v = v.; return v; catch java.lang.Exception from label to label with label; } public void setBrokerName(java.lang.String) { java.lang.String v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: java.lang.String; v. = v; return; } public org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics() { org.apache.activemq.broker.region.DestinationStatistics v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = v.; return v; } protected javax.jms.JMSException createUnknownDestinationTypeException(org.apache.activemq.command.ActiveMQDestination) { byte v; java.lang.String v; javax.jms.JMSException v; org.apache.activemq.broker.region.RegionBroker v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = new javax.jms.JMSException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown destination type: \u0001"); specialinvoke v.(java.lang.String)>(v); return v; } public synchronized void addBroker(org.apache.activemq.broker.Connection, org.apache.activemq.command.BrokerInfo) { java.lang.Object[] v; org.slf4j.Logger v; java.lang.Integer v; org.apache.activemq.command.BrokerInfo v; java.util.Map v, v, v; org.apache.activemq.command.BrokerId v, v; int v; java.lang.Object v; java.lang.String v, v; org.apache.activemq.broker.Connection v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.Connection; v := @parameter: org.apache.activemq.command.BrokerInfo; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = virtualinvoke v.(); virtualinvoke v.(null); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: virtualinvoke v.(); v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v[2] = v; interfaceinvoke v.("{} addBroker: {} brokerInfo size: {}", v); virtualinvoke v.(v); return; } public synchronized void removeBroker(org.apache.activemq.broker.Connection, org.apache.activemq.command.BrokerInfo) { java.lang.Object[] v; java.lang.Integer v; org.apache.activemq.command.BrokerInfo v; java.util.Map v, v, v; int v, v; java.lang.String v, v; org.apache.activemq.broker.Connection v; boolean v; org.apache.activemq.broker.BrokerService v; org.slf4j.Logger v; org.apache.activemq.command.BrokerId v, v; java.lang.Object v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.Connection; v := @parameter: org.apache.activemq.command.BrokerInfo; if v == null goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v[2] = v; interfaceinvoke v.("{} removeBroker: {} brokerInfo size: {}", v); v = v.; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(v); label: return; } public synchronized org.apache.activemq.command.BrokerInfo[] getPeerBrokerInfos() { java.lang.Object[] v; org.apache.activemq.command.BrokerInfo[] v; java.util.Collection v; java.util.Map v, v; int v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v = v.; v = interfaceinvoke v.(); v = newarray (org.apache.activemq.command.BrokerInfo)[v]; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); return v; } public void preProcessDispatch(org.apache.activemq.command.MessageDispatch) { java.lang.Throwable v; org.apache.activemq.command.Message$MessageDestination v, v, v; long v, v, v; org.apache.activemq.command.Message v; org.apache.activemq.command.MessageDispatch v; int v; java.lang.String v, v; boolean v, v, v, v; org.apache.activemq.store.MessageStore v; org.apache.activemq.broker.BrokerService v; org.slf4j.Logger v; org.apache.activemq.command.MessageId v; org.apache.activemq.broker.region.RegionBroker$3 v; java.io.IOException v; java.lang.RuntimeException v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.management.TimeStatisticImpl v; org.apache.activemq.broker.region.DestinationStatistics v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.command.MessageDispatch; v = virtualinvoke v.(); if v == null goto label; v = staticinvoke (); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = new org.apache.activemq.broker.region.RegionBroker$3; specialinvoke v.(org.apache.activemq.broker.region.RegionBroker,org.apache.activemq.command.MessageDispatch,org.apache.activemq.command.Message)>(v, v, v); virtualinvoke v.(v); label: virtualinvoke v.(v); goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to persist JMSRedeliveryFlag on \u in \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.