public class org.apache.activemq.ActiveMQMessageConsumer extends java.lang.Object implements org.apache.activemq.MessageAvailableConsumer, org.apache.activemq.management.StatsCapable, org.apache.activemq.ActiveMQDispatcher { private static final org.slf4j.Logger LOG; protected final org.apache.activemq.ActiveMQSession session; protected final org.apache.activemq.command.ConsumerInfo info; protected final org.apache.activemq.MessageDispatchChannel unconsumedMessages; protected final java.util.LinkedList deliveredMessages; private org.apache.activemq.ActiveMQMessageConsumer$PreviouslyDeliveredMap previouslyDeliveredMessages; private int deliveredCounter; private int additionalWindowSize; private long redeliveryDelay; private int ackCounter; private int dispatchedCount; private final java.util.concurrent.atomic.AtomicReference messageListener; private final org.apache.activemq.management.JMSConsumerStatsImpl stats; private final java.lang.String selector; private boolean synchronizationRegistered; private final java.util.concurrent.atomic.AtomicBoolean started; private org.apache.activemq.MessageAvailableListener availableListener; private org.apache.activemq.RedeliveryPolicy redeliveryPolicy; private boolean optimizeAcknowledge; private final java.util.concurrent.atomic.AtomicBoolean deliveryingAcknowledgements; private java.util.concurrent.ExecutorService executorService; private org.apache.activemq.MessageTransformer transformer; private volatile boolean clearDeliveredList; java.util.concurrent.atomic.AtomicInteger inProgressClearRequiredFlag; private org.apache.activemq.command.MessageAck pendingAck; private long lastDeliveredSequenceId; private java.io.IOException failureError; private long optimizeAckTimestamp; private long optimizeAcknowledgeTimeOut; private long optimizedAckScheduledAckInterval; private java.lang.Runnable optimizedAckTask; private long failoverRedeliveryWaitPeriod; private boolean transactedIndividualAck; private boolean nonBlockingRedelivery; private boolean consumerExpiryCheckEnabled; public void (org.apache.activemq.ActiveMQSession, org.apache.activemq.command.ConsumerId, org.apache.activemq.command.ActiveMQDestination, java.lang.String, java.lang.String, int, int, boolean, boolean, boolean, javax.jms.MessageListener) throws javax.jms.JMSException { org.apache.activemq.FifoMessageDispatchChannel v; org.apache.activemq.command.ConsumerId v; java.util.Map v, v, v; org.apache.activemq.broker.region.policy.RedeliveryPolicyMap v; org.apache.activemq.management.JMSConsumerStatsImpl v; org.apache.activemq.SimplePriorityMessageDispatchChannel v; org.apache.activemq.ActiveMQSession v, v, v, v, v, v, v; long v, v, v, v; org.apache.activemq.command.ConnectionInfo v; javax.jms.InvalidDestinationException v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; javax.jms.MessageListener v; java.util.concurrent.atomic.AtomicInteger v; org.apache.activemq.management.JMSSessionStatsImpl v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.MessageTransformer v; org.apache.activemq.ActiveMQConnection v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; javax.jms.JMSException v, v; org.apache.activemq.command.ActiveMQDestination v; java.util.concurrent.atomic.AtomicBoolean v, v; java.util.HashMap v; org.apache.activemq.RedeliveryPolicy v, v, v; java.util.concurrent.atomic.AtomicReference v; int v, v, v, v, v, v; java.util.LinkedList v; org.apache.activemq.ConfigurationException v; org.apache.activemq.ActiveMQMessageConsumer v; org.slf4j.Logger v; org.apache.activemq.command.ConnectionId v; java.lang.IllegalArgumentException v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: org.apache.activemq.ActiveMQSession; v := @parameter: org.apache.activemq.command.ConsumerId; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: int; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: javax.jms.MessageListener; specialinvoke v.()>(); v = new java.util.LinkedList; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v. = -1L; v = staticinvoke (); v. = v; v. = 0L; v. = 0L; v. = 0L; v. = 0; v. = 0; v. = 1; if v != null goto label; v = new javax.jms.InvalidDestinationException; specialinvoke v.(java.lang.String)>("Don\'t understand null destinations"); throw v; label: v = virtualinvoke v.(); if v != null goto label; v = new javax.jms.InvalidDestinationException; specialinvoke v.(java.lang.String)>("The destination object was not given a physical name."); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Physical name of Destination should be valid: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v >= 0 goto label; v = new javax.jms.InvalidDestinationException; specialinvoke v.(java.lang.String)>("Cannot use a Temporary destination from another Connection"); throw v; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = new javax.jms.InvalidDestinationException; specialinvoke v.(java.lang.String)>("Cannot use a Temporary destination that has been deleted"); throw v; label: if v >= 0 goto label; v = new javax.jms.JMSException; specialinvoke v.(java.lang.String)>("Cannot have a prefetch size less than zero"); throw v; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.SimplePriorityMessageDispatchChannel; specialinvoke v.()>(); v. = v; goto label; label: v = new org.apache.activemq.FifoMessageDispatchChannel; specialinvoke v.()>(); v. = v; label: v. = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v. = v; v = v.; if v != null goto label; v = new org.apache.activemq.RedeliveryPolicy; specialinvoke v.()>(); v. = v; label: v = virtualinvoke v.(); virtualinvoke v.(v); v = new org.apache.activemq.command.ConsumerInfo; specialinvoke v.(org.apache.activemq.command.ConsumerId)>(v); v. = v; v = v.; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(null); v = virtualinvoke v.(); if v == null goto label; v = new java.util.HashMap; v = virtualinvoke v.(); specialinvoke v.(java.util.Map)>(v); v = staticinvoke (v, "consumer."); v = v.; staticinvoke (v, v); v = interfaceinvoke v.(); if v <= 0 goto label; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("There are \u consumer options that couldn\'t be set on the consumer. Check the options are spelled correctly. Unknown parameters=[\u]. This consumer cannot be started."); v = ; interfaceinvoke v.(v); v = new org.apache.activemq.ConfigurationException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; staticinvoke (v); v = v.; virtualinvoke v.(v); v. = v; goto label; label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); staticinvoke (v); v = v.; v = virtualinvoke v.(); v. = v; goto label; label: v. = null; label: v = new org.apache.activemq.management.JMSConsumerStatsImpl; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.management.JMSSessionStatsImpl,javax.jms.Destination)>(v, v); v. = v; v = v.; v = virtualinvoke v.(); if v == 0 goto label; 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; label: v. = v; v = v.; if v == 0 goto label; v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: v. = v; v = v.; v = virtualinvoke v.(); v. = v; if v == null goto label; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(v); throw v; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: return; catch javax.jms.JMSException from label to label with label; } private boolean isAutoAcknowledgeEach() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.ActiveMQSession v, v; boolean v, v, v, v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } private boolean isAutoAcknowledgeBatch() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.ActiveMQSession v; boolean v, v, v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public org.apache.activemq.management.StatsImpl getStats() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.management.JMSConsumerStatsImpl v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; return v; } public org.apache.activemq.management.JMSConsumerStatsImpl getConsumerStats() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.management.JMSConsumerStatsImpl v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; return v; } public org.apache.activemq.RedeliveryPolicy getRedeliveryPolicy() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.RedeliveryPolicy v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; return v; } public void setRedeliveryPolicy(org.apache.activemq.RedeliveryPolicy) { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.RedeliveryPolicy v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: org.apache.activemq.RedeliveryPolicy; v. = v; return; } public org.apache.activemq.MessageTransformer getTransformer() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.MessageTransformer v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; return v; } public void setTransformer(org.apache.activemq.MessageTransformer) { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.MessageTransformer v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: org.apache.activemq.MessageTransformer; v. = v; return; } public org.apache.activemq.command.ConsumerId getConsumerId() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = virtualinvoke v.(); return v; } public java.lang.String getConsumerName() { org.apache.activemq.ActiveMQMessageConsumer v; java.lang.String v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = virtualinvoke v.(); return v; } protected boolean isNoLocal() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.ConsumerInfo v; boolean v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = virtualinvoke v.(); return v; } protected boolean isBrowser() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.ConsumerInfo v; boolean v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = virtualinvoke v.(); return v; } protected org.apache.activemq.command.ActiveMQDestination getDestination() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.ConsumerInfo v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = virtualinvoke v.(); return v; } public int getPrefetchNumber() { int v; org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = virtualinvoke v.(); return v; } public boolean isDurableSubscriber() { org.apache.activemq.ActiveMQMessageConsumer v; java.lang.String v; org.apache.activemq.command.ConsumerInfo v, v; boolean v, v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public java.lang.String getMessageSelector() throws javax.jms.JMSException { org.apache.activemq.ActiveMQMessageConsumer v; java.lang.String v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; virtualinvoke v.(); v = v.; return v; } public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException { org.apache.activemq.ActiveMQMessageConsumer v; java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); return v; } public void setMessageListener(javax.jms.MessageListener) throws javax.jms.JMSException { org.apache.activemq.ActiveMQMessageConsumer v; javax.jms.MessageListener v; java.util.concurrent.atomic.AtomicReference v, v; javax.jms.JMSException v; org.apache.activemq.MessageDispatchChannel v; int v; org.apache.activemq.ActiveMQSession v, v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: javax.jms.MessageListener; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = new javax.jms.JMSException; specialinvoke v.(java.lang.String)>("Illegal prefetch size of zero. This setting is not supported for asynchronous consumers please set a value of at least 1"); throw v; label: if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(); label: v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v, v); if v == 0 goto label; v = v.; virtualinvoke v.(); goto label; label: v = v.; virtualinvoke v.(null); label: return; } public org.apache.activemq.MessageAvailableListener getAvailableListener() { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.MessageAvailableListener v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; return v; } public void setAvailableListener(org.apache.activemq.MessageAvailableListener) { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.MessageAvailableListener v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: org.apache.activemq.MessageAvailableListener; v. = v; return; } private org.apache.activemq.command.MessageDispatch dequeue(long) throws javax.jms.JMSException { org.apache.activemq.command.ConsumerId v, v, v, v; org.apache.activemq.command.Message v; org.apache.activemq.command.MessageDispatch v; byte v, v, v, v; java.lang.Thread v; boolean v, v, v, v; javax.jms.JMSException v, v; long v, v, v, v, v, v, v, v, v; org.apache.activemq.RedeliveryPolicy v; int v; java.lang.String v, v; org.apache.activemq.ActiveMQMessageConsumer v; org.slf4j.Logger v, v, v, v; java.io.IOException v, v; org.apache.activemq.MessageDispatchChannel v, v; java.lang.InterruptedException v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: long; label: v = 0L; v = v cmp 0L; if v <= 0 goto label; v = staticinvoke (); v = v + v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = v cmp 0L; if v <= 0 goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = staticinvoke (); v = v - v; v = staticinvoke (v, 0L); goto label; label: v = v.; if v == null goto label; v = v.; v = staticinvoke (v); throw v; label: return null; label: v = virtualinvoke v.(); if v != null goto label; label: return null; label: v = specialinvoke v.(v); if v == 0 goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("{} received expired message: {}", v, v); specialinvoke v.(v); specialinvoke v.(v, 1); v = v cmp 0L; if v <= 0 goto label; v = staticinvoke (); v = v - v; v = staticinvoke (v, 0L); label: virtualinvoke v.(v); goto label; label: v = specialinvoke v.(v); if v == 0 goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("{} received with excessive redelivered: {}", v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Dispatch[\u] to \u exceeds redelivery policy limit:\u0001"); specialinvoke v.(v, v); v = v cmp 0L; if v <= 0 goto label; v = staticinvoke (); v = v - v; v = staticinvoke (v, 0L); label: virtualinvoke v.(v); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u received message: \u0001"); interfaceinvoke v.(v); label: return v; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); v = staticinvoke (v); throw v; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; } private boolean consumeExpiredMessage(org.apache.activemq.command.MessageDispatch) { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.Message v; org.apache.activemq.command.MessageDispatch v; boolean v, v, v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: org.apache.activemq.command.MessageDispatch; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } private void poisonAck(org.apache.activemq.command.MessageDispatch, java.lang.String) throws javax.jms.JMSException { java.lang.Throwable v; org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.MessageAck v; org.apache.activemq.command.MessageId v; org.apache.activemq.command.Message v; org.apache.activemq.command.MessageDispatch v; java.lang.String v; org.apache.activemq.ActiveMQSession v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: org.apache.activemq.command.MessageDispatch; v := @parameter: java.lang.String; v = new org.apache.activemq.command.MessageAck; specialinvoke v.(org.apache.activemq.command.MessageDispatch,byte,int)>(v, 1, 1); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = new java.lang.Throwable; specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); return; } private boolean redeliveryExceeded(org.apache.activemq.command.MessageDispatch) { org.apache.activemq.RedeliveryPolicy v, v, v, v; org.apache.activemq.command.Message v; org.apache.activemq.command.MessageDispatch v; int v, v, v, v; boolean v, v, v; org.apache.activemq.ActiveMQMessageConsumer v; java.lang.Exception v; java.lang.Object v; org.apache.activemq.ActiveMQSession v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: org.apache.activemq.command.MessageDispatch; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = (int) -1; if v == v goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v <= v goto label; v = virtualinvoke v.(); v = virtualinvoke v.("redeliveryDelay"); if v != null goto label; v = 1; goto label; label: v = 0; label: return v; label: v := @caughtexception; return 0; catch java.lang.Exception from label to label with label; } public javax.jms.Message receive() throws javax.jms.JMSException { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.ActiveMQMessage v; org.apache.activemq.command.MessageDispatch v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(0L); v = specialinvoke v.(-1L); if v != null goto label; return null; label: specialinvoke v.(v); specialinvoke v.(v, 0); v = specialinvoke v.(v); return v; } private org.apache.activemq.command.ActiveMQMessage createActiveMQMessage(org.apache.activemq.command.MessageDispatch) throws javax.jms.JMSException { org.apache.activemq.command.ActiveMQMessage v; org.apache.activemq.command.Message v, v; org.apache.activemq.command.MessageDispatch v; byte v, v; org.apache.activemq.blob.BlobDownloader v; javax.jms.Message v; boolean v, v, v; org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.ActiveMQMessageConsumer$1 v; org.apache.activemq.ActiveMQMessageConsumer$2 v; org.apache.activemq.MessageTransformer v, v; org.apache.activemq.ActiveMQConnection v, v, v; java.util.List v; org.apache.activemq.blob.BlobTransferPolicy v; org.apache.activemq.ActiveMQSession v, v, v, v, v, v, v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: org.apache.activemq.command.MessageDispatch; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 29 goto label; v = new org.apache.activemq.blob.BlobDownloader; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.blob.BlobTransferPolicy)>(v); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v != 26 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; if v == null goto label; v = v.; v = v.; v = interfaceinvoke v.(v, v, v); if v == null goto label; v = v.; v = v.; v = staticinvoke (v, v); label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.ActiveMQMessageConsumer$1; specialinvoke v.(org.apache.activemq.ActiveMQMessageConsumer)>(v); virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.ActiveMQMessageConsumer$2; specialinvoke v.(org.apache.activemq.ActiveMQMessageConsumer,org.apache.activemq.command.MessageDispatch)>(v, v); virtualinvoke v.(v); label: return v; } public javax.jms.Message receive(long) throws javax.jms.JMSException { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.ActiveMQMessage v; long v; org.apache.activemq.command.MessageDispatch v; byte v, v; int v; javax.jms.Message v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v := @parameter: long; virtualinvoke v.(); virtualinvoke v.(); v = v cmp 0L; if v != 0 goto label; v = virtualinvoke v.(); return v; label: virtualinvoke v.(v); v = v cmp 0L; if v <= 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = specialinvoke v.(-1L); goto label; label: v = specialinvoke v.(v); label: if v != null goto label; return null; label: specialinvoke v.(v); specialinvoke v.(v, 0); v = specialinvoke v.(v); return v; label: return null; } public javax.jms.Message receiveNoWait() throws javax.jms.JMSException { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.command.MessageDispatch v; int v; org.apache.activemq.command.ActiveMQMessage v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(-1L); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = specialinvoke v.(-1L); goto label; label: v = specialinvoke v.(0L); label: if v != null goto label; return null; label: specialinvoke v.(v); specialinvoke v.(v, 0); v = specialinvoke v.(v); return v; } public void close() throws javax.jms.JMSException { org.apache.activemq.ActiveMQMessageConsumer v; org.apache.activemq.ActiveMQMessageConsumer$3 v; org.apache.activemq.MessageDispatchChannel v; java.util.LinkedList v; org.apache.activemq.ActiveMQSession v, v; boolean v, v, v; org.apache.activemq.TransactionContext v, v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.ActiveMQMessageConsumer$3; specialinvoke v.(org.apache.activemq.ActiveMQMessageConsumer)>(v); virtualinvoke v.(v); goto label; label: virtualinvoke v.(); label: return; } void doClose() throws javax.jms.JMSException { org.apache.activemq.ActiveMQMessageConsumer v; org.slf4j.Logger v; long v, v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.RemoveInfo v; java.lang.Long v; org.apache.activemq.ActiveMQSession v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = v.; v = staticinvoke (v); interfaceinvoke v.("remove: {}, lastDeliveredSequenceId: {}", v, v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); return; } void inProgressClearRequired() { org.apache.activemq.ActiveMQMessageConsumer v; java.util.concurrent.atomic.AtomicInteger v; java.util.LinkedList v; org.apache.activemq.ActiveMQSession v, v; boolean v, v; org.apache.activemq.TransactionContext v, v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; virtualinvoke v.(); v. = 1; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(1); label: return; } void clearMessagesInProgress() { java.lang.Throwable v; java.lang.Integer v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.Message v; java.util.concurrent.atomic.AtomicInteger v, v, v; int v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v, v; org.apache.activemq.ActiveMQMessageConsumer v; org.slf4j.Logger v; java.util.Iterator v; org.apache.activemq.ActiveMQConnection v, v; org.apache.activemq.MessageDispatchChannel v, v, v, v; java.util.List v; java.lang.Object v, v, v; org.apache.activemq.ActiveMQSession v, v; v := @this: org.apache.activemq.ActiveMQMessageConsumer; v = v.; v = virtualinvoke v.(); if v <= 0 goto label; v = v.; v = interfaceinvoke v.(); entermonitor v; label: v = v.; v = virtualinvoke v.(); if v <= 0 goto label; v = ; v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{} clearing unconsumed list ({}) on transport interrupt", v, v); v = v.; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.