public class org.apache.activemq.broker.region.TopicSubscription extends org.apache.activemq.broker.region.AbstractSubscription { private static final org.slf4j.Logger LOG; private static final java.util.concurrent.atomic.AtomicLong CURSOR_NAME_COUNTER; protected org.apache.activemq.broker.region.cursors.PendingMessageCursor matched; protected final org.apache.activemq.usage.SystemUsage usageManager; boolean singleDestination; org.apache.activemq.broker.region.Destination destination; private final org.apache.activemq.thread.Scheduler scheduler; private int maximumPendingMessages; private org.apache.activemq.broker.region.policy.MessageEvictionStrategy messageEvictionStrategy; private final java.util.concurrent.atomic.AtomicInteger discarded; private final java.lang.Object matchedListMutex; private int memoryUsageHighWaterMark; protected int maxProducersToAudit; protected int maxAuditDepth; protected boolean enableAudit; protected org.apache.activemq.ActiveMQMessageAudit audit; protected boolean active; protected boolean discarding; private boolean useTopicSubscriptionInflightStats; protected final java.lang.Object dispatchLock; protected final java.util.List dispatched; public void (org.apache.activemq.broker.Broker, org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo, org.apache.activemq.usage.SystemUsage) throws java.lang.Exception { long v; org.apache.activemq.command.ConsumerId v; java.util.ArrayList v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.cursors.FilePendingMessageCursor v; java.util.concurrent.atomic.AtomicInteger v; int v; org.apache.activemq.store.PListStore v; org.apache.activemq.usage.SystemUsage v; java.lang.String v, v; org.apache.activemq.broker.region.TopicSubscription v; org.apache.activemq.broker.region.cursors.VMPendingMessageCursor v; org.apache.activemq.command.ConsumerInfo v; boolean v; org.apache.activemq.command.ActiveMQDestination v; java.util.concurrent.atomic.AtomicLong v; org.apache.activemq.broker.region.policy.OldestMessageEvictionStrategy v; org.apache.activemq.thread.Scheduler v; java.lang.Object v, v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; v := @parameter: org.apache.activemq.usage.SystemUsage; specialinvoke v.(org.apache.activemq.broker.Broker,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ConsumerInfo)>(v, v, v); v. = 1; v = (int) -1; v. = v; v = new org.apache.activemq.broker.region.policy.OldestMessageEvictionStrategy; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v. = v; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v. = 95; v. = 1024; v. = 1000; v. = 0; v. = 0; v. = 0; v. = 1; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v. = v; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("TopicSubscription:\u[\u]"); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); if v != null goto label; label: v = new org.apache.activemq.broker.region.cursors.VMPendingMessageCursor; specialinvoke v.(boolean)>(0); v. = v; goto label; label: v = new org.apache.activemq.broker.region.cursors.FilePendingMessageCursor; specialinvoke v.(org.apache.activemq.broker.Broker,java.lang.String,boolean)>(v, v, 0); v. = v; label: v = interfaceinvoke v.(); v. = v; return; } public void init() throws java.lang.Exception { org.apache.activemq.ActiveMQMessageAudit v; int v, v, v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v; org.apache.activemq.broker.region.TopicSubscription v; boolean v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; if v == 0 goto label; v = new org.apache.activemq.ActiveMQMessageAudit; v = v.; v = v.; specialinvoke v.(int,int)>(v, v); v. = v; label: v. = 1; return; } public void add(org.apache.activemq.broker.region.MessageReference) throws java.lang.Exception { org.apache.activemq.usage.TempUsage v; java.lang.Integer v, v, v; org.apache.activemq.broker.ConnectionContext v, v, v, v, v; org.apache.activemq.command.Message v; org.apache.activemq.usage.SystemUsage v, v; org.apache.activemq.broker.region.TopicSubscription v; java.util.concurrent.CopyOnWriteArrayList v; org.apache.activemq.broker.region.Destination v; java.lang.Throwable v, v; java.lang.Object[] v, v; java.lang.String v, v, v, v, v; org.apache.activemq.broker.Connection v, v; org.apache.activemq.command.ConsumerInfo v, v; org.apache.activemq.broker.region.MessageReference[] v; org.apache.activemq.management.CountStatisticImpl v, v; org.apache.activemq.usage.MemoryUsage v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.MessageId v; org.apache.activemq.broker.region.policy.MessageEvictionStrategy v, v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.concurrent.atomic.AtomicBoolean v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.LinkedList v; org.apache.activemq.broker.region.MessageReference v, v; org.apache.activemq.broker.region.IndirectMessageReference v; org.slf4j.Logger v, v, v, v; java.util.Iterator v, v; org.apache.activemq.broker.region.SubscriptionStatistics v, v; java.lang.Object v, v, v, v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: org.apache.activemq.broker.region.MessageReference; v = specialinvoke v.(v); if v == 0 goto label; return; label: v = new org.apache.activemq.broker.region.IndirectMessageReference; v = interfaceinvoke v.(); specialinvoke v.(org.apache.activemq.command.Message)>(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); v = v.; entermonitor v; label: v = v.; if v == 0 goto label; exitmonitor v; label: return; label: v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; specialinvoke v.(v); virtualinvoke v.(0); goto label; label: v = v.; v = virtualinvoke v.(); if v <= 1 goto label; v = v.; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); if v <= v goto label; v = virtualinvoke v.(); if v != 0 goto label; v = null; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = ; v = virtualinvoke v.(); if v == null goto label; v = dynamicinvoke "makeConcatWithConstants" (v) (": \u0001"); goto label; label: v = ""; label: interfaceinvoke v.("{}: has twice its prefetch limit pending, without an ack; it appears to be slow{}", v, v); virtualinvoke v.(1); v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); goto label; label: v = v.; if v == 0 goto label; v = 0; label: v = v.; if v == 0 goto label; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.("{}: stopped waiting for space in pendingMessage cursor for: {}", v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); exitmonitor v; label: return; label: if v != 0 goto label; v = ; v = newarray (java.lang.Object)[4]; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; interfaceinvoke v.("{}: Pending message cursor [{}] is full, temp usage ({}%) or memory usage ({}%) limit reached, blocking message add() pending the release of resources.", v); v = 1; label: v = v.; virtualinvoke v.(20L); goto label; label: v = v.; v = interfaceinvoke v.(v, 10L); if v == 0 goto label; label: v = v.; if v <= 0 goto label; v = v.; v = interfaceinvoke v.(); v = v.; if v <= 0 goto label; v = v.; if v >= v goto label; v = v.; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); if v <= v goto label; virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); v = v.; if v <= v goto label; v = v.; v = interfaceinvoke v.(); v = v.; v = v - v; v = staticinvoke (1000, v); v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = 0; if v == null goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; specialinvoke v.(v); v = v + 1; goto label; label: if v != 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; v = v.; v[1] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; interfaceinvoke v.("No messages to evict returned for {} from eviction strategy: {} out of {} candidates", v); label: specialinvoke v.(); 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; 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 boolean isDuplicate(org.apache.activemq.broker.region.MessageReference) { org.apache.activemq.broker.region.MessageReference v; org.slf4j.Logger v, v; org.apache.activemq.command.MessageId v; org.apache.activemq.ActiveMQMessageAudit v, v; org.apache.activemq.broker.region.TopicSubscription v; boolean v, v, v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: org.apache.activemq.broker.region.MessageReference; v = 0; v = v.; if v == 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; if v == 0 goto label; v = ; v = interfaceinvoke v.(); interfaceinvoke v.("{}, ignoring duplicate add: {}", v, v); label: return v; } protected void removeExpiredMessages() throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.command.Message$MessageDestination v; org.apache.activemq.broker.Broker v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.broker.region.TopicSubscription v; boolean v, v, v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v, v, v; org.apache.activemq.broker.region.DestinationStatistics v; v := @this: org.apache.activemq.broker.region.TopicSubscription; 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.(); if v == 0 goto label; v = v.; interfaceinvoke v.(); interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v, 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; } public void processMessageDispatchNotification(org.apache.activemq.command.MessageDispatchNotification) { java.lang.Throwable v, v, v; org.apache.activemq.command.MessageDispatchNotification v; org.apache.activemq.management.CountStatisticImpl v; int v; org.apache.activemq.broker.region.TopicSubscription v; boolean v, v, v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.command.MessageId v, v; org.apache.activemq.management.SizeStatisticImpl v; java.util.List v; org.apache.activemq.broker.region.SubscriptionStatistics v, v; java.lang.Object v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v, v, v, v, v, v; org.apache.activemq.broker.region.TopicSubscription$DispatchedNode v; v := @this: org.apache.activemq.broker.region.TopicSubscription; 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 = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = new org.apache.activemq.broker.region.TopicSubscription$DispatchedNode; specialinvoke v.(org.apache.activemq.broker.region.MessageReference)>(v); interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v); label: interfaceinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; 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: 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; } public synchronized void acknowledge(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck) throws java.lang.Exception { org.apache.activemq.broker.ConnectionContext v; int v, v, v; java.lang.String v, v; org.apache.activemq.broker.region.TopicSubscription v; boolean v, v, v, v, v, v, v, v; org.apache.activemq.command.MessageAck v; javax.jms.JMSException v, v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.MessageAck; specialinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; specialinvoke v.(v, v); goto label; 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: specialinvoke v.(v, v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; specialinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(1); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; specialinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; return; label: v = new javax.jms.JMSException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid acknowledgment: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: specialinvoke v.(); return; } private void updateStatsOnAck(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck) { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.MessageAck v; org.apache.activemq.broker.region.TopicSubscription$1 v; org.apache.activemq.broker.region.TopicSubscription v; org.apache.activemq.transaction.Transaction v; boolean v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.MessageAck; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = new org.apache.activemq.broker.region.TopicSubscription$1; specialinvoke v.(org.apache.activemq.broker.region.TopicSubscription,org.apache.activemq.command.MessageAck)>(v, v); virtualinvoke v.(v); goto label; label: specialinvoke v.(v); label: return; } public org.apache.activemq.command.Response pullMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessagePull) throws java.lang.Exception { long v, v, v, v, 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.TopicSubscription v; boolean v; org.apache.activemq.broker.region.SubscriptionStatistics v, v; org.apache.activemq.thread.Scheduler v; org.apache.activemq.broker.region.TopicSubscription$2 v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.MessagePull; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); specialinvoke v.(); 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; specialinvoke v.(null); v = v.; virtualinvoke v.(0); label: v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = v.; v = new org.apache.activemq.broker.region.TopicSubscription$2; specialinvoke v.(org.apache.activemq.broker.region.TopicSubscription,long,org.apache.activemq.command.MessagePull)>(v, v, v); v = virtualinvoke v.(); virtualinvoke v.(v, v); label: return null; } private final void pullTimeout(long, boolean) { java.lang.Throwable v, v; long v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.management.CountStatisticImpl v; byte v; java.util.concurrent.atomic.AtomicInteger v, v, v; org.apache.activemq.broker.Connection v; org.apache.activemq.broker.region.TopicSubscription 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.TopicSubscription; 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: specialinvoke v.(null); 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; } private void updateStatsOnAck(org.apache.activemq.command.MessageAck) { org.apache.activemq.broker.region.TopicSubscription v; boolean v, v, v, v, v, v, v, v, v; org.apache.activemq.command.MessageId v, v, v, v; java.util.List v, v; org.apache.activemq.broker.region.Destination v, v, v; java.lang.Throwable v; long v, v; java.util.ArrayList v; int v, v; org.apache.activemq.command.MessageAck v; java.util.Iterator v, v; org.apache.activemq.management.SizeStatisticImpl v; org.apache.activemq.broker.region.SubscriptionStatistics v; java.lang.Object v, v, v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: org.apache.activemq.command.MessageAck; v = virtualinvoke v.(); if v == 0 goto label; v = v.; entermonitor 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 = virtualinvoke 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; interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = neg v; virtualinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(v, v, 1); v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(1); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; if v == 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); specialinvoke v.(v, v, v); label: v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } private void incrementStatsOnAck(org.apache.activemq.broker.region.Destination, org.apache.activemq.command.MessageAck, int) { org.apache.activemq.management.CountStatisticImpl v, v, v, v, v; int v; org.apache.activemq.broker.region.TopicSubscription v; org.apache.activemq.command.ConsumerInfo v; boolean v, v; org.apache.activemq.command.MessageAck v; org.apache.activemq.broker.region.SubscriptionStatistics v; org.apache.activemq.broker.region.DestinationStatistics v, v, v, v; org.apache.activemq.broker.region.Destination v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: org.apache.activemq.broker.region.Destination; v := @parameter: org.apache.activemq.command.MessageAck; v := @parameter: int; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } public int countBeforeFull() { java.util.concurrent.atomic.AtomicInteger v, v; int v, v, v, v, v, v; org.apache.activemq.broker.region.TopicSubscription v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.broker.region.TopicSubscription; 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 = virtualinvoke v.(); v = v - v; label: return v; } public int getPendingQueueSize() { int v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = virtualinvoke v.(); return v; } public long getPendingMessageSize() { long v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = v.; v = interfaceinvoke v.(); return v; } public int getDispatchedQueueSize() { long v, v, v; org.apache.activemq.management.CountStatisticImpl v, v; org.apache.activemq.broker.region.SubscriptionStatistics v, v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; return v; } public int getMaximumPendingMessages() { int v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = 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.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; 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.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke 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.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public int discarded() { int v; org.apache.activemq.broker.region.TopicSubscription v; java.util.concurrent.atomic.AtomicInteger v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = v.; v = virtualinvoke v.(); return v; } public int matched() { int v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = v.; v = interfaceinvoke v.(); return v; } public void setMaximumPendingMessages(int) { int v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: int; v. = v; return; } public org.apache.activemq.broker.region.policy.MessageEvictionStrategy getMessageEvictionStrategy() { org.apache.activemq.broker.region.TopicSubscription v; org.apache.activemq.broker.region.policy.MessageEvictionStrategy v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = v.; return v; } public void setMessageEvictionStrategy(org.apache.activemq.broker.region.policy.MessageEvictionStrategy) { org.apache.activemq.broker.region.TopicSubscription v; org.apache.activemq.broker.region.policy.MessageEvictionStrategy v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: org.apache.activemq.broker.region.policy.MessageEvictionStrategy; v. = v; return; } public synchronized int getMaxProducersToAudit() { int v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = v.; return v; } public synchronized void setMaxProducersToAudit(int) { org.apache.activemq.ActiveMQMessageAudit v, v; int v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: int; v. = v; v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: return; } public synchronized int getMaxAuditDepth() { int v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = v.; return v; } public synchronized void setMaxAuditDepth(int) { org.apache.activemq.ActiveMQMessageAudit v, v; int v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: int; v. = v; v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: return; } public boolean isEnableAudit() { org.apache.activemq.broker.region.TopicSubscription v; boolean v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = v.; return v; } public synchronized void setEnableAudit(boolean) { org.apache.activemq.ActiveMQMessageAudit v, v; int v, v; org.apache.activemq.broker.region.TopicSubscription v; boolean v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v := @parameter: boolean; v. = v; if v == 0 goto label; v = v.; if v != null goto label; v = new org.apache.activemq.ActiveMQMessageAudit; v = v.; v = v.; specialinvoke v.(int,int)>(v, v); v. = v; label: return; } public boolean isFull() { java.util.concurrent.atomic.AtomicInteger v, v; int v, v, v, v, v, v; org.apache.activemq.broker.region.TopicSubscription v; org.apache.activemq.command.ConsumerInfo v; boolean v; v := @this: org.apache.activemq.broker.region.TopicSubscription; 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 = virtualinvoke 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 int getInFlightSize() { int v; org.apache.activemq.broker.region.TopicSubscription v; v := @this: org.apache.activemq.broker.region.TopicSubscription; v = virtualinvoke v.