public class org.apache.activemq.broker.region.Topic extends org.apache.activemq.broker.region.BaseDestination implements org.apache.activemq.thread.Task { protected static final org.slf4j.Logger LOG; private final org.apache.activemq.store.TopicMessageStore topicStore; protected final java.util.concurrent.CopyOnWriteArrayList consumers; private final java.util.concurrent.locks.ReentrantReadWriteLock dispatchLock; private org.apache.activemq.broker.region.policy.DispatchPolicy dispatchPolicy; private org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy subscriptionRecoveryPolicy; private final java.util.concurrent.ConcurrentMap durableSubscribers; private final org.apache.activemq.thread.TaskRunner taskRunner; private final org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactor; private final java.util.LinkedList messagesWaitingForSpace; private final java.lang.Runnable sendMessagesWaitingForSpaceTask; private final java.util.concurrent.atomic.AtomicBoolean expiryTaskInProgress; private final java.lang.Runnable expireMessagesWork; private final java.lang.Runnable expireMessagesTask; public void (org.apache.activemq.broker.BrokerService, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.store.TopicMessageStore, org.apache.activemq.broker.region.DestinationStatistics, org.apache.activemq.thread.TaskRunnerFactory) throws java.lang.Exception { org.apache.activemq.broker.region.Topic$1 v; org.apache.activemq.broker.region.Topic$7 v; org.apache.activemq.broker.region.Topic$6 v; java.util.concurrent.atomic.AtomicBoolean v; java.util.concurrent.locks.ReentrantReadWriteLock v; org.apache.activemq.broker.region.policy.RetainedMessageSubscriptionRecoveryPolicy v; java.lang.String v, v; java.util.LinkedList v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.broker.region.Topic v; java.util.concurrent.ConcurrentHashMap v; org.apache.activemq.broker.region.policy.SimpleDispatchPolicy v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.store.TopicMessageStore v; org.apache.activemq.thread.TaskRunner v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.broker.region.DestinationStatistics v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.BrokerService; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: org.apache.activemq.store.TopicMessageStore; v := @parameter: org.apache.activemq.broker.region.DestinationStatistics; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; specialinvoke v.(org.apache.activemq.broker.BrokerService,org.apache.activemq.store.MessageStore,org.apache.activemq.command.ActiveMQDestination,org.apache.activemq.broker.region.DestinationStatistics)>(v, v, v, v); v = new java.util.concurrent.CopyOnWriteArrayList; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.broker.region.policy.SimpleDispatchPolicy; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.LinkedList; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.broker.region.Topic$1; specialinvoke v.(org.apache.activemq.broker.region.Topic)>(v); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new org.apache.activemq.broker.region.Topic$6; specialinvoke v.(org.apache.activemq.broker.region.Topic)>(v); v. = v; v = new org.apache.activemq.broker.region.Topic$7; specialinvoke v.(org.apache.activemq.broker.region.Topic)>(v); v. = v; v. = v; v = new org.apache.activemq.broker.region.policy.RetainedMessageSubscriptionRecoveryPolicy; specialinvoke v.(org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy)>(null); v. = v; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Topic \u0001"); v = virtualinvoke v.(v, v); v. = v; v. = v; return; } public void initialize() throws java.lang.Exception { org.apache.activemq.store.MessageStore v, v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.broker.region.policy.LastImageSubscriptionRecoveryPolicy v; boolean v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.Topic; specialinvoke v.(); v = v.; v = staticinvoke (v); if v == 0 goto label; v = new org.apache.activemq.broker.region.policy.LastImageSubscriptionRecoveryPolicy; specialinvoke v.()>(); v. = v; virtualinvoke v.(1); label: v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: return; } public java.util.List getConsumers() { java.lang.Throwable v; org.apache.activemq.broker.region.Topic v; java.util.ArrayList v; java.util.concurrent.CopyOnWriteArrayList v, v; v := @this: org.apache.activemq.broker.region.Topic; v = v.; entermonitor v; label: v = new java.util.ArrayList; v = v.; specialinvoke v.(java.util.Collection)>(v); exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } public boolean lock(org.apache.activemq.broker.region.MessageReference, org.apache.activemq.broker.region.LockOwner) { org.apache.activemq.broker.region.LockOwner v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.broker.region.Topic v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.region.MessageReference; v := @parameter: org.apache.activemq.broker.region.LockOwner; return 1; } public void addSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription) throws java.lang.Exception { org.apache.activemq.util.SubscriptionKey v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.broker.ConnectionContext v; boolean v, v, v, v, v, v, v, v, v, v, v; java.util.concurrent.CopyOnWriteArrayList v, v, v, v, v, v, v, v, v, v; java.lang.Throwable v, v, v, v; org.apache.activemq.broker.region.Subscription v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.ConcurrentMap v; int v; org.apache.activemq.command.ConsumerInfo v, v, v; org.apache.activemq.broker.region.Topic v; java.util.Iterator v; org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = 0; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(v, v); v = v.; virtualinvoke v.(v); v = 1; specialinvoke v.(v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == 0 goto label; v = v.; interfaceinvoke v.(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 = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(v, v); v = v.; virtualinvoke v.(v); specialinvoke v.(v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: specialinvoke v.(v, v); interfaceinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; entermonitor v; label: v = 0; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = 0; goto label; label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = 1; label: if v != 0 goto label; v = v.; virtualinvoke v.(v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: return; 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 removeSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription, long) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.broker.region.Subscription v; long v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.ConsumerInfo v; boolean v, v; java.util.concurrent.CopyOnWriteArrayList v, v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v := @parameter: long; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == 0 goto label; specialinvoke v.(v, v, v); label: interfaceinvoke v.(v, v); return; catch java.lang.Throwable from label to label with label; } public void deleteSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.util.SubscriptionKey) throws java.lang.Exception { org.apache.activemq.broker.region.Topic v; org.apache.activemq.util.SubscriptionKey v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.store.TopicMessageStore v, v; java.lang.Object v; java.lang.String v, v; org.apache.activemq.broker.region.DestinationStatistics v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.util.SubscriptionKey; v = v.; if v == null goto label; v = v.; v = v.; v = v.; interfaceinvoke v.(v, v); v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(0, 0L); v = v.; virtualinvoke v.(v); label: return; } private boolean hasDurableSubChanged(org.apache.activemq.command.SubscriptionInfo, org.apache.activemq.command.ConsumerInfo) throws java.io.IOException { org.apache.activemq.command.SubscriptionInfo v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.command.ConsumerInfo v; boolean v, v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.command.SubscriptionInfo; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = specialinvoke v.(v, v); if v == 0 goto label; return 1; label: v = specialinvoke v.(v, v); return v; } private boolean hasNoLocalChanged(org.apache.activemq.command.SubscriptionInfo, org.apache.activemq.command.ConsumerInfo) throws java.io.IOException { org.apache.activemq.broker.BrokerService v; org.apache.activemq.command.SubscriptionInfo v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.broker.Broker v; org.apache.activemq.store.PersistenceAdapter v; org.apache.activemq.command.ConsumerInfo v; boolean v, v, v, v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.command.SubscriptionInfo; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v instanceof org.apache.activemq.store.NoLocalSubscriptionAware; if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v ^ v; if v == 0 goto label; return 1; label: return 0; } private boolean hasSelectorChanged(org.apache.activemq.command.SubscriptionInfo, org.apache.activemq.command.ConsumerInfo) { org.apache.activemq.command.SubscriptionInfo v; org.apache.activemq.broker.region.Topic v; java.lang.String v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v, v, v, v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.command.SubscriptionInfo; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = virtualinvoke v.(); if v == null goto label; v = 1; goto label; label: v = 0; label: v = virtualinvoke v.(); if v == null goto label; v = 1; goto label; label: v = 0; label: v = v ^ v; if v == 0 goto label; return 1; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; return 1; label: return 0; } public void activate(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.DurableTopicSubscription) throws java.lang.Exception { org.apache.activemq.broker.region.Topic$2 v; org.apache.activemq.filter.NonCachedMessageEvaluationContext v; org.apache.activemq.util.SubscriptionKey v, v; org.apache.activemq.broker.region.DurableTopicSubscription v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v; org.apache.activemq.broker.ConnectionContext v; boolean v, v, v, v, v; org.apache.activemq.command.ActiveMQDestination v, v, v; java.util.concurrent.CopyOnWriteArrayList v, v, v, v, v, v, v; java.lang.Throwable v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v; java.lang.String v, v, v, v; org.apache.activemq.command.ConsumerInfo v, v, v, v, v, v; org.apache.activemq.command.SubscriptionInfo v, v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.store.TopicMessageStore v, v, v, v, v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.DurableTopicSubscription; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; if v != null goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); v = specialinvoke v.(v, v); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); v = null; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; entermonitor v; label: v = v.; virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; virtualinvoke v.(v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v != null goto label; v = new org.apache.activemq.command.SubscriptionInfo; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; entermonitor v; label: v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = new org.apache.activemq.filter.NonCachedMessageEvaluationContext; specialinvoke v.()>(); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = new org.apache.activemq.broker.region.Topic$2; specialinvoke v.(org.apache.activemq.broker.region.Topic,org.apache.activemq.filter.MessageEvaluationContext,org.apache.activemq.broker.region.DurableTopicSubscription)>(v, v, v); interfaceinvoke v.(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; 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 deactivate(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.DurableTopicSubscription, java.util.List) throws java.lang.Exception { java.lang.Throwable v; java.util.List v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.broker.region.DurableTopicSubscription v; java.util.concurrent.CopyOnWriteArrayList v, v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.DurableTopicSubscription; v := @parameter: java.util.List; v = v.; entermonitor v; label: v = v.; virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: virtualinvoke v.(v, v, v); return; catch java.lang.Throwable from label to label with label; } public void recoverRetroactiveMessages(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription) throws java.lang.Exception { org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.command.ConsumerInfo v; boolean v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v, v); label: return; } public void send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message) throws java.lang.Exception { org.apache.activemq.broker.region.Topic$3 v; java.lang.Integer v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.state.ProducerState v; java.lang.Long v, v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.command.ProducerAck v, v; org.apache.activemq.broker.ProducerBrokerExchange v; java.lang.Throwable v; long v, v, v; org.apache.activemq.broker.Broker v; java.lang.String v, v, v, v, v, v; org.apache.activemq.broker.Connection v, v; java.io.IOException v; org.apache.activemq.command.ProducerId v, v, v, v; org.apache.activemq.management.CountStatisticImpl v, v; org.apache.activemq.usage.MemoryUsage v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; javax.jms.ResourceAllocationException v; org.apache.activemq.command.ActiveMQDestination v, v, v, v; org.apache.activemq.broker.region.DestinationStatistics v, v; java.util.concurrent.atomic.AtomicBoolean v; int v, v, v, v, v, v; java.util.LinkedList v, v; org.apache.activemq.broker.region.Topic v; org.slf4j.Logger v, v, v, v; org.apache.activemq.command.ProducerInfo v; org.apache.activemq.transaction.Transaction v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange; v := @parameter: org.apache.activemq.command.Message; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v, null); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.command.ProducerAck; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.ProducerId,int)>(v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); label: return; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v, v); virtualinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{}, Usage Manager memory limit reached {}. Producers will be throttled to the rate at which messages are removed from this destination to prevent flooding it. See http://activemq.apache.org/producer-flow-control.html for more info.", v, v); goto label; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{}, Usage Manager memory limit reached {}. Producers will be throttled to the rate at which messages are removed from this destination to prevent flooding it. See http://activemq.apache.org/producer-flow-control.html for more info.", v, v); label: v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new javax.jms.ResourceAllocationException; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Usage Manager memory limit (\u) reached. Rejecting send for producer (\u) to prevent flooding \u. See http://activemq.apache.org/producer-flow-control.html for more info"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v > 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; entermonitor v; label: v = v.; v = new org.apache.activemq.broker.region.Topic$3; specialinvoke v.(org.apache.activemq.broker.region.Topic,org.apache.activemq.command.Message,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.broker.ProducerBrokerExchange,boolean,org.apache.activemq.command.ProducerInfo)>(v, v, v, v, v, v); virtualinvoke v.(v); specialinvoke v.(); virtualinvoke v.(1); exitmonitor v; label: return; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = 0; label: v = v.; v = virtualinvoke v.(1000L); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Connection closed, send aborted."); throw v; label: if v <= 2 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = 0; v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = staticinvoke (v); interfaceinvoke v.("Waiting for space to send transacted message - transaction elements = {} need more space to commit. Message = {}", v, v); label: v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Usage Manager Memory Usage limit reached. Stopping producer (\u) to prevent flooding \u. See http://activemq.apache.org/producer-flow-control.html for more info"); virtualinvoke v.(v, v, v, v); label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); v = ; interfaceinvoke v.("Expired message: {}", v); return; label: virtualinvoke v.(v, v); virtualinvoke v.(v, v); if v == 0 goto label; v = new org.apache.activemq.command.ProducerAck; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.ProducerId,int)>(v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } synchronized void doMessageSend(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message) throws java.io.IOException, java.lang.Exception { org.apache.activemq.broker.region.Topic$4 v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.usage.SystemUsage v, v, v, v; boolean v, v, v, v, v, v, v, v; java.util.concurrent.CancellationException v; org.apache.activemq.command.MessageId v; javax.jms.ResourceAllocationException v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.ProducerBrokerExchange v; java.lang.Throwable v; long v, v; org.apache.activemq.store.ListenableFuture v; int v, v, v; java.lang.String v, v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.command.ProducerId v; org.apache.activemq.store.TopicMessageStore v, v; org.apache.activemq.usage.StoreUsage v, v, v; org.apache.activemq.transaction.Transaction v, v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange; v := @parameter: org.apache.activemq.command.Message; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = null; v = v.; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = specialinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("Persistent store is Full, \u0001% of \u. Stopping producer (\u) to prevent flooding \u. See http://activemq.apache.org/producer-flow-control.html for more info"); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new javax.jms.ResourceAllocationException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, v); label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); label: virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = new org.apache.activemq.broker.region.Topic$4; specialinvoke v.(org.apache.activemq.broker.region.Topic,org.apache.activemq.command.Message,org.apache.activemq.broker.ConnectionContext)>(v, v, v); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; label: return; catch java.lang.Throwable from label to label with label; catch java.util.concurrent.CancellationException from label to label with label; } private boolean canOptimizeOutPersistence() { org.apache.activemq.broker.region.Topic v; int v; boolean v; java.util.concurrent.ConcurrentMap v; v := @this: org.apache.activemq.broker.region.Topic; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public java.lang.String toString() { org.apache.activemq.broker.region.Topic v; int v; java.lang.String v, v; java.util.concurrent.CopyOnWriteArrayList v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.Topic; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Topic: destination=\u, subscriptions=\u0001"); return v; } public void acknowledge(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription, org.apache.activemq.command.MessageAck, org.apache.activemq.broker.region.MessageReference) throws java.io.IOException { org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.command.MessageAck v, v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.command.MessageId v; org.apache.activemq.util.SubscriptionKey v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.store.TopicMessageStore v, v; java.lang.String v, v; boolean v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v := @parameter: org.apache.activemq.command.MessageAck; v := @parameter: org.apache.activemq.broker.region.MessageReference; v = v.; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); interfaceinvoke v.(v, v, v, v, v); label: virtualinvoke v.(v, v); return; } public void gc() { org.apache.activemq.broker.region.Topic v; v := @this: org.apache.activemq.broker.region.Topic; return; } public org.apache.activemq.command.Message loadMessage(org.apache.activemq.command.MessageId) throws java.io.IOException { org.apache.activemq.command.Message v; org.apache.activemq.store.TopicMessageStore v, v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.command.MessageId v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: org.apache.activemq.command.MessageId; v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(v); goto label; label: v = null; label: return v; } public void start() throws java.lang.Exception { org.apache.activemq.broker.region.Topic v; java.util.concurrent.atomic.AtomicBoolean v; long v, v; java.lang.Runnable v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy v; byte v; org.apache.activemq.thread.Scheduler v; org.apache.activemq.usage.MemoryUsage v, v; boolean v, v; v := @this: org.apache.activemq.broker.region.Topic; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; v = v.; interfaceinvoke v.(); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); label: return; } public void stop() throws java.lang.Exception { org.apache.activemq.broker.region.Topic v; java.util.concurrent.atomic.AtomicBoolean v; java.lang.Runnable v; org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy v; org.apache.activemq.store.TopicMessageStore v, v; org.apache.activemq.thread.TaskRunner v, v; org.apache.activemq.thread.Scheduler v; org.apache.activemq.usage.MemoryUsage v, v; boolean v; v := @this: org.apache.activemq.broker.region.Topic; v = v.; v = virtualinvoke v.(1, 0); if v == 0 goto label; v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: v = v.; interfaceinvoke v.(); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: v = v.; v = v.; virtualinvoke v.(v); label: return; } public org.apache.activemq.command.Message[] browse() { java.lang.Object[] v; org.apache.activemq.broker.region.Topic v; org.apache.activemq.command.Message[] v; int v, v; java.util.ArrayList v; v := @this: org.apache.activemq.broker.region.Topic; v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v, v); v = interfaceinvoke v.(); v = newarray (org.apache.activemq.command.Message)[v]; v = interfaceinvoke v.(v); return v; } public void doBrowse(java.util.List, int) { java.lang.Throwable v; org.apache.activemq.broker.region.Topic$5 v; java.util.ArrayList v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; int v, v, v, v; java.lang.String v; boolean v, v, v, v; org.apache.activemq.broker.region.Topic v; org.slf4j.Logger v; java.util.Iterator v, v; org.apache.activemq.command.Message[] v; java.util.Collection v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy v; java.util.List v; org.apache.activemq.store.TopicMessageStore v, v; java.lang.Object v, v; v := @this: org.apache.activemq.broker.region.Topic; v := @parameter: java.util.List; v := @parameter: int; label: v = v.; if v == null goto label; v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = new org.apache.activemq.broker.region.Topic$5; specialinvoke v.(org.apache.activemq.broker.region.Topic,java.util.List,java.util.List,int)>(v, v, v, v); interfaceinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.