public abstract class org.apache.activemq.broker.region.PrefetchSubscription extends org.apache.activemq.broker.region.AbstractSubscription { private static final org.slf4j.Logger LOG; protected final org.apache.activemq.thread.Scheduler scheduler; protected org.apache.activemq.broker.region.cursors.PendingMessageCursor pending; protected final java.util.List dispatched; private int maxProducersToAudit; private int maxAuditDepth; protected final org.apache.activemq.usage.SystemUsage usageManager; protected final java.lang.Object pendingLock; protected final java.lang.Object dispatchLock; private final java.util.concurrent.CountDownLatch okForAckAsDispatchDone; public void (org.apache.activemq.broker.Broker, org.apache.activemq.usage.SystemUsage, org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo, org.apache.activemq.broker.region.cursors.PendingMessageCursor) throws javax.jms.JMSException { org.apache.activemq.broker.region.PrefetchSubscription v; javax.jms.JMSException v; java.lang.Exception v; java.util.ArrayList v; java.util.concurrent.CountDownLatch v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.thread.Scheduler v; java.lang.Object v, v; org.apache.activemq.usage.SystemUsage v; java.lang.String v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; v := @parameter: org.apache.activemq.broker.region.cursors.PendingMessageCursor; specialinvoke v.(org.apache.activemq.broker.Broker,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ConsumerInfo)>(v, v, v); v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v. = 32; v. = 2048; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v. = v; v. = v; v. = v; label: v = v.; interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = new javax.jms.JMSException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(); v. = v; return; catch java.lang.Exception from label to label with label; } public void (org.apache.activemq.broker.Broker, org.apache.activemq.usage.SystemUsage, org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo) throws javax.jms.JMSException { org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.PrefetchSubscription v; org.apache.activemq.broker.region.cursors.VMPendingMessageCursor v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = new org.apache.activemq.broker.region.cursors.VMPendingMessageCursor; specialinvoke v.(boolean)>(0); specialinvoke v.(org.apache.activemq.broker.Broker,org.apache.activemq.usage.SystemUsage,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ConsumerInfo,org.apache.activemq.broker.region.cursors.PendingMessageCursor)>(v, v, v, v, v); return; } public org.apache.activemq.command.Response pullMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessagePull) throws java.lang.Exception { java.lang.Throwable v; long v, v, v, v, v; org.apache.activemq.broker.region.PrefetchSubscription v; org.apache.activemq.command.MessagePull v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v, v; byte v, v, v; java.util.concurrent.atomic.AtomicInteger v, v; int v, v; org.apache.activemq.broker.region.PrefetchSubscription$1 v; org.apache.activemq.broker.region.QueueMessageReference v; boolean v, v; java.util.Iterator v; org.apache.activemq.broker.region.SubscriptionStatistics v, v; org.apache.activemq.thread.Scheduler v; java.lang.Object v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.MessagePull; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: virtualinvoke v.(); entermonitor v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); v = v cmp -1L; if v != 0 goto label; v = v.; virtualinvoke v.(1); v = ; virtualinvoke v.(v); virtualinvoke v.(); label: v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = v.; v = new org.apache.activemq.broker.region.PrefetchSubscription$1; specialinvoke v.(org.apache.activemq.broker.region.PrefetchSubscription,long,org.apache.activemq.command.MessagePull)>(v, v, v); v = virtualinvoke v.(); virtualinvoke v.(v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return null; catch java.lang.Throwable from label to label with label; } final void pullTimeout(long, boolean) { java.lang.Throwable v, v; long v, v; org.apache.activemq.broker.region.PrefetchSubscription v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v; byte v; java.util.concurrent.atomic.AtomicInteger v, v, v, v; org.apache.activemq.broker.Connection v; org.apache.activemq.broker.region.QueueMessageReference v; boolean v; java.lang.Exception v; org.apache.activemq.broker.region.SubscriptionStatistics v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: long; v := @parameter: boolean; v = v.; entermonitor v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; if v == 0 goto label; label: v = v.; virtualinvoke v.(1); v = ; virtualinvoke v.(v); virtualinvoke v.(); label: v = v.; virtualinvoke v.(0); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = v.; virtualinvoke v.(0); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(0); throw v; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor 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; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void add(org.apache.activemq.broker.region.MessageReference) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.command.Message$MessageDestination v; org.apache.activemq.broker.region.PrefetchSubscription v; org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.broker.region.SubscriptionStatistics v; java.lang.Object v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.QueueMessageReference v, v; boolean v, v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.region.MessageReference; v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = ; if v == v goto label; exitmonitor v; label: return; label: v = ; v = virtualinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: virtualinvoke v.(); return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void processMessageDispatchNotification(org.apache.activemq.command.MessageDispatchNotification) throws java.lang.Exception { java.lang.Throwable v, v, v; org.apache.activemq.command.MessageDispatchNotification v; org.apache.activemq.broker.region.PrefetchSubscription v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.Message v, v; java.lang.String v, v; boolean v, v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.command.MessageId v, v, v; javax.jms.JMSException v; org.apache.activemq.command.ActiveMQDestination v; java.util.List v; java.lang.Object v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v, v, v, v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.command.MessageDispatchNotification; v = v.; entermonitor v; label: v = v.; interfaceinvoke v.(); label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; entermonitor v; label: v = v.; interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, v); v = v.; interfaceinvoke v.(v); v = interfaceinvoke v.(); virtualinvoke v.(v, v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; interfaceinvoke v.(); exitmonitor v; label: return; label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = new javax.jms.JMSException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Slave broker out of sync with master: Dispatched message (\u) was not in the pending list for \u on \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.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 final void acknowledge(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.CountDownLatch v; java.lang.Throwable v, v; java.util.ArrayList v, v; org.apache.activemq.broker.Broker v; java.lang.String 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.MessageId v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; javax.jms.JMSException v, v, v, v, v; java.util.List v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.command.Message$MessageDestination v, v, v, v; org.apache.activemq.broker.region.PrefetchSubscription v; int v; org.apache.activemq.command.MessageAck v; org.slf4j.Logger v, v, v, v; java.util.Iterator v, v, v, v, v, v, v, v; java.util.concurrent.TimeUnit v; org.apache.activemq.broker.region.SubscriptionStatistics v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.MessageAck; v = 0; v = v.; v = ; v = virtualinvoke v.(0L, v); if v != 0 goto label; v = ; interfaceinvoke v.("Ignoring ack received before dispatch; result of failover with an outstanding ack. Acked messages will be replayed if present on this broker. Ignored ack: {}", v); return; label: v = ; interfaceinvoke v.("ack: {}", v); v = v.; entermonitor v; label: v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(v); v = 0; v = new java.util.ArrayList; specialinvoke v.()>(); 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 == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = 1; label: if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); interfaceinvoke v.(v); virtualinvoke v.(1); goto label; label: specialinvoke v.(v, v); label: virtualinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); v = 1; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; interfaceinvoke v.(v); specialinvoke v.(v); goto label; label: if v != 0 goto label; v = ; interfaceinvoke v.("Could not correlate acknowledgment with dispatched message: {}", v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); v = v.; interfaceinvoke v.(v); specialinvoke v.(v); virtualinvoke v.(1); goto label; label: specialinvoke v.(v, v); virtualinvoke v.(1); label: virtualinvoke v.(v, v, v); interfaceinvoke v.(); v = 1; goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); v = v; v = 1; label: if v != 0 goto label; v = new javax.jms.JMSException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not correlate acknowledgment with dispatched message: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = 0; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = 1; label: if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(v, v, v); label: interfaceinvoke v.(); specialinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; virtualinvoke v.(1); interfaceinvoke v.(); v = 1; label: if v != 0 goto label; v = new javax.jms.JMSException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not correlate expiration acknowledgment with dispatched message: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = 0; 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 == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = 1; label: if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(); v = 1; label: if v != 0 goto label; v = new javax.jms.JMSException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not correlate acknowledgment with dispatched message: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = new javax.jms.JMSException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Poison ack cannot be transacted: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = 0; v = new java.util.ArrayList; specialinvoke v.()>(); 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 == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = 1; label: if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; virtualinvoke v.(1); v = v; v = 1; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; interfaceinvoke v.(v); specialinvoke v.(v); goto label; label: if v != 0 goto label; v = new javax.jms.JMSException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not correlate acknowledgment with dispatched message: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == 0 goto label; if v == null goto label; interfaceinvoke v.(); virtualinvoke v.(); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(); goto label; label: v = ; interfaceinvoke v.("Acknowledgment out of sync (Normally occurs when failover connection reconnects): {}", v); label: return; catch java.lang.Throwable from label to label with label; } private void registerRemoveSync(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.PrefetchSubscription v; org.apache.activemq.transaction.Transaction v; org.apache.activemq.broker.region.PrefetchSubscription$2 v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.MessageReference; v = virtualinvoke v.(); v = new org.apache.activemq.broker.region.PrefetchSubscription$2; specialinvoke v.(org.apache.activemq.broker.region.PrefetchSubscription,org.apache.activemq.broker.region.MessageReference)>(v, v); virtualinvoke v.(v); return; } protected void assertAckMatchesDispatched(org.apache.activemq.command.MessageAck) throws javax.jms.JMSException { org.apache.activemq.broker.region.PrefetchSubscription v; int v, v, v; java.lang.String v, v, v; boolean v, v, v, v, v, v; org.apache.activemq.command.MessageAck v; java.util.Iterator v; org.apache.activemq.command.MessageId v, v, v, v; javax.jms.JMSException v, v, v; java.util.List v; java.lang.Object v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.command.MessageAck; v = virtualinvoke v.(); v = virtualinvoke v.(); v = 0; v = 0; v = 0; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v != null goto label; v = 1; goto label; label: if v != 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = 1; label: if v == 0 goto label; v = v + 1; label: if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = 1; label: if v != 0 goto label; if v == null goto label; v = new javax.jms.JMSException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Unmatched acknowledge: \u; Could not find Message-ID \u in dispatched-list (start of ack)"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v != 0 goto label; if v == null goto label; v = new javax.jms.JMSException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Unmatched acknowledge: \u; Could not find Message-ID \u in dispatched-list (end of ack)"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v == v goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new javax.jms.JMSException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Unmatched acknowledge: \u; Expected message count (\u) differs from count in dispatched-list (\u)"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } protected void sendToDLQ(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.MessageReference, java.lang.Throwable) throws java.io.IOException, java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.Broker v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.broker.region.PrefetchSubscription v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.MessageReference; v := @parameter: java.lang.Throwable; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v, v, v, v); return; } public int getInFlightSize() { int v; java.util.List v; org.apache.activemq.broker.region.PrefetchSubscription v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = v.; v = interfaceinvoke v.(); return v; } public boolean isFull() { org.apache.activemq.broker.region.PrefetchSubscription v; java.util.List v; java.util.concurrent.atomic.AtomicInteger v, v; int v, v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = v - v; v = v.; v = virtualinvoke v.(); if v < v goto label; v = 1; goto label; label: v = 0; label: return v; } public boolean isLowWaterMark() { org.apache.activemq.broker.region.PrefetchSubscription v; java.util.List v; byte v; java.util.concurrent.atomic.AtomicInteger v; int v, v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v; double v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = v.; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = v - v; v = v.; v = virtualinvoke v.(); v = v * 0.4; v = v cmpg v; if v > 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public boolean isHighWaterMark() { org.apache.activemq.broker.region.PrefetchSubscription v; java.util.List v; byte v; java.util.concurrent.atomic.AtomicInteger v; int v, v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v; double v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = v.; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = v - v; v = v.; v = virtualinvoke v.(); v = v * 0.9; v = v cmpl v; if v < 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public int countBeforeFull() { org.apache.activemq.broker.region.PrefetchSubscription v; java.util.List v; java.util.concurrent.atomic.AtomicInteger v, v; int v, v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v + v; v = v.; v = interfaceinvoke v.(); v = v - v; label: return v; } public int getPendingQueueSize() { int v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.PrefetchSubscription v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = v.; v = interfaceinvoke v.(); return v; } public long getPendingMessageSize() { long v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.PrefetchSubscription v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = v.; v = interfaceinvoke v.(); return v; } public int getDispatchedQueueSize() { int v; java.util.List v; org.apache.activemq.broker.region.PrefetchSubscription v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = v.; v = interfaceinvoke v.(); return v; } public long getDequeueCounter() { org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.broker.region.SubscriptionStatistics v; long v; org.apache.activemq.broker.region.PrefetchSubscription v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public long getDispatchedCounter() { org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.broker.region.SubscriptionStatistics v; long v; org.apache.activemq.broker.region.PrefetchSubscription v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public long getEnqueueCounter() { org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.broker.region.SubscriptionStatistics v; long v; org.apache.activemq.broker.region.PrefetchSubscription v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public boolean isRecoveryRequired() { org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.PrefetchSubscription v; boolean v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = v.; v = interfaceinvoke v.(); return v; } public org.apache.activemq.broker.region.cursors.PendingMessageCursor getPending() { org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.PrefetchSubscription v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = v.; return v; } public void setPending(org.apache.activemq.broker.region.cursors.PendingMessageCursor) { int v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v; org.apache.activemq.broker.region.PrefetchSubscription v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.region.cursors.PendingMessageCursor; v. = v; v = v.; if v == null goto label; v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: return; } public void add(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Destination) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.broker.ConnectionContext v; java.lang.Object v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.PrefetchSubscription v; org.apache.activemq.broker.region.Destination v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Destination; v = v.; entermonitor v; label: specialinvoke v.(v, v); v = v.; interfaceinvoke v.(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 java.util.List remove(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Destination) throws java.lang.Exception { java.util.List v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.PrefetchSubscription v; org.apache.activemq.broker.region.Destination v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Destination; v = v.; v = virtualinvoke v.(v, v, v); return v; } public java.util.List remove(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Destination, java.util.List) throws java.lang.Exception { java.lang.Throwable v, v; org.apache.activemq.broker.region.PrefetchSubscription v; java.util.List v, v, v; org.apache.activemq.broker.ConnectionContext v; java.lang.Object v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; java.util.LinkedList v; org.apache.activemq.broker.region.Destination v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Destination; v := @parameter: java.util.List; v = new java.util.LinkedList; specialinvoke v.()>(); v = v.; entermonitor v; label: specialinvoke v.(v, v); v = v.; v = interfaceinvoke v.(v, v); virtualinvoke v.(v); if v != null goto label; exitmonitor v; label: return v; label: v = v.; if v != v goto label; v = v.; entermonitor v; label: specialinvoke v.(v, v, v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: specialinvoke v.(v, v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor 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; } private void addReferencesAndUpdateRedispatch(java.util.LinkedList, org.apache.activemq.broker.region.Destination, java.util.List) { org.apache.activemq.command.Message$MessageDestination v; org.apache.activemq.broker.region.PrefetchSubscription v; java.util.ArrayList v; org.apache.activemq.management.CountStatisticImpl v; int v, v, v; java.util.LinkedList v; boolean v; java.util.Iterator v; org.apache.activemq.management.SizeStatisticImpl v; java.util.List v; org.apache.activemq.broker.region.SubscriptionStatistics v; java.lang.Object v; org.apache.activemq.broker.region.DestinationStatistics v; org.apache.activemq.broker.region.Destination v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v := @parameter: java.util.LinkedList; v := @parameter: org.apache.activemq.broker.region.Destination; v := @parameter: java.util.List; v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != v goto label; virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = neg v; virtualinvoke v.(v); goto label; label: virtualinvoke v.(0, v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); interfaceinvoke v.(v); return; } public void dispatchPending() throws java.io.IOException { org.apache.activemq.broker.ConnectionContext v, v; boolean v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v, v, v, v, v; java.util.concurrent.CopyOnWriteArrayList v; java.lang.Throwable v, v, v; org.apache.activemq.command.Message$MessageDestination v; org.apache.activemq.broker.region.PrefetchSubscription v; org.apache.activemq.broker.Broker v; int v, v; org.apache.activemq.broker.region.QueueMessageReference v; org.apache.activemq.broker.region.MessageReference v; java.util.Iterator v; java.lang.Object v, v, v; v := @this: org.apache.activemq.broker.region.PrefetchSubscription; v = null; v = v.; entermonitor v; label: v = virtualinvoke v.(); if v <= 0 goto label; virtualinvoke v.(0); v = v.; virtualinvoke v.(v, v); v = 0; v = v.; interfaceinvoke v.(); label: if v >= v goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(); goto label; label: v = v.; entermonitor v; label: v = v.; interfaceinvoke v.(); v = virtualinvoke v.