public abstract class org.apache.activemq.broker.region.AbstractRegion extends java.lang.Object implements org.apache.activemq.broker.region.Region { private static final org.slf4j.Logger LOG; protected final java.util.Map destinations; protected final org.apache.activemq.filter.DestinationMap destinationMap; protected final java.util.Map subscriptions; protected final org.apache.activemq.usage.SystemUsage usageManager; protected final org.apache.activemq.broker.region.DestinationFactory destinationFactory; protected final org.apache.activemq.broker.region.DestinationStatistics destinationStatistics; protected final org.apache.activemq.broker.region.RegionStatistics regionStatistics; protected final org.apache.activemq.broker.region.RegionBroker broker; protected boolean autoCreateDestinations; protected final org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory; protected final java.util.concurrent.locks.ReentrantReadWriteLock destinationsLock; protected final java.util.Map consumerChangeMutexMap; protected boolean started; public void (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) { org.apache.activemq.broker.region.RegionStatistics v; java.util.concurrent.ConcurrentHashMap v, v; java.util.HashMap v; java.util.concurrent.locks.ReentrantReadWriteLock v; java.lang.IllegalArgumentException v, v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.filter.DestinationMap 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.AbstractRegion; v := @parameter: org.apache.activemq.broker.region.RegionBroker; v := @parameter: org.apache.activemq.broker.region.DestinationStatistics; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; v := @parameter: org.apache.activemq.broker.region.DestinationFactory; specialinvoke v.()>(); v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.filter.DestinationMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.broker.region.RegionStatistics; specialinvoke v.()>(); v. = v; v. = 1; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("null broker"); throw v; label: 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; return; } public final void start() throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.security.SecurityContext v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.broker.Broker v, v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; java.util.Map v; boolean v, v; org.apache.activemq.broker.BrokerService v; java.util.Iterator v, v; java.util.Collection v; java.util.Set v; org.apache.activemq.broker.region.AbstractRegion v; java.lang.Object v, v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v. = 1; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.activemq.broker.ConnectionContext; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v, 0); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; 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 stop() throws java.lang.Exception { java.lang.Throwable v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.management.CountStatisticImpl v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; java.util.Map v, v; boolean v; org.apache.activemq.broker.region.RegionStatistics v, v, v; java.util.Iterator v; java.util.Collection v; org.apache.activemq.broker.region.AbstractRegion v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v. = 0; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke 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; catch java.lang.Throwable from label to label with label; } public org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, boolean) throws java.lang.Exception { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.broker.ConnectionContext v; java.util.Map v, v; java.lang.String v, v; org.apache.activemq.DestinationDoesNotExistException v; boolean v, v; org.slf4j.Logger v; org.apache.activemq.broker.region.DestinationInterceptor v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.filter.DestinationMap v; java.lang.Object v; org.apache.activemq.broker.region.RegionBroker v, v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: boolean; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = virtualinvoke v.(); if v == 0 goto label; if v == 0 goto label; label: virtualinvoke v.(v); v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{} adding destination: {}", v, v); v = virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(v); label: interfaceinvoke v.(); virtualinvoke v.(v, v); v = v.; interfaceinvoke v.(v, v); virtualinvoke v.(v, 1); v = v.; virtualinvoke v.(v, v); label: if v != null goto label; v = new org.apache.activemq.DestinationDoesNotExistException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); throw 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 java.util.Map getSubscriptions() { org.apache.activemq.broker.region.AbstractRegion v; java.util.Map v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v = v.; return v; } protected void updateRegionDestCounts(org.apache.activemq.command.ActiveMQDestination, int) { org.apache.activemq.broker.region.RegionStatistics v, v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.management.CountStatisticImpl v, v, v; int v; org.apache.activemq.broker.region.AbstractRegion v; boolean v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: int; if v == null goto label; v = staticinvoke (v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } protected void validateMaxDestinations(org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception { long v; org.apache.activemq.broker.region.policy.PolicyMap v, v; org.apache.activemq.management.CountStatisticImpl v; int v, v, v, v; java.lang.String v, v; boolean v; org.apache.activemq.broker.region.RegionStatistics v; java.util.Set v; javax.jms.IllegalStateException v, v; org.apache.activemq.command.ActiveMQDestination v, v, v, v, v; org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.filter.DestinationMap v; org.apache.activemq.broker.region.RegionBroker v, v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); if v < 0 goto label; v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); interfaceinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(); if v < v goto label; v = virtualinvoke v.(); if v == null goto label; v = new javax.jms.IllegalStateException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("The maxmimum number of destinations allowed (\u) for the policy \u has already been reached."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new javax.jms.IllegalStateException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("The maxmimum number of destinations allowed (\u) has already been reached."); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } protected java.util.List addSubscriptionsForDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Destination) throws java.lang.Exception { java.lang.Object[] v; java.util.ArrayList v; org.apache.activemq.broker.ConnectionContext v, v, v; java.util.Map v; java.lang.SecurityException v; java.lang.String v; boolean v, v, v; org.slf4j.Logger v; java.util.Iterator v; java.util.Collection v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.broker.region.AbstractRegion v; java.lang.Object v; org.apache.activemq.broker.region.Destination v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Destination; v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; label: v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); goto label; label: v = v; label: interfaceinvoke v.(v, v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = interfaceinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Subscription denied for {} to destination {}: {}", v); goto label; label: throw v; label: return v; catch java.lang.SecurityException from label to label with label; } public void removeDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, long) throws java.lang.Exception { java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.broker.ConnectionContext v; byte v, v; java.util.Map v, v, v; boolean v, v, v, v, v; java.util.Collection v, v; javax.jms.JMSException v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.filter.DestinationMap v; org.apache.activemq.broker.region.Destination v; java.lang.Throwable v; long v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; int v; java.lang.String v, v; org.slf4j.Logger v, v; java.util.Iterator v, v; org.apache.activemq.broker.region.DestinationInterceptor v; java.lang.Object v, v, v; org.apache.activemq.broker.region.RegionBroker v, v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: long; v = v cmp 0L; if v != 0 goto 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); if v == 0 goto label; v = new javax.jms.JMSException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Destination still has an active subscription: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{} removing destination: {}", v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = (int) -1; virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(v, v, 0L); goto label; label: v = v.; virtualinvoke v.(v, v); v = v instanceof org.apache.activemq.broker.region.Queue; if v == 0 goto label; virtualinvoke v.(); label: virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); if v == null goto label; interfaceinvoke v.(v); goto label; label: v = ; interfaceinvoke v.("Cannot remove a destination that doesn\'t exist: {}", 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 java.util.Set getDestinations(org.apache.activemq.command.ActiveMQDestination) { java.lang.Throwable v; java.util.Set v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.command.ActiveMQDestination v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.filter.DestinationMap v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke 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 java.util.Map getDestinationMap() { org.apache.activemq.broker.region.AbstractRegion v; java.util.Map v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v = v.; return v; } 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.command.ConsumerId v, v, v, v, v, v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; java.util.Map v, v, v, v, v, v; java.util.Set v; java.lang.Exception v; java.lang.Throwable v, v, v; java.lang.Object[] v, v, v; long v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.ArrayList v, v; java.lang.String v, v, v; org.apache.activemq.command.ConsumerInfo v; java.lang.SecurityException v; boolean v, v, v, v, v, v, v; org.apache.activemq.command.ActiveMQDestination v, v, v, v, v; org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.filter.DestinationMap v; org.apache.activemq.broker.region.Subscription v; org.slf4j.Logger v, v, v, v; java.util.Iterator v, v, v; java.lang.Object v, v, v, v, v, v, v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = ; v = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("{} adding consumer: {} for destination: {}", v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(v, v, 1); label: v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = new java.lang.Object; specialinvoke v.()>(); v = v; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v; entermonitor v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = ; interfaceinvoke v.("A duplicate subscription was detected. Clients may be misbehaving. Later warnings you may see about subscription removal are a consequence of this."); exitmonitor v; label: return v; label: v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(v, v); v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: v = v.; v = virtualinvoke 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: v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: interfaceinvoke v.(v, v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = interfaceinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Subscription denied for {} to destination {}: {}", v); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: v = virtualinvoke v.(); interfaceinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[4]; v[0] = v; v[1] = v; v = virtualinvoke v.(); v[2] = v; v[3] = v; interfaceinvoke v.("Error unsubscribing {} from {}: {}", v); goto label; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); throw v; label: interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.SecurityException from label to label with label; catch java.lang.Exception 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 java.util.Set getDurableDestinations() { java.util.Set v; org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.broker.region.DestinationFactory v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v = v.; v = virtualinvoke v.(); return v; } protected java.util.Set getInactiveDestinations() { java.lang.Throwable v; java.util.Set v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; java.util.Map v; org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.broker.region.DestinationFactory v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); interfaceinvoke 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 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 { org.apache.activemq.command.ConsumerId v, v, v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; java.util.Map v, v, v; boolean v, v; java.util.Set v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.filter.DestinationMap v; java.lang.Throwable v, v; java.lang.Object[] v; long v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.ArrayList v; java.lang.String v; org.apache.activemq.command.ConsumerInfo v; org.slf4j.Logger v; java.util.Iterator v, v; java.lang.Object v, v, v; org.apache.activemq.broker.region.RegionBroker v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = ; v = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("{} removing consumer: {} for destination: {}", v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v, v); goto label; label: virtualinvoke v.(v); label: v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw 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 destroySubscription(org.apache.activemq.broker.region.Subscription) { org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.broker.region.Subscription v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.region.Subscription; interfaceinvoke v.(); return; } public void removeSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.RemoveSubscriptionInfo) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.RemoveSubscriptionInfo v; org.apache.activemq.broker.region.AbstractRegion v; javax.jms.JMSException v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.RemoveSubscriptionInfo; v = new javax.jms.JMSException; specialinvoke v.(java.lang.String)>("Invalid operation."); throw v; } public void send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message) throws java.lang.Exception { org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.state.ProducerState v, v, v; org.apache.activemq.command.ProducerInfo v, v; org.apache.activemq.broker.region.AbstractRegion v; org.apache.activemq.broker.ProducerBrokerExchange v; boolean v; org.apache.activemq.broker.region.Destination v, v, v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange; v := @parameter: org.apache.activemq.command.Message; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != null goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(v, v, 0); virtualinvoke v.(v); label: v = virtualinvoke v.(); interfaceinvoke v.(v, v); 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.(); virtualinvoke v.(); 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.slf4j.Logger v, v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.broker.ConsumerBrokerExchange v; java.lang.IllegalArgumentException v; org.apache.activemq.command.ConsumerId v, v; org.apache.activemq.broker.ConnectionContext v, v; java.util.Map v; org.apache.activemq.broker.region.AbstractRegion v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.ConsumerBrokerExchange; v := @parameter: org.apache.activemq.command.MessageAck; v = virtualinvoke v.(); if v != null goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("Ack for non existent subscription, ack: {}", v); v = new java.lang.IllegalArgumentException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("The subscription does not exist: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; interfaceinvoke v.("Ack for non existent subscription in recovery, ack: {}", v); return; label: virtualinvoke v.(v); label: v = virtualinvoke v.(); interfaceinvoke v.(v, v); return; } 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; java.lang.IllegalArgumentException v; org.apache.activemq.command.ConsumerId v, v; org.apache.activemq.command.MessagePull v; org.apache.activemq.broker.ConnectionContext v; java.util.Map v; org.apache.activemq.broker.region.AbstractRegion v; java.lang.Object v; java.lang.String v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.MessagePull; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = new java.lang.IllegalArgumentException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("The subscription does not exist: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v, v); return v; } protected org.apache.activemq.broker.region.Destination lookup(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, boolean) throws java.lang.Exception { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; java.util.Map v; java.lang.String v; boolean v, v; javax.jms.JMSException v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.AbstractRegion v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.AbstractRegion; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: boolean; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke 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: if v != null goto label; v = virtualinvoke v.