public class org.apache.activemq.broker.region.Queue extends org.apache.activemq.broker.region.BaseDestination implements org.apache.activemq.thread.Task, org.apache.activemq.usage.UsageListener, org.apache.activemq.store.IndexListener { protected static final org.slf4j.Logger LOG; protected final org.apache.activemq.thread.TaskRunnerFactory taskFactory; protected org.apache.activemq.thread.TaskRunner taskRunner; private final java.util.concurrent.locks.ReentrantReadWriteLock consumersLock; protected final java.util.List consumers; private final java.util.concurrent.locks.ReentrantReadWriteLock messagesLock; protected org.apache.activemq.broker.region.cursors.PendingMessageCursor messages; private final java.util.concurrent.locks.ReentrantReadWriteLock pagedInMessagesLock; private final org.apache.activemq.broker.region.cursors.PendingList pagedInMessages; private final java.util.concurrent.locks.ReentrantReadWriteLock pagedInPendingDispatchLock; protected org.apache.activemq.broker.region.cursors.QueueDispatchPendingList dispatchPendingList; private java.util.concurrent.atomic.AtomicInteger pendingSends; private org.apache.activemq.broker.region.group.MessageGroupMap messageGroupOwners; private org.apache.activemq.broker.region.policy.DispatchPolicy dispatchPolicy; private org.apache.activemq.broker.region.group.MessageGroupMapFactory messageGroupMapFactory; final java.util.concurrent.locks.Lock sendLock; private java.util.concurrent.ExecutorService executor; private final java.util.Map messagesWaitingForSpace; private boolean useConsumerPriority; private boolean strictOrderDispatch; private final org.apache.activemq.broker.region.QueueDispatchSelector dispatchSelector; private boolean optimizedDispatch; private boolean iterationRunning; private boolean firstConsumer; private int timeBeforeDispatchStarts; private int consumersBeforeDispatchStarts; private java.util.concurrent.CountDownLatch consumersBeforeStartsLatch; private final java.util.concurrent.atomic.AtomicLong pendingWakeups; private boolean allConsumersExclusiveByDefault; private volatile boolean resetNeeded; 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; private final java.lang.Object iteratingMutex; java.util.concurrent.DelayQueue flowControlTimeoutMessages; private final org.apache.activemq.broker.region.Queue$FlowControlTimeoutTask flowControlTimeoutTask; private final java.util.Comparator orderedCompare; java.util.concurrent.ConcurrentLinkedQueue browserSubscriptions; private volatile javax.jms.ResourceAllocationException sendMemAllocationException; private final java.util.LinkedList indexOrderedCursorUpdates; public boolean singlePendingSend() { java.util.concurrent.atomic.AtomicInteger v; org.apache.activemq.broker.region.Queue v; int v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; v = virtualinvoke v.(); if v > 1 goto label; v = 1; goto label; label: v = 0; label: return v; } public void (org.apache.activemq.broker.BrokerService, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.store.MessageStore, org.apache.activemq.broker.region.DestinationStatistics, org.apache.activemq.thread.TaskRunnerFactory) throws java.lang.Exception { org.apache.activemq.broker.region.cursors.QueueDispatchPendingList v; org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy v; java.util.concurrent.atomic.AtomicBoolean v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v; java.util.ArrayList v; org.apache.activemq.broker.region.Queue$FlowControlTimeoutTask v; java.util.LinkedHashMap v; org.apache.activemq.broker.region.group.CachedMessageGroupMapFactory v; java.util.concurrent.atomic.AtomicInteger v; java.util.concurrent.DelayQueue v; org.apache.activemq.broker.region.cursors.OrderedPendingList v; java.util.LinkedList v; org.apache.activemq.store.MessageStore v; org.apache.activemq.broker.BrokerService v; java.util.concurrent.locks.ReentrantLock v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.broker.region.Queue$1 v; org.apache.activemq.broker.region.Queue$2 v; org.apache.activemq.broker.region.Queue$3 v; org.apache.activemq.broker.region.Queue$4 v; org.apache.activemq.command.ActiveMQDestination v; java.util.concurrent.atomic.AtomicLong v; org.apache.activemq.thread.TaskRunnerFactory v; java.lang.Object v; org.apache.activemq.broker.region.QueueDispatchSelector v; org.apache.activemq.broker.region.DestinationStatistics v; java.util.concurrent.ConcurrentLinkedQueue v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.BrokerService; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: org.apache.activemq.store.MessageStore; 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.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.(int)>(50); v. = v; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.broker.region.cursors.OrderedPendingList; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.broker.region.cursors.QueueDispatchPendingList; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v = new org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.broker.region.group.CachedMessageGroupMapFactory; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.locks.ReentrantLock; specialinvoke v.()>(); v. = v; v = new java.util.LinkedHashMap; specialinvoke v.()>(); v. = v; v. = 1; v. = 0; v. = 0; v. = 0; v. = 0; v. = 0; v. = 0; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v. = 0; v = new org.apache.activemq.broker.region.Queue$1; specialinvoke v.(org.apache.activemq.broker.region.Queue)>(v); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new org.apache.activemq.broker.region.Queue$2; specialinvoke v.(org.apache.activemq.broker.region.Queue)>(v); v. = v; v = new org.apache.activemq.broker.region.Queue$3; specialinvoke v.(org.apache.activemq.broker.region.Queue)>(v); v. = v; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.DelayQueue; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.broker.region.Queue$FlowControlTimeoutTask; specialinvoke v.(org.apache.activemq.broker.region.Queue)>(v); v. = v; v = new org.apache.activemq.broker.region.Queue$4; specialinvoke v.(org.apache.activemq.broker.region.Queue)>(v); v. = v; v = new java.util.concurrent.ConcurrentLinkedQueue; specialinvoke v.()>(); v. = v; v. = null; v = new java.util.LinkedList; specialinvoke v.()>(); v. = v; v. = v; v = new org.apache.activemq.broker.region.QueueDispatchSelector; specialinvoke v.(org.apache.activemq.command.ActiveMQDestination)>(v); v. = v; if v == null goto label; interfaceinvoke v.(v); label: return; } public java.util.List getConsumers() { java.lang.Throwable v; org.apache.activemq.broker.region.Queue v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.ArrayList v; java.util.List v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = new java.util.ArrayList; v = v.; specialinvoke v.(java.util.Collection)>(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 setPrioritizedMessages(boolean) { org.apache.activemq.broker.region.cursors.QueueDispatchPendingList v; org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: boolean; specialinvoke v.(v); v = v.; virtualinvoke v.(v); return; } public void initialize() throws java.lang.Exception { org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.usage.MemoryUsage v, v; org.apache.activemq.usage.SystemUsage v, v, v; boolean v, v, v, v, v, v, v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.broker.region.cursors.StoreQueueCursor v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.broker.region.Queue$BatchMessageRecoveryListener v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.DestinationStatistics v; org.apache.activemq.broker.Broker v, v; int v, v, v, v, v; java.lang.String v, v; org.apache.activemq.broker.region.cursors.VMPendingMessageCursor v; org.apache.activemq.store.MessageStore v, v, v, v, v; org.apache.activemq.thread.TaskRunner v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; if v != null goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v == null goto label; v = v.; if v != null goto label; label: v = new org.apache.activemq.broker.region.cursors.VMPendingMessageCursor; v = virtualinvoke v.(); specialinvoke v.(boolean)>(v); v. = v; goto label; label: v = new org.apache.activemq.broker.region.cursors.StoreQueueCursor; v = v.; specialinvoke v.(org.apache.activemq.broker.Broker,org.apache.activemq.broker.region.Queue)>(v, v); v. = v; label: v = v.; v = v instanceof org.apache.activemq.broker.region.cursors.VMPendingMessageCursor; if v == 0 goto label; v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Queue:\u0001"); v = virtualinvoke v.(v, v); v. = v; specialinvoke v.(); v = v.; if v == null goto label; v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); if v <= 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.broker.region.Queue$BatchMessageRecoveryListener; specialinvoke v.(org.apache.activemq.broker.region.Queue,int)>(v, v); label: virtualinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } public void addSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription) throws java.lang.Exception { java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v, v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v, v, v; byte v, v, v; java.lang.Long v, v, v; boolean v, v, v, v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.ActiveMQDestination v; java.util.concurrent.CountDownLatch v, v, v; java.util.List v; org.apache.activemq.broker.region.QueueDispatchSelector v, v; org.apache.activemq.broker.region.DestinationStatistics v, v, v; java.util.concurrent.ConcurrentLinkedQueue v; java.lang.Throwable v, v; java.lang.Object[] v; org.apache.activemq.broker.region.Subscription v, v; long v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v; int v, v, v, v; java.lang.String v; org.apache.activemq.command.ConsumerInfo v, v, v, v; org.slf4j.Logger v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v = ; v = newarray (java.lang.Object)[5]; v = virtualinvoke v.(); v = virtualinvoke v.(); v[0] = v; v[1] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[4] = v; interfaceinvoke v.("{} add sub: {}, dequeues: {}, dispatched: {}, inflight: {}", v); specialinvoke v.(v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: interfaceinvoke v.(v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v. = 1; v = v.; if v == 0 goto label; v = new java.util.concurrent.CountDownLatch; v = v.; v = v - 1; specialinvoke v.(int)>(v); v. = v; goto label; label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: specialinvoke v.(v); 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.(); if v != null goto label; v = v; goto label; label: v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 127 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v <= v goto label; label: v = v; label: v = v.; virtualinvoke 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 instanceof org.apache.activemq.broker.region.QueueBrowserSubscription; if v == 0 goto label; virtualinvoke v.(); v = v.; virtualinvoke v.(v); label: v = v.; if v != 0 goto label; 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: v = v.; if v == 0 goto label; virtualinvoke v.(); label: return; 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 { org.apache.activemq.broker.region.cursors.QueueDispatchPendingList v, v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.broker.ConnectionContext v; byte v, v, v, v, v, v, v; java.lang.Long v, v, v, v, v, v; org.apache.activemq.broker.BrokerService v, v; org.apache.activemq.broker.region.QueueDispatchSelector v, v, v; java.lang.Throwable v, v; java.lang.Object[] v; org.apache.activemq.broker.region.group.MessageGroupMap v; long v, v, v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v; java.lang.String v; org.apache.activemq.command.ConsumerInfo v, v, v, v, v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v, v, v; org.apache.activemq.management.CountStatisticImpl v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v, v; org.apache.activemq.command.ActiveMQDestination v, v; java.util.List v, v, v, v; org.apache.activemq.broker.region.LockOwner v; org.apache.activemq.broker.region.DestinationStatistics v, v, v; java.util.concurrent.ConcurrentLinkedQueue v; org.apache.activemq.broker.region.Subscription v, v, v, v; org.apache.activemq.broker.region.cursors.OrderedPendingList v; org.apache.activemq.broker.region.MessageReference v, v; org.slf4j.Logger v, v; java.util.Iterator v, v, v, v; java.lang.Object v, v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v := @parameter: long; specialinvoke v.(v, v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = ; v = newarray (java.lang.Object)[7]; v = virtualinvoke v.(); v = virtualinvoke v.(); v[0] = v; v[1] = v; v = staticinvoke (v); v[2] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[4] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[5] = v; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); v = staticinvoke (v); v[6] = v; interfaceinvoke v.("{} remove sub: {}, lastDeliveredSeqId: {}, dequeues: {}, dispatched: {}, inflight: {}, groups: {}", v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: specialinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != v goto label; v = null; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v <= v goto label; label: v = v; goto label; label: v = v.; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = null; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v <= v goto label; label: v = v; goto label; label: v = v.; virtualinvoke v.(v); label: v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); v = 0; v = null; v = interfaceinvoke v.(v, v); v = v cmp -1L; if v <= 0 goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v = v; v = 1; v = ; v = staticinvoke (v); v = interfaceinvoke v.(); interfaceinvoke v.("found lastDeliveredSeqID: {}, message reference: {}", v, v); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); if v != v goto label; interfaceinvoke v.(); v = v cmp -2L; if v != 0 goto label; interfaceinvoke v.(); goto label; label: if v == 0 goto label; interfaceinvoke v.(); label: if v != v goto label; v = 0; label: v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); goto label; label: v = v.; v = v.; if v == 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: virtualinvoke v.(v, v); v = v instanceof org.apache.activemq.broker.region.QueueBrowserSubscription; if v == 0 goto label; virtualinvoke v.(); v = v.; virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.activemq.broker.region.cursors.OrderedPendingList; specialinvoke v.()>(); specialinvoke 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.; if v != 0 goto label; 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: v = v.; if v == 0 goto label; virtualinvoke v.(); label: return; catch java.lang.Throwable from label to label with label; 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 { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.state.ProducerState v, v; byte v; java.lang.Long v, v, v, v; org.apache.activemq.broker.region.Queue$TimeoutMessage v; java.util.Map v, v; org.apache.activemq.usage.SystemUsage v, v, v; org.apache.activemq.command.ProducerAck v, v; org.apache.activemq.broker.ProducerBrokerExchange v, v; java.lang.Throwable v, v; java.lang.Object[] v, v; long v, v, v, v, v, v; org.apache.activemq.broker.Broker v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.Connection v, v; org.apache.activemq.command.ProducerId v, v, v; org.apache.activemq.broker.region.Queue$FlowControlTimeoutTask v, v, v; org.apache.activemq.management.CountStatisticImpl v, v, v; org.apache.activemq.usage.MemoryUsage v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v; javax.jms.ResourceAllocationException v, v; javax.jms.JMSException v; org.apache.activemq.broker.region.Queue$5 v; org.apache.activemq.command.ActiveMQDestination v, v, v, v, v; org.apache.activemq.broker.region.DestinationStatistics v, v, v; int v, v, v, v; java.util.concurrent.DelayQueue v; org.slf4j.Logger v, v, v, v; org.apache.activemq.command.ProducerInfo v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange; v := @parameter: org.apache.activemq.command.Message; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v != null goto label; v = ; interfaceinvoke v.("Send failed for: {}, missing producer state for: {}", v, v); v = new javax.jms.JMSException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot send message to \u with invalid (null) producer state"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); 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; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v, v, null); 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 = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[1] = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Usage Manager Memory Limit ({}) reached on {}, size {}. 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); goto label; label: v = ; v = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[1] = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Usage Manager Memory Limit ({}) reached on {}, size {}. 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); label: v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; if v != null goto label; entermonitor v; label: v = v.; if v != null goto label; v = new javax.jms.ResourceAllocationException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Usage Manager Memory Limit reached on \u. See http://activemq.apache.org/producer-flow-control.html for more info"); specialinvoke v.(java.lang.String)>(v); v = v; v. = v; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: throw v; label: v = virtualinvoke v.(); if v > 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u Producer Flow Control Timeout Task"); virtualinvoke v.(v); v = v.; virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.broker.region.Queue$5; specialinvoke v.(org.apache.activemq.broker.region.Queue,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); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(1); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = v cmp 0L; if v == 0 goto label; v = v.; v = new org.apache.activemq.broker.region.Queue$TimeoutMessage; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.broker.region.Queue,org.apache.activemq.command.Message,org.apache.activemq.broker.ConnectionContext,long)>(v, v, v, v); virtualinvoke v.(v); label: 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 = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Usage Manager Memory Limit reached. Producer (\u) stopped 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 = ; interfaceinvoke v.("Expired message: {}", v); v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v, v, null); return; label: 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; catch java.lang.Throwable from label to label with label; } private void registerCallbackForNotFullNotification() { org.apache.activemq.broker.region.Queue v; org.apache.activemq.usage.MemoryUsage v; java.lang.Runnable v, v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; interfaceinvoke v.(); label: return; } public void onAdd(org.apache.activemq.store.IndexListener$MessageContext) { java.lang.Throwable v; org.apache.activemq.store.IndexListener$MessageContext v; org.apache.activemq.broker.region.Queue v; java.util.LinkedList v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.store.IndexListener$MessageContext; v = v.; entermonitor v; label: v = v.; virtualinvoke 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; } public void rollbackPendingCursorAdditions(org.apache.activemq.command.MessageId) { java.lang.Throwable v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v, v; java.lang.Runnable v, v; org.apache.activemq.command.Message v; int v, v; java.lang.Object v; java.util.LinkedList v, v, v, v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.command.MessageId; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); v = v - 1; label: if v < 0 goto label; v = v.; v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); goto label; label: v = v - 1; goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } private void doPendingCursorAdditions() throws java.lang.Exception { java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; java.lang.Runnable v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v, v, v, v, v, v; java.lang.Long v; boolean v, v, v, v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v, v, v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; java.lang.Throwable v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; int v; java.util.LinkedList v, v, v, v, v; org.slf4j.Logger v; java.util.Iterator v, v; java.util.concurrent.locks.Lock v, v, v; java.lang.Object v, v, v, v, v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v = new java.util.LinkedList; specialinvoke v.()>(); v = v.; interfaceinvoke v.(); label: v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); label: if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v instanceof java.lang.Long; if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (-1L); v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{} messageStore indicated duplicate add attempt for {}, suppressing duplicate dispatch", v, v); goto label; label: virtualinvoke v.(v); label: v = v.; virtualinvoke v.(); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; v. = 1; label: v = v.; if v == null goto label; v = 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.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; if v != 0 goto label; v = v.; v = v.; virtualinvoke v.(v, v); goto label; label: virtualinvoke v.(); 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; } void doMessageSend(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message) throws java.io.IOException, java.lang.Exception { java.util.concurrent.atomic.AtomicBoolean v; long v; org.apache.activemq.broker.region.PendingMarshalUsageTracker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.store.ListenableFuture v; java.util.concurrent.atomic.AtomicInteger v, v; boolean v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.MessageStore v, v, v; java.util.concurrent.CancellationException v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v, v, v; java.lang.Exception v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.ProducerBrokerExchange v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange; v := @parameter: org.apache.activemq.command.Message; v = virtualinvoke v.(); v = null; virtualinvoke v.(); v = v.; virtualinvoke v.(); label: specialinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(null); label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); v = new org.apache.activemq.broker.region.PendingMarshalUsageTracker; specialinvoke v.(org.apache.activemq.command.Message)>(v); interfaceinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v. = 1; v = v.; virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = specialinvoke v.(v, v); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; label: if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; label: return; catch java.lang.Exception from label to label with label; catch java.util.concurrent.CancellationException from label to label with label; } private boolean tryOrderedCursorAdd(org.apache.activemq.command.Message, org.apache.activemq.broker.ConnectionContext) throws java.lang.Exception { org.apache.activemq.store.MessageStore v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.store.IndexListener$MessageContext v; org.apache.activemq.broker.region.Queue$CursorAddSync v; org.apache.activemq.transaction.Transaction v; boolean v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.command.Message; v := @parameter: org.apache.activemq.broker.ConnectionContext; v = 1; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = new org.apache.activemq.broker.region.Queue$CursorAddSync; v = new org.apache.activemq.store.IndexListener$MessageContext; specialinvoke v.(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,java.lang.Runnable)>(v, v, null); specialinvoke v.(org.apache.activemq.broker.region.Queue,org.apache.activemq.store.IndexListener$MessageContext)>(v, v); virtualinvoke v.(v); goto label; label: v = v.; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; specialinvoke v.(); goto label; label: v = specialinvoke v.(v); virtualinvoke v.(v, v); label: return v; } private void checkUsage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message) throws javax.jms.ResourceAllocationException, java.io.IOException, java.lang.InterruptedException { org.apache.activemq.usage.TempUsage v, v, v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.usage.SystemUsage v, v, v, v, v, v, v, v; boolean v, v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v; org.apache.activemq.broker.ProducerBrokerExchange v; long v, v; int v, v, v, v; java.lang.String v, v, v, v; org.apache.activemq.store.MessageStore v; org.apache.activemq.command.ProducerId v, v; org.apache.activemq.usage.StoreUsage v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange; v := @parameter: org.apache.activemq.command.Message; v = virtualinvoke v.(); if v == 0 goto label; v = v.; if v == null 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 = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, v); goto label; label: v = v.; v = interfaceinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); 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) ("Temp 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 = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); label: return; } private void expireMessages() { org.slf4j.Logger v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.ActiveMQDestination v, v; int v; java.lang.String v, v; org.apache.activemq.broker.util.InsertionCountList v; v := @this: org.apache.activemq.broker.region.Queue; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("{} expiring messages ..", v); v = new org.apache.activemq.broker.util.InsertionCountList; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v, v); specialinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("{} expiring messages done.", v); return; } public void gc() { org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; return; } 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.store.MessageStore v, v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.command.MessageAck v, v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.broker.ConnectionContext v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; 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; virtualinvoke v.(v, v); v = v.; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(v, v); interfaceinvoke v.(v, v); label: return; } org.apache.activemq.command.Message loadMessage(org.apache.activemq.command.MessageId) throws java.io.IOException { org.apache.activemq.store.MessageStore v, v; org.apache.activemq.command.Message v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.command.MessageId; v = null; v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: return v; } public long getPendingMessageSize() { java.lang.Throwable v; org.apache.activemq.broker.region.Queue v; long v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke 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 long getPendingMessageCount() { org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.broker.region.Queue v; long v; org.apache.activemq.broker.region.DestinationStatistics v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public java.lang.String toString() { org.apache.activemq.broker.region.Queue v; long v; org.apache.activemq.command.ActiveMQDestination v; java.util.List v; org.apache.activemq.management.CountStatisticImpl v; int v, v, v; org.apache.activemq.usage.MemoryUsage v; java.lang.String v, v; java.util.LinkedList v; org.apache.activemq.broker.region.DestinationStatistics v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v) ("\u, subscriptions=\u, memory=\u0001%, size=\u, pending=\u0001"); return v; } public void start() throws java.lang.Exception { org.apache.activemq.usage.TempUsage v, v; java.util.concurrent.atomic.AtomicBoolean v; long v, v; java.lang.Runnable v; byte v; org.apache.activemq.usage.MemoryUsage v, v, v; org.apache.activemq.usage.SystemUsage v, v, v, v, v; boolean v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.usage.StoreUsage v, v; org.apache.activemq.thread.Scheduler v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); label: specialinvoke v.(0); label: return; } public void stop() throws java.lang.Exception { org.apache.activemq.usage.TempUsage v, v; java.lang.Runnable v; org.apache.activemq.broker.region.Queue$FlowControlTimeoutTask v, v; org.apache.activemq.usage.MemoryUsage v, v, v; org.apache.activemq.usage.SystemUsage v, v, v, v, v; boolean v, v, v; org.apache.activemq.broker.region.Queue v; java.util.Collection v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v; org.apache.activemq.broker.region.cursors.PendingList v, v; java.util.concurrent.atomic.AtomicBoolean v; java.util.concurrent.ExecutorService v, v; org.apache.activemq.store.MessageStore v, v; java.util.Iterator v; org.apache.activemq.thread.TaskRunner v, v; org.apache.activemq.usage.StoreUsage v, v; org.apache.activemq.thread.Scheduler v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.Queue; 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.; if v == null goto label; v = v.; staticinvoke (v); v. = null; label: v = v.; v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(); label: v = v.; if v == null goto label; v = v.; interfaceinvoke 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.; interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: return; } public org.apache.activemq.command.ActiveMQDestination getActiveMQDestination() { org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } public org.apache.activemq.broker.region.group.MessageGroupMap getMessageGroupOwners() { org.apache.activemq.broker.region.Queue v; org.apache.activemq.broker.region.group.MessageGroupMap v, v, v, v; org.apache.activemq.broker.region.group.MessageGroupMapFactory v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; if v != null goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); v. = v; v = v.; interfaceinvoke v.(v); label: v = v.; return v; } public org.apache.activemq.broker.region.policy.DispatchPolicy getDispatchPolicy() { org.apache.activemq.broker.region.policy.DispatchPolicy v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } public void setDispatchPolicy(org.apache.activemq.broker.region.policy.DispatchPolicy) { org.apache.activemq.broker.region.policy.DispatchPolicy v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.policy.DispatchPolicy; v. = v; return; } public org.apache.activemq.broker.region.group.MessageGroupMapFactory getMessageGroupMapFactory() { org.apache.activemq.broker.region.group.MessageGroupMapFactory v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } public void setMessageGroupMapFactory(org.apache.activemq.broker.region.group.MessageGroupMapFactory) { org.apache.activemq.broker.region.group.MessageGroupMapFactory v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.group.MessageGroupMapFactory; v. = v; return; } public org.apache.activemq.broker.region.cursors.PendingMessageCursor getMessages() { org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } public void setMessages(org.apache.activemq.broker.region.cursors.PendingMessageCursor) { org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.cursors.PendingMessageCursor; v. = v; return; } public boolean isUseConsumerPriority() { org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } public void setUseConsumerPriority(boolean) { org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: boolean; v. = v; return; } public boolean isStrictOrderDispatch() { org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } public void setStrictOrderDispatch(boolean) { org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: boolean; v. = v; return; } public boolean isOptimizedDispatch() { org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } public void setOptimizedDispatch(boolean) { org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: boolean; v. = v; return; } public int getTimeBeforeDispatchStarts() { int v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } public void setTimeBeforeDispatchStarts(int) { int v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: int; v. = v; return; } public int getConsumersBeforeDispatchStarts() { int v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } public void setConsumersBeforeDispatchStarts(int) { int v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: int; v. = v; return; } public void setAllConsumersExclusiveByDefault(boolean) { org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: boolean; v. = v; return; } public boolean isAllConsumersExclusiveByDefault() { org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } public boolean isResetNeeded() { org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; return v; } private org.apache.activemq.broker.region.QueueMessageReference createMessageReference(org.apache.activemq.command.Message) { org.apache.activemq.command.Message v; org.apache.activemq.broker.region.IndirectMessageReference v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.command.Message; v = new org.apache.activemq.broker.region.IndirectMessageReference; specialinvoke v.(org.apache.activemq.command.Message)>(v); return v; } public org.apache.activemq.command.Message[] browse() { java.lang.Object[] v; org.apache.activemq.command.Message[] v; org.apache.activemq.broker.region.Queue v; int v, v; java.util.ArrayList v; v := @this: org.apache.activemq.broker.region.Queue; 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.cursors.QueueDispatchPendingList v; org.apache.activemq.broker.region.cursors.PendingList v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; int v, v, v, v, v; org.apache.activemq.usage.MemoryUsage v; boolean v, v, v; org.slf4j.Logger v; org.apache.activemq.broker.BrokerStoppedException v; org.apache.activemq.broker.region.Queue v; java.lang.Exception v; java.util.List v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: java.util.List; v := @parameter: int; v = virtualinvoke v.(); label: if v <= 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = v / v; v = 1 + 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 = specialinvoke v.(v); if v == 0 goto label; v = v; v = v - 1; if v <= 0 goto label; v = v.; v = virtualinvoke v.(110); if v != 0 goto label; v = 1; goto label; label: v = 0; label: virtualinvoke v.(v, v); goto label; label: v = v.; v = v.; virtualinvoke v.(v, v, v, v, v, "redeliveredWaitingDispatch+pagedInPendingDispatch"); v = v.; v = v.; virtualinvoke v.(v, v, v, v, v, "pagedInMessages"); label: goto label; label: v := @caughtexception; goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Problem retrieving message for browse", v); label: return; catch java.lang.Throwable from label to label with label; catch org.apache.activemq.broker.BrokerStoppedException from label to label with label; catch java.lang.Exception from label to label with label; } protected void doBrowseList(java.util.List, int, org.apache.activemq.broker.region.cursors.PendingList, java.util.concurrent.locks.ReentrantReadWriteLock, org.apache.activemq.broker.ConnectionContext, java.lang.String) throws java.lang.Exception { java.lang.Throwable v, v; org.apache.activemq.broker.region.cursors.PendingList v; java.util.concurrent.locks.ReentrantReadWriteLock v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; java.util.ArrayList v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; int v; java.lang.String v; boolean v, v; org.slf4j.Logger v; java.util.Iterator v; org.apache.activemq.broker.region.Queue v; java.util.Collection v; java.util.List v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: java.util.List; v := @parameter: int; v := @parameter: org.apache.activemq.broker.region.cursors.PendingList; v := @parameter: java.util.concurrent.locks.ReentrantReadWriteLock; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: java.lang.String; v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(); label: v = interfaceinvoke v.(); specialinvoke v.(v, v, v, v); label: v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = ; interfaceinvoke v.("expiring from {}: {}", v, v); virtualinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); virtualinvoke v.(); label: interfaceinvoke v.(v); label: v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: interfaceinvoke v.(); goto label; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private boolean shouldPageInMoreForBrowse(int) { java.lang.Integer v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v, v, v, v; org.apache.activemq.usage.MemoryUsage v; boolean v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v; java.lang.Throwable v, v; java.lang.Object[] v; org.apache.activemq.broker.region.cursors.PendingList v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v; int v, v, v, v, v; org.slf4j.Logger v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: int; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke 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.; v = virtualinvoke v.(); virtualinvoke v.(); label: 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: v = ; v = newarray (java.lang.Object)[4]; v = staticinvoke (v); v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; interfaceinvoke v.("max {}, alreadyPagedIn {}, messagesCount {}, memoryUsage {}%", v); if v == 0 goto label; if v >= v goto label; if v >= v goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private void addAll(java.util.Collection, java.util.List, int, java.util.List) throws java.lang.Exception { java.util.Iterator v; org.apache.activemq.broker.region.Queue v; java.util.Collection v; java.util.List v, v; org.apache.activemq.broker.region.LockOwner v; org.apache.activemq.command.Message v, v; int v, v; java.lang.Object v; boolean v, v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: java.util.Collection; v := @parameter: java.util.List; v := @parameter: int; v := @parameter: java.util.List; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v >= v goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v != null goto label; interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: return; } public org.apache.activemq.broker.region.QueueMessageReference getMessage(java.lang.String) { java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v; org.apache.activemq.command.Message v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v, v; boolean v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v, v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v, v, v, v; java.lang.Throwable v, v, v; org.apache.activemq.broker.region.cursors.PendingList v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v, v, v; java.lang.String v; org.apache.activemq.broker.region.QueueMessageReference v; org.apache.activemq.broker.region.MessageReference v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: java.lang.String; v = new org.apache.activemq.command.MessageId; specialinvoke v.(java.lang.String)>(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return 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.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; interfaceinvoke v.(); label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = specialinvoke v.(v); interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = v.; interfaceinvoke v.(); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return v; label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw 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 null; 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 purge() throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v, v, v, v; byte v, v; java.lang.Long v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; boolean v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v; java.util.Collection v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.DestinationStatistics v, v, v, v; java.lang.Throwable v, v; java.lang.Object[] v; org.apache.activemq.broker.region.cursors.PendingList v; long v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.ArrayList v; int v; java.lang.String v; org.apache.activemq.broker.region.MessageReference v; org.slf4j.Logger v; java.util.Iterator v; java.io.IOException v; java.util.concurrent.locks.Lock v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v = virtualinvoke v.(); label: v = v.; interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); label: v = virtualinvoke v.(); specialinvoke v.(1, 0, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = new java.util.ArrayList; v = v.; v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(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 = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); label: virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; goto label; label: v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp 0L; if v > 0 goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v = virtualinvoke v.(); v[0] = v; v = staticinvoke (v); v[1] = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; interfaceinvoke v.("{} after purge of {} messages, message count stats report: {}", v); label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; catch java.lang.Throwable from label to label with label; } public void clearPendingMessages(int) { java.lang.Throwable v; org.apache.activemq.command.ActiveMQMessage v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; int v, v; boolean v; org.slf4j.Logger v; org.apache.activemq.broker.region.Queue v; java.lang.Exception v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: int; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = new org.apache.activemq.command.ActiveMQMessage; specialinvoke v.()>(); virtualinvoke v.(1); v = 0; label: if v >= v goto label; label: v = v.; interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unexpected exception on tracking pending message additions", v); label: v = v + 1; goto label; label: v = v.; if v == 0 goto label; v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v. = 0; goto label; label: v = v.; interfaceinvoke v.(); label: specialinvoke 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.Exception from label to label with label; catch java.lang.Throwable from label to label with label; } public boolean removeMessage(java.lang.String) throws java.lang.Exception { org.apache.activemq.broker.region.Queue v; int v; java.lang.String v; org.apache.activemq.broker.region.MessageReferenceFilter v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: java.lang.String; v = virtualinvoke v.(v); v = virtualinvoke v.(v, 1); if v <= 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public int removeMatchingMessages(java.lang.String) throws java.lang.Exception { org.apache.activemq.broker.region.Queue v; int v, v; java.lang.String v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: java.lang.String; v = (int) -1; v = virtualinvoke v.(v, v); return v; } public int removeMatchingMessages(java.lang.String, int) throws java.lang.Exception { org.apache.activemq.broker.region.Queue v; int v, v; java.lang.String v; org.apache.activemq.broker.region.MessageReferenceFilter v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: java.lang.String; v := @parameter: int; v = virtualinvoke v.(v); v = virtualinvoke v.(v, v); return v; } public int removeMatchingMessages(org.apache.activemq.broker.region.MessageReferenceFilter, int) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.region.cursors.PendingList v; long v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v; java.util.ArrayList v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v; byte v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v, v; int v, v, v; java.util.LinkedHashSet v; boolean v, v, v; org.apache.activemq.broker.region.MessageReference v; java.util.Iterator v; org.apache.activemq.broker.region.Queue v; java.util.Collection v; org.apache.activemq.broker.region.MessageReferenceFilter v; org.apache.activemq.broker.region.DestinationStatistics v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.MessageReferenceFilter; v := @parameter: int; v = 0; v = new java.util.LinkedHashSet; specialinvoke v.()>(); v = virtualinvoke v.(); label: specialinvoke v.(1); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return 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.(java.util.Collection)>(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); v = interfaceinvoke v.(v, v); if v == 0 goto label; virtualinvoke v.(v, v); interfaceinvoke v.(v); v = v + 1; if v < v goto label; if v <= 0 goto label; return v; label: v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v < 0 goto label; return v; catch java.lang.Throwable from label to label with label; } public boolean copyMessageTo(org.apache.activemq.broker.ConnectionContext, java.lang.String, org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.Queue v; int v; java.lang.String v; org.apache.activemq.broker.region.MessageReferenceFilter v; boolean v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: java.lang.String; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = virtualinvoke v.(v); v = virtualinvoke v.(v, v, v, 1); if v <= 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public int copyMatchingMessagesTo(org.apache.activemq.broker.ConnectionContext, java.lang.String, org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.Queue v; int v, v; java.lang.String v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: java.lang.String; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = (int) -1; v = virtualinvoke v.(v, v, v, v); return v; } public int copyMatchingMessagesTo(org.apache.activemq.broker.ConnectionContext, java.lang.String, org.apache.activemq.command.ActiveMQDestination, int) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.Queue v; int v, v; java.lang.String v; org.apache.activemq.broker.region.MessageReferenceFilter v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: java.lang.String; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: int; v = virtualinvoke v.(v); v = virtualinvoke v.(v, v, v, v); return v; } public int copyMatchingMessages(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.MessageReferenceFilter, org.apache.activemq.command.ActiveMQDestination, int) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.management.CountStatisticImpl v; byte v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v, v; boolean v, v, v, v, v, v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.broker.region.Queue v; java.util.Collection v; org.apache.activemq.broker.region.MessageReferenceFilter v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v; org.apache.activemq.broker.region.DestinationStatistics v; java.lang.Throwable v, v; org.apache.activemq.broker.region.cursors.PendingList v; long v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v; java.util.ArrayList v; org.apache.activemq.broker.Broker v; int v, v, v, v; java.util.LinkedHashSet v; org.apache.activemq.broker.region.MessageReference v; java.util.Iterator v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.MessageReferenceFilter; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: int; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; return 0; label: v = 0; v = 0; v = new java.util.LinkedHashSet; specialinvoke v.()>(); label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; label: v = v.; v = interfaceinvoke v.(); goto label; label: v = virtualinvoke v.(); label: specialinvoke v.(1, 0, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return 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.(java.util.Collection)>(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); v = interfaceinvoke v.(v, v); if v == 0 goto label; virtualinvoke v.(); label: v = virtualinvoke v.(); staticinvoke (v, v, v); v = v + 1; if v < v goto label; if v <= 0 goto label; label: virtualinvoke v.(); return v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v < 0 goto label; return v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public boolean moveMessageTo(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.QueueMessageReference, org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception { java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v, v, v; org.apache.activemq.broker.region.policy.DeadLetterStrategy v; boolean v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v; java.util.Set v, v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.Destination v, v, v; java.lang.Throwable v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.broker.Broker v, v; org.apache.activemq.broker.region.QueueMessageReference v; java.util.Iterator v, v, v, v; java.lang.Object v, v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.QueueMessageReference; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = v.; v = interfaceinvoke v.(v); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v instanceof org.apache.activemq.broker.region.Queue; if v == 0 goto label; virtualinvoke v.(); goto label; label: v = interfaceinvoke v.(); staticinvoke (v, v, v); virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); 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 = v instanceof org.apache.activemq.broker.region.Queue; if v == 0 goto label; virtualinvoke v.(); goto label; label: v := @caughtexception; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v instanceof org.apache.activemq.broker.region.Queue; if v == 0 goto label; virtualinvoke v.(); goto label; label: throw v; label: return 1; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public boolean moveMessageTo(org.apache.activemq.broker.ConnectionContext, java.lang.String, org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.Queue v; int v; java.lang.String v; org.apache.activemq.broker.region.MessageReferenceFilter v; boolean v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: java.lang.String; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = virtualinvoke v.(v); v = virtualinvoke v.(v, v, v, 1); if v <= 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public int moveMatchingMessagesTo(org.apache.activemq.broker.ConnectionContext, java.lang.String, org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.Queue v; int v; java.lang.String v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: java.lang.String; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = virtualinvoke v.(v, v, v, 2147483647); return v; } public int moveMatchingMessagesTo(org.apache.activemq.broker.ConnectionContext, java.lang.String, org.apache.activemq.command.ActiveMQDestination, int) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.Queue v; int v, v; java.lang.String v; org.apache.activemq.broker.region.MessageReferenceFilter v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: java.lang.String; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: int; v = virtualinvoke v.(v); v = virtualinvoke v.(v, v, v, v); return v; } public int moveMatchingMessagesTo(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.MessageReferenceFilter, org.apache.activemq.command.ActiveMQDestination, int) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v; byte v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v, v; boolean v, v, v, v; org.apache.activemq.broker.region.Queue v; java.util.Collection v; org.apache.activemq.broker.region.MessageReferenceFilter v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.broker.region.DestinationStatistics v; java.lang.Throwable v; org.apache.activemq.broker.region.cursors.PendingList v; long v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v; java.util.ArrayList v; int v, v, v, v; java.util.LinkedHashSet v; org.apache.activemq.broker.region.MessageReference v; java.util.Iterator v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.MessageReferenceFilter; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: int; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; return 0; label: v = 0; v = new java.util.LinkedHashSet; specialinvoke v.()>(); label: specialinvoke v.(1); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return 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.(java.util.Collection)>(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v, v); if v == 0 goto label; virtualinvoke v.(v, v, v); interfaceinvoke v.(v); v = v + 1; if v < v goto label; if v <= 0 goto label; return v; label: v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v >= 0 goto label; v = interfaceinvoke v.(); if v < v goto label; label: return v; catch java.lang.Throwable from label to label with label; } public int retryMessages(org.apache.activemq.broker.ConnectionContext, int) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v, v; org.apache.activemq.management.CountStatisticImpl v, v; byte v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v, v; boolean v, v, v; org.apache.activemq.broker.region.Queue v; java.util.Collection v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.broker.region.DestinationStatistics v, v; java.lang.Throwable v; org.apache.activemq.broker.region.cursors.PendingList v; long v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v; java.util.ArrayList v; int v, v, v; java.util.LinkedHashSet v; org.apache.activemq.broker.region.MessageReference v; java.util.Iterator v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: int; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.Exception; specialinvoke v.(java.lang.String)>("Retry of message is only possible on Dead Letter Queues!"); throw v; label: v = 0; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = new java.util.LinkedHashSet; specialinvoke v.()>(); label: specialinvoke v.(1); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return 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.(java.util.Collection)>(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v - 1L; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); interfaceinvoke v.(v); v = v + 1; if v < v goto label; if v <= 0 goto label; return v; label: v = v cmp 0L; if v <= 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v < 0 goto label; label: return v; catch java.lang.Throwable from label to label with label; } public boolean iterate() { org.apache.activemq.broker.region.cursors.QueueDispatchPendingList v, v; org.apache.activemq.filter.NonCachedMessageEvaluationContext v; java.lang.Integer v, v, v, v, v; byte v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v, v, v, v, v, v, v; java.util.Map v, v; java.lang.Exception v, v; java.util.concurrent.CountDownLatch v; java.lang.Throwable v, v, v, v, v, v; org.apache.activemq.broker.region.cursors.PendingList v, v, v; long v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v, v, v, v; java.lang.String v, v; java.util.concurrent.atomic.AtomicLong v, v, v; org.apache.activemq.usage.MemoryUsage v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v; java.util.Collection v; org.apache.activemq.command.ActiveMQDestination v; java.util.List v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; java.util.concurrent.ConcurrentLinkedQueue v, v; int v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.cursors.OrderedPendingList v; org.apache.activemq.broker.region.MessageReference v; org.slf4j.Logger v, v, v, v, v, v, v; java.util.Iterator v, v, v; org.apache.activemq.broker.region.cursors.PrioritizedPendingList v; java.util.concurrent.TimeUnit v; java.lang.Object v, v, v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v = virtualinvoke v.(); staticinvoke ("activemq.destination", v); v = v.; entermonitor v; label: v. = 1; v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: specialinvoke v.(); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; if v == 0 goto label; v. = 0; label: v = v.; if v <= 0 goto label; v = 1000; v = v.; if v <= 0 goto label; v = v.; label: v = v.; v = ; v = virtualinvoke v.(v, v); if v == 0 goto label; v = ; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{} consumers subscribed. Starting dispatch.", v); goto label; label: v = ; v = staticinvoke (v); v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{} ms elapsed and {} consumers subscribed. Starting dispatch.", v, v); label: v = v.; if v <= 0 goto label; v = v.; if v > 0 goto label; v = v.; v = v.; virtualinvoke v.(v); v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("{} ms elapsed. Starting dispatch.", v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = 0 | 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.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: 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.; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; if v != 0 goto label; if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; label: if v == 0 goto label; v = virtualinvoke v.(); if v <= 0 goto label; v = 1; goto label; label: v = 0; label: v = virtualinvoke v.(); virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to page in more queue messages ", v); label: if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.broker.region.cursors.PrioritizedPendingList; v = v; specialinvoke v.()>(); goto label; label: v = new org.apache.activemq.broker.region.cursors.OrderedPendingList; v = v; specialinvoke v.()>(); label: v = v; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: 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: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: v = new org.apache.activemq.filter.NonCachedMessageEvaluationContext; specialinvoke v.()>(); v = v.; virtualinvoke v.(v); v = ; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("dispatch to browser: {}, already dispatched/paged count: {}", v, v); v = 0; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(v); v = virtualinvoke v.(v, v); if v == 0 goto label; virtualinvoke v.(v); v = 1; goto label; label: if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: virtualinvoke v.(); interfaceinvoke v.(); goto label; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("exception on dispatch to browser: {}", v, v); goto label; label: v = v.; v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = v.; virtualinvoke v.(); label: staticinvoke ("activemq.destination"); v. = 0; v = v.; v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = 1; goto label; label: v = 0; 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.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; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable 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; } public void pauseDispatch() { org.apache.activemq.broker.region.QueueDispatchSelector v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; virtualinvoke v.(); return; } public void resumeDispatch() { org.apache.activemq.broker.region.QueueDispatchSelector v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; virtualinvoke v.(); virtualinvoke v.(); return; } public boolean isDispatchPaused() { org.apache.activemq.broker.region.QueueDispatchSelector v; org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; v = virtualinvoke v.(); return v; } protected org.apache.activemq.broker.region.MessageReferenceFilter createMessageIdFilter(java.lang.String) { org.apache.activemq.broker.region.Queue$6 v; java.lang.String v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: java.lang.String; v = new org.apache.activemq.broker.region.Queue$6; specialinvoke v.(org.apache.activemq.broker.region.Queue,java.lang.String)>(v, v); return v; } protected org.apache.activemq.broker.region.MessageReferenceFilter createSelectorFilter(java.lang.String) throws javax.jms.InvalidSelectorException { org.apache.activemq.broker.region.Queue$7 v; org.apache.activemq.broker.region.Queue$8 v; org.apache.activemq.broker.region.Queue v; java.lang.String v; org.apache.activemq.filter.BooleanExpression v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: java.lang.String; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = new org.apache.activemq.broker.region.Queue$7; specialinvoke v.(org.apache.activemq.broker.region.Queue)>(v); return v; label: v = staticinvoke (v); v = new org.apache.activemq.broker.region.Queue$8; specialinvoke v.(org.apache.activemq.broker.region.Queue,org.apache.activemq.filter.BooleanExpression)>(v, v); return v; } protected void removeMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.QueueMessageReference) throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.broker.region.cursors.QueueDispatchPendingList v; org.apache.activemq.broker.region.Queue v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.QueueMessageReference v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.QueueMessageReference; virtualinvoke v.(v, null, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; virtualinvoke 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; } protected void removeMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription, org.apache.activemq.broker.region.QueueMessageReference) throws java.io.IOException { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.MessageAck v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v; org.apache.activemq.broker.region.QueueMessageReference v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v := @parameter: org.apache.activemq.broker.region.QueueMessageReference; v = new org.apache.activemq.command.MessageAck; specialinvoke v.()>(); virtualinvoke v.(2); v = v.; virtualinvoke v.(v); v = interfaceinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v, v, v, v); return; } protected void removeMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription, org.apache.activemq.broker.region.QueueMessageReference, org.apache.activemq.command.MessageAck) throws java.io.IOException { java.lang.Throwable v, v; org.apache.activemq.broker.region.Subscription v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.broker.region.QueueMessageReference v; org.apache.activemq.command.ConsumerInfo v, v; boolean v, v, v, v; org.apache.activemq.command.MessageAck v; org.slf4j.Logger v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v, v; org.apache.activemq.broker.region.Queue$9 v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.DestinationStatistics v; org.apache.activemq.transaction.Transaction v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v := @parameter: org.apache.activemq.broker.region.QueueMessageReference; v := @parameter: org.apache.activemq.command.MessageAck; v = ; v = interfaceinvoke v.(); interfaceinvoke v.("ack of {} with {}", v, v); v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(v, v, v, v); specialinvoke v.(v); goto label; label: virtualinvoke v.(v, v, v, v); label: v = virtualinvoke v.(); v = new org.apache.activemq.broker.region.Queue$9; specialinvoke v.(org.apache.activemq.broker.region.Queue,org.apache.activemq.broker.region.QueueMessageReference)>(v, v); virtualinvoke v.(v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = new org.apache.activemq.broker.region.Queue$9; specialinvoke v.(org.apache.activemq.broker.region.Queue,org.apache.activemq.broker.region.QueueMessageReference)>(v, v); virtualinvoke v.(v); throw v; label: v = virtualinvoke v.(); if v != 0 goto label; if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: 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: if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); label: interfaceinvoke v.(1); return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private void dropMessage(org.apache.activemq.broker.region.QueueMessageReference) { java.lang.Throwable v; org.apache.activemq.broker.region.cursors.PendingList v; org.apache.activemq.broker.region.Queue v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.management.CountStatisticImpl v, v; org.apache.activemq.broker.region.DestinationStatistics v, v; org.apache.activemq.broker.region.QueueMessageReference v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.QueueMessageReference; v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: 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: return; catch java.lang.Throwable from label to label with label; } public void messageExpired(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.MessageReference) { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.MessageReference; virtualinvoke v.(v, null, v); return; } public void messageExpired(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription, org.apache.activemq.broker.region.MessageReference) { java.lang.Throwable v; org.apache.activemq.broker.region.Subscription v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.broker.region.MessageReference v; org.slf4j.Logger v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v; java.io.IOException v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.DestinationStatistics v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v := @parameter: org.apache.activemq.broker.region.MessageReference; v = ; interfaceinvoke v.("message expired: {}", v); v = v.; interfaceinvoke v.(v, v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: virtualinvoke v.(v, v, 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: v := @caughtexception; v = ; interfaceinvoke v.("Failed to remove expired Message from the store ", v); label: return; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; } private final boolean cursorAdd(org.apache.activemq.command.Message) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.region.Queue v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.command.Message v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.command.Message; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke 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; } private final boolean tryCursorAdd(org.apache.activemq.command.Message) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.region.Queue v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.command.Message v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.command.Message; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(v, 50L); 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; } final void messageSent(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message) throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.management.CountStatisticImpl v, v; java.util.concurrent.atomic.AtomicInteger v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; int v; java.lang.String v; boolean v; org.slf4j.Logger v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v; org.apache.activemq.management.SizeStatisticImpl v; org.apache.activemq.command.ActiveMQDestination v; java.util.List v; org.apache.activemq.broker.region.DestinationStatistics v, v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.Message; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke 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 = newarray (java.lang.Object)[3]; v = v.; v = interfaceinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = v.; v[2] = v; interfaceinvoke v.("{} Message {} sent to {}", v); virtualinvoke v.(); return; catch java.lang.Throwable from label to label with label; } public void wakeup() { java.util.concurrent.atomic.AtomicLong v; org.apache.activemq.broker.region.Queue v; boolean v, v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; virtualinvoke v.(); v = v.; virtualinvoke v.(); goto label; label: specialinvoke v.(); label: return; } private void asyncWakeup() { java.util.concurrent.atomic.AtomicLong v; org.apache.activemq.thread.TaskRunner v; org.slf4j.Logger v; java.lang.InterruptedException v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; label: v = v.; virtualinvoke v.(); v = v.; interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Async task runner failed to wakeup ", v); label: return; catch java.lang.InterruptedException from label to label with label; } private void doPageIn(boolean) throws java.lang.Exception { int v; org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: boolean; v = virtualinvoke v.(); specialinvoke v.(v, 1, v); return; } private void doPageIn(boolean, boolean, int) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.region.cursors.QueueDispatchPendingList v, v, v, v; org.apache.activemq.broker.region.cursors.PendingList v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; int v; boolean v, v, v, v, v; java.util.Iterator v; org.apache.activemq.broker.region.Queue v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: int; v = specialinvoke v.(v, v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; virtualinvoke 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: return; catch java.lang.Throwable from label to label with label; } private org.apache.activemq.broker.region.cursors.PendingList doPageInForDispatch(boolean, boolean, int) throws java.lang.Exception { org.apache.activemq.broker.region.cursors.QueueDispatchPendingList v; java.lang.Integer v, v, v, v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.command.Message v, v, v, v, v, v; java.lang.Long v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v, v, v, v; org.apache.activemq.usage.SystemUsage v, v; java.lang.Throwable v, v, v, v, v, v; java.lang.Object[] v, v; org.apache.activemq.broker.region.cursors.PendingList v, v, v, v, v; long v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v, v, v, v, v, v, v; java.util.ArrayList v; org.apache.activemq.broker.Broker v, v, v; java.lang.String v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v, v, v; org.apache.activemq.management.CountStatisticImpl v, v, v; org.apache.activemq.usage.MemoryUsage v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.DestinationStatistics v, v, v; int v, v, v, v, v, v, v; java.lang.Boolean v; org.apache.activemq.broker.region.cursors.OrderedPendingList v, v; org.apache.activemq.broker.region.QueueMessageReference v; org.apache.activemq.store.MessageStore v, v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.command.MessageAck v; org.slf4j.Logger v, v, v, v, v, v; java.util.Iterator v; org.apache.activemq.broker.region.cursors.PrioritizedPendingList v; java.lang.Object v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: int; v = null; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = staticinvoke (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.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; 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: v = virtualinvoke v.(); if v == 0 goto label; if v != 0 goto label; v = specialinvoke v.(); v = staticinvoke (v, v); label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[10]; v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v[4] = v; v = staticinvoke (v); v[5] = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[6] = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[7] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[8] = v; v = staticinvoke (v); v[9] = v; interfaceinvoke v.("{} toPageIn: {}, force:{}, Inflight: {}, pagedInMessages.size {}, pagedInPendingDispatch.size {}, enqueueCount: {}, dequeueCount: {}, memUsage:{}, maxPageSize:{}", v); label: if v <= 0 goto label; if v != 0 goto label; v = specialinvoke v.(); if v == 0 goto label; if v >= v goto label; label: v = 0; v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); label: if v >= v goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = interfaceinvoke v.(); v = specialinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: interfaceinvoke v.(); goto label; label: interfaceinvoke v.(v); v = v + 1; goto label; label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw 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 <= 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.broker.region.cursors.PrioritizedPendingList; specialinvoke v.()>(); v = v; goto label; label: v = new org.apache.activemq.broker.region.cursors.OrderedPendingList; specialinvoke v.()>(); v = v; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; v = v.; interfaceinvoke v.(v); interfaceinvoke v.(v); goto label; label: interfaceinvoke v.(); v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = interfaceinvoke v.(); v[1] = v; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("{}, duplicate message {} - {} from cursor, is cursor audit disabled or too constrained? Redirecting to dlq", v); v = v.; if v == null goto label; v = virtualinvoke v.(); specialinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = ; v = interfaceinvoke v.(); interfaceinvoke v.("Duplicate message {} from cursor, removing from store", v); v = v.; v = new org.apache.activemq.command.MessageAck; v = interfaceinvoke v.(); specialinvoke v.(org.apache.activemq.command.Message,byte,int)>(v, 1, 1); interfaceinvoke v.(v, v); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = new java.lang.Throwable; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("duplicate paged in from cursor for \u0001"); specialinvoke v.(java.lang.String)>(v); interfaceinvoke v.(v, v, null, 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 = interfaceinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{} cursor blocked, no space available to page in messages; usage: {}", v, v); goto label; label: v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{} cursor blocked, no space available to page in messages; usage: {}", v, v); label: if v == null goto label; v = v; goto label; label: v = new org.apache.activemq.broker.region.cursors.OrderedPendingList; v = v; specialinvoke 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; } private final boolean haveRealConsumer() { java.util.List v; org.apache.activemq.broker.region.Queue v; int v, v, v; boolean v; java.util.concurrent.ConcurrentLinkedQueue v; v := @this: org.apache.activemq.broker.region.Queue; v = v.; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = v - v; if v <= 0 goto label; v = 1; goto label; label: v = 0; label: return v; } private void doDispatch(org.apache.activemq.broker.region.cursors.PendingList) throws java.lang.Exception { org.apache.activemq.broker.region.cursors.QueueDispatchPendingList v, v, v, v, v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; boolean v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.Queue v; java.lang.Throwable v; org.apache.activemq.broker.region.cursors.PendingList v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.Iterator v, v; java.lang.Object v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.cursors.PendingList; v = 0; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = null; label: v = v.; specialinvoke v.(v); if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = specialinvoke v.(v); virtualinvoke v.(v); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = 1; 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 == 0 goto label; specialinvoke v.(); label: return; catch java.lang.Throwable from label to label with label; } private org.apache.activemq.broker.region.cursors.PendingList doActualDispatch(org.apache.activemq.broker.region.cursors.PendingList) throws java.lang.Exception { java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.command.ConsumerId v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v; java.util.List v, v, v, v; org.apache.activemq.broker.region.QueueDispatchSelector v, v; java.lang.Throwable v, v; org.apache.activemq.broker.region.cursors.PendingList v; org.apache.activemq.broker.region.Subscription v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v, v; java.util.ArrayList v, v, v; java.util.HashSet v; int v, v, v, v; org.apache.activemq.command.ConsumerInfo v; org.apache.activemq.broker.region.MessageReference v; org.slf4j.Logger v, v; java.util.Iterator v, v; java.lang.Object v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.cursors.PendingList; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return v; label: v = new java.util.ArrayList; v = v.; specialinvoke v.(java.util.Collection)>(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.HashSet; v = v.; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = null; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v instanceof org.apache.activemq.broker.region.QueueBrowserSubscription; if v != 0 goto label; v = interfaceinvoke v.(v); if v != 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(v, v); if v == 0 goto label; v = virtualinvoke v.(v, v); if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("assigned {} to consumer {}", v, v); interfaceinvoke v.(); v = v; goto label; label: interfaceinvoke v.(v); v = ; interfaceinvoke v.("Subscription full {}", v); goto label; label: if v != null goto label; v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); label: if v != null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != v goto label; return v; label: if v == null goto label; v = v.; if v != 0 goto label; v = interfaceinvoke v.(); if v <= 1 goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = specialinvoke v.(v); if v == 0 goto label; specialinvoke v.(v); v = new java.util.ArrayList; v = v.; specialinvoke v.(java.util.Collection)>(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 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; } protected boolean assignMessageGroup(org.apache.activemq.broker.region.Subscription, org.apache.activemq.broker.region.QueueMessageReference) throws java.lang.Exception { org.apache.activemq.broker.region.Subscription v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.broker.region.group.MessageGroupMap v; org.apache.activemq.command.ConsumerId v, v; org.apache.activemq.command.ActiveMQDestination v; int v; java.lang.String v; org.apache.activemq.broker.region.QueueMessageReference v; org.apache.activemq.command.ConsumerInfo v, v; boolean v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.Subscription; v := @parameter: org.apache.activemq.broker.region.QueueMessageReference; v = 1; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 1 goto label; virtualinvoke v.(v, v, v, v); goto label; label: v = interfaceinvoke v.(v); if v != null goto label; virtualinvoke v.(v, v, v, v); goto label; label: v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; if v >= 0 goto label; interfaceinvoke v.(v); v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v); goto label; label: v = 0; label: return v; } protected void assignGroup(org.apache.activemq.broker.region.Subscription, org.apache.activemq.broker.region.group.MessageGroupMap, org.apache.activemq.broker.region.MessageReference, java.lang.String) throws java.io.IOException { org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.broker.region.group.MessageGroupMap v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.Message v; java.lang.String v; org.apache.activemq.command.ConsumerInfo v, v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.Subscription; v := @parameter: org.apache.activemq.broker.region.group.MessageGroupMap; v := @parameter: org.apache.activemq.broker.region.MessageReference; v := @parameter: java.lang.String; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = interfaceinvoke v.(); virtualinvoke v.(1); v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v); return; } protected void pageInMessages(boolean, int) throws java.lang.Exception { org.apache.activemq.broker.region.cursors.PendingList v; org.apache.activemq.broker.region.Queue v; int v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: boolean; v := @parameter: int; v = specialinvoke v.(v, 1, v); specialinvoke v.(v); return; } private void addToConsumerList(org.apache.activemq.broker.region.Subscription) { java.util.List v, v, v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.broker.region.Queue v; java.util.Comparator v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.Subscription; v = v.; if v == 0 goto label; v = v.; interfaceinvoke v.(v); v = v.; v = v.; staticinvoke (v, v); goto label; label: v = v.; interfaceinvoke v.(v); label: return; } private boolean removeFromConsumerList(org.apache.activemq.broker.region.Subscription) { java.util.List v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.broker.region.Queue v; boolean v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.broker.region.Subscription; v = v.; v = interfaceinvoke v.(v); return v; } private int getConsumerMessageCountBeforeFull() throws java.lang.Exception { java.lang.Throwable v; java.util.Iterator v; org.apache.activemq.broker.region.Queue v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.List v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; int v, v; java.lang.Object v; boolean v, v; v := @this: org.apache.activemq.broker.region.Queue; v = 0; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = v + v; 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 v; catch java.lang.Throwable from label to label with label; } public void processDispatchNotification(org.apache.activemq.command.MessageDispatchNotification) throws java.lang.Exception { org.apache.activemq.command.MessageDispatchNotification v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.broker.region.QueueMessageReference v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.command.MessageDispatchNotification; v = specialinvoke v.(v); if v == null goto label; v = specialinvoke v.(v); interfaceinvoke v.(v); interfaceinvoke v.(v); label: return; } private org.apache.activemq.broker.region.QueueMessageReference getMatchingMessage(org.apache.activemq.command.MessageDispatchNotification) throws java.lang.Exception { org.apache.activemq.broker.region.cursors.QueueDispatchPendingList v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v, v, v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.Message v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; boolean v, v, v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.command.MessageId v, v, v, v; javax.jms.JMSException v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v, v, v, v; java.lang.Throwable v, v, v, v; org.apache.activemq.broker.region.cursors.PendingList v; org.apache.activemq.command.MessageDispatchNotification v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v, v, v, v; int v, v; java.lang.String v; org.apache.activemq.broker.region.MessageReference v, v; java.util.Iterator v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.command.MessageDispatchNotification; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; virtualinvoke 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 = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: 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 = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(v); label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw 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.(v); if v == null goto label; v = specialinvoke v.(v); label: if v != null goto label; v = new javax.jms.JMSException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("Slave broker out of sync with master - Message: \u on \u does not exist among pending(\u) for subscription: \u0001"); specialinvoke v.(java.lang.String)>(v); 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; } private org.apache.activemq.broker.region.Subscription getMatchingSubscription(org.apache.activemq.command.MessageDispatchNotification) throws javax.jms.JMSException { java.lang.Throwable v; org.apache.activemq.command.MessageDispatchNotification v; org.apache.activemq.broker.region.Subscription v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; org.apache.activemq.command.ConsumerId v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v, v; java.util.Iterator v; org.apache.activemq.broker.region.Queue v; java.util.List v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.command.MessageDispatchNotification; v = null; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; 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 onUsageChanged(org.apache.activemq.usage.Usage, int, int) { org.apache.activemq.broker.region.Queue v; int v, v; org.apache.activemq.usage.Usage v; v := @this: org.apache.activemq.broker.region.Queue; v := @parameter: org.apache.activemq.usage.Usage; v := @parameter: int; v := @parameter: int; if v <= v goto label; specialinvoke v.(); label: return; } protected org.slf4j.Logger getLog() { org.slf4j.Logger v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.Queue; v = ; return v; } protected boolean isOptimizeStorage() { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; int v, v, v; boolean v, v, v, v, v; java.util.Iterator v; org.apache.activemq.broker.region.Queue v; java.util.List v, v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.Queue; v = 0; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = 1; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = 0; goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = 0; goto label; label: v = interfaceinvoke v.(); v = virtualinvoke v.(); if v <= v goto label; v = 0; 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; } static void () { org.slf4j.Logger v; v = staticinvoke (class "Lorg/apache/activemq/broker/region/Queue;"); = v; return; } }