public class org.apache.activemq.state.ConnectionStateTracker extends org.apache.activemq.state.CommandVisitorAdapter { private static final org.slf4j.Logger LOG; private static final org.apache.activemq.state.Tracked TRACKED_RESPONSE_MARKER; private static final int MESSAGE_PULL_SIZE; protected final java.util.concurrent.ConcurrentMap connectionStates; private boolean trackTransactions; private boolean restoreSessions; private boolean restoreConsumers; private boolean restoreProducers; private boolean restoreTransaction; private boolean trackMessages; private boolean trackTransactionProducers; private int maxCacheSize; private long currentCacheSize; private final java.util.Map messageCache; public void () { java.util.concurrent.ConcurrentHashMap v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.state.ConnectionStateTracker$1 v; v := @this: org.apache.activemq.state.ConnectionStateTracker; specialinvoke v.()>(); v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v. = 1; v. = 1; v. = 1; v. = 1; v. = 1; v. = 1; v. = 131072; v = new org.apache.activemq.state.ConnectionStateTracker$1; specialinvoke v.(org.apache.activemq.state.ConnectionStateTracker)>(v); v. = v; return; } public org.apache.activemq.state.Tracked track(org.apache.activemq.command.Command) throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.command.Response v; org.apache.activemq.command.Command v; org.apache.activemq.state.ConnectionStateTracker v; java.io.IOException v, v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.Command; label: v = interfaceinvoke v.(v); label: return v; label: v := @caughtexception; throw v; label: v := @caughtexception; v = staticinvoke (v); throw v; catch java.io.IOException from label to label with label; catch java.lang.Throwable from label to label with label; } public void trackBack(org.apache.activemq.command.Command) { org.apache.activemq.command.Command v; org.apache.activemq.state.ConnectionStateTracker v; long v, v, v, v; int v; org.apache.activemq.command.TransactionId v; boolean v, v, v, v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.Command; if v == null goto label; v = v.; if v == 0 goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != null goto label; v = v.; v = virtualinvoke v.(); v = v + v; v. = v; goto label; label: v = v instanceof org.apache.activemq.command.MessagePull; if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = v + 400L; v. = v; label: return; } public void restore(org.apache.activemq.transport.Transport) throws java.io.IOException { java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.ConnectionInfo v, v, v; java.util.Map v; java.lang.String v, v; boolean v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v; java.util.Iterator v, v; org.apache.activemq.command.Command v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; java.util.Collection v, v; org.apache.activemq.transport.Transport v; org.apache.activemq.command.DataStructure v; java.lang.Object v, v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.transport.Transport; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("conn: \u0001"); interfaceinvoke v.(v); label: v = virtualinvoke v.(); interfaceinvoke v.(v); virtualinvoke v.(v, v); v = v.; if v == 0 goto label; virtualinvoke v.(v, v); label: v = v.; if v == 0 goto label; specialinvoke v.(v, v); goto label; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = v; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("command: \u0001"); interfaceinvoke v.(v); label: interfaceinvoke v.(v); goto label; label: return; } private void restoreTransactions(org.apache.activemq.transport.Transport, org.apache.activemq.state.ConnectionState) throws java.io.IOException { java.util.Vector v; byte v; java.util.Map v, v; javax.jms.TransactionRolledBackException v; org.apache.activemq.command.RemoveInfo v; java.lang.String v, v, v, v, v, v; org.apache.activemq.command.TransactionId v, v, v; org.apache.activemq.transport.TransportListener v; boolean v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.state.ConnectionStateTracker v; java.util.Collection v, v, v; org.apache.activemq.transport.Transport v; java.util.List v, v, v, v; int v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v; java.util.Iterator v, v, v, v, v; org.apache.activemq.command.Command v; org.apache.activemq.state.ConnectionState v; org.apache.activemq.command.ExceptionResponse v; org.apache.activemq.command.ProducerInfo v, v, v, v; java.lang.Object v, v, v, v, v, v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.transport.Transport; v := @parameter: org.apache.activemq.state.ConnectionState; v = new java.util.Vector; specialinvoke v.()>(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("tx: \u0001"); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v - 1; v = interfaceinvoke v.(v); v = v instanceof org.apache.activemq.command.TransactionInfo; if v == 0 goto label; v = virtualinvoke v.(); if v != 2 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("rolling back potentially completed tx: \u0001"); interfaceinvoke v.(v); label: virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("tx replay producer :\u0001"); interfaceinvoke v.(v); label: v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("tx replay: \u0001"); interfaceinvoke v.(v); label: interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("tx remove replayed producer :\u0001"); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.activemq.command.ExceptionResponse; specialinvoke v.()>(); v = new javax.jms.TransactionRolledBackException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Transaction completion in doubt due to failover. Forcing rollback of \u0001"); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: return; } protected void restoreSessions(org.apache.activemq.transport.Transport, org.apache.activemq.state.ConnectionState) throws java.io.IOException { org.apache.activemq.command.SessionInfo v, v; java.lang.String v; boolean v, v, v, v; org.slf4j.Logger v, v; java.util.Iterator v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.command.SessionId v; java.util.Collection v; org.apache.activemq.state.ConnectionState v; org.apache.activemq.transport.Transport v; java.lang.Object v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.transport.Transport; v := @parameter: org.apache.activemq.state.ConnectionState; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("session: \u0001"); interfaceinvoke v.(v); label: v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; if v == 0 goto label; virtualinvoke v.(v, v); label: v = v.; if v == 0 goto label; virtualinvoke v.(v, v); goto label; label: return; } protected void restoreConsumers(org.apache.activemq.transport.Transport, org.apache.activemq.state.SessionState) throws java.io.IOException { org.apache.activemq.command.ConsumerId v, v, v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.state.SessionState v; org.apache.activemq.command.SessionInfo v; java.util.Map v; int v, v; java.lang.String v, v; org.apache.activemq.command.ConsumerInfo v, v, v, v; boolean v, v, v, v; org.slf4j.Logger v, v, v, v; java.util.Iterator v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.command.SessionId v; java.util.Collection v; org.apache.activemq.transport.Transport v; java.lang.Object v, v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.transport.Transport; v := @parameter: org.apache.activemq.state.SessionState; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); virtualinvoke v.(0); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("restore consumer: \u in pull mode pending recovery, overriding prefetch: \u0001"); interfaceinvoke v.(v); label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("consumer: \u0001"); interfaceinvoke v.(v); label: interfaceinvoke v.(v); goto label; label: return; } protected void restoreProducers(org.apache.activemq.transport.Transport, org.apache.activemq.state.SessionState) throws java.io.IOException { org.slf4j.Logger v, v; java.util.Iterator v; org.apache.activemq.state.ConnectionStateTracker v; java.util.Collection v; org.apache.activemq.transport.Transport v; org.apache.activemq.command.ProducerId v; org.apache.activemq.state.SessionState v; org.apache.activemq.command.ProducerInfo v, v; java.lang.Object v; java.lang.String v; boolean v, v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.transport.Transport; v := @parameter: org.apache.activemq.state.SessionState; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("producer: \u0001"); interfaceinvoke v.(v); label: v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: return; } protected void restoreTempDestinations(org.apache.activemq.transport.Transport, org.apache.activemq.state.ConnectionState) throws java.io.IOException { org.slf4j.Logger v, v; java.util.Iterator v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.state.ConnectionState v; org.apache.activemq.transport.Transport v; org.apache.activemq.command.ActiveMQDestination v; java.util.List v; java.lang.Object v; java.lang.String v; boolean v, v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.transport.Transport; v := @parameter: org.apache.activemq.state.ConnectionState; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("tempDest: \u0001"); interfaceinvoke v.(v); goto label; label: return; } public org.apache.activemq.command.Response processAddDestination(org.apache.activemq.command.DestinationInfo) { org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.state.Tracked v; java.lang.Object v; org.apache.activemq.command.DestinationInfo v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.DestinationInfo; if v == null goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(v); label: v = ; return v; } public org.apache.activemq.command.Response processRemoveDestination(org.apache.activemq.command.DestinationInfo) { org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.state.Tracked v; java.lang.Object v; org.apache.activemq.command.DestinationInfo v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.DestinationInfo; if v == null goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = ; return v; } public org.apache.activemq.command.Response processAddProducer(org.apache.activemq.command.ProducerInfo) { org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.command.SessionId v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.ProducerId v, v; org.apache.activemq.state.Tracked v, v; org.apache.activemq.state.SessionState v; org.apache.activemq.command.ProducerInfo v; org.apache.activemq.state.ConnectionStateTracker$ExceptionResponseCheckAction v; java.lang.Object v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.ProducerInfo; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.state.Tracked; v = new org.apache.activemq.state.ConnectionStateTracker$ExceptionResponseCheckAction; specialinvoke v.(org.apache.activemq.state.ConnectionStateTracker,org.apache.activemq.command.Command)>(v, v); specialinvoke v.(org.apache.activemq.state.ResponseHandler)>(v); return v; label: v = ; return v; } public org.apache.activemq.command.Response processRemoveProducer(org.apache.activemq.command.ProducerId) { org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.command.SessionId v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.ProducerId v; org.apache.activemq.state.Tracked v; org.apache.activemq.state.SessionState v; java.lang.Object v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.ProducerId; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: v = ; return v; } public org.apache.activemq.command.Response processAddConsumer(org.apache.activemq.command.ConsumerInfo) { org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.command.SessionId v; org.apache.activemq.command.ConsumerId v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.state.Tracked v, v; org.apache.activemq.state.SessionState v; org.apache.activemq.state.ConnectionStateTracker$ExceptionResponseCheckAction v; java.lang.Object v; org.apache.activemq.command.ConsumerInfo v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.ConsumerInfo; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.state.Tracked; v = new org.apache.activemq.state.ConnectionStateTracker$ExceptionResponseCheckAction; specialinvoke v.(org.apache.activemq.state.ConnectionStateTracker,org.apache.activemq.command.Command)>(v, v); specialinvoke v.(org.apache.activemq.state.ResponseHandler)>(v); return v; label: v = ; return v; } public org.apache.activemq.command.Response processRemoveConsumer(org.apache.activemq.command.ConsumerId, long) { org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.command.SessionId v; long v; org.apache.activemq.command.ConsumerId v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.state.Tracked v; org.apache.activemq.state.SessionState v; java.util.Map v; java.lang.Object v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.ConsumerId; v := @parameter: long; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = ; return v; } public org.apache.activemq.command.Response processAddSession(org.apache.activemq.command.SessionInfo) { org.apache.activemq.state.Tracked v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.command.SessionId v; org.apache.activemq.command.SessionInfo v; java.lang.Object v; java.util.concurrent.ConcurrentMap v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.SessionInfo; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: v = ; return v; } public org.apache.activemq.command.Response processRemoveSession(org.apache.activemq.command.SessionId, long) { org.apache.activemq.state.Tracked v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.command.SessionId v; java.lang.Object v; long v; java.util.concurrent.ConcurrentMap v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.SessionId; v := @parameter: long; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: v = ; return v; } public org.apache.activemq.command.Response processAddConnection(org.apache.activemq.command.ConnectionInfo) { org.apache.activemq.state.Tracked v; org.apache.activemq.command.ConnectionInfo v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.state.ConnectionState v; java.util.concurrent.ConcurrentMap v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.ConnectionInfo; if v == null goto label; v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.state.ConnectionState; specialinvoke v.(org.apache.activemq.command.ConnectionInfo)>(v); interfaceinvoke v.(v, v); label: v = ; return v; } public org.apache.activemq.command.Response processRemoveConnection(org.apache.activemq.command.ConnectionId, long) throws java.lang.Exception { org.apache.activemq.state.Tracked v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; long v; java.util.concurrent.ConcurrentMap v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.ConnectionId; v := @parameter: long; if v == null goto label; v = v.; interfaceinvoke v.(v); label: v = ; return v; } public org.apache.activemq.command.Response processMessage(org.apache.activemq.command.Message) throws java.lang.Exception { java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.Message v; org.apache.activemq.state.ProducerState v; org.apache.activemq.state.SessionState v; java.util.Map v; org.apache.activemq.command.TransactionId v, v; boolean v, v, v; org.apache.activemq.state.TransactionState v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.command.MessageId v; org.apache.activemq.command.SessionId v, v; org.apache.activemq.command.ProducerId v; org.apache.activemq.state.Tracked v; java.lang.Object v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.Message; if v == null goto label; v = v.; if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); v = v.; if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); virtualinvoke v.(v); label: v = ; return v; label: v = v.; if v == 0 goto label; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: return null; } public org.apache.activemq.command.Response processBeginTransaction(org.apache.activemq.command.TransactionInfo) { org.apache.activemq.state.TransactionState v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.state.Tracked v; org.apache.activemq.command.TransactionInfo v; java.lang.Object v; org.apache.activemq.command.TransactionId v, v, v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.TransactionInfo; v = v.; if v == 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); label: v = ; return v; label: return null; } public org.apache.activemq.command.Response processPrepareTransaction(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.state.TransactionState v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.state.ConnectionStateTracker$PrepareReadonlyTransactionAction v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.state.Tracked v; org.apache.activemq.command.TransactionInfo v; java.lang.Object v; org.apache.activemq.command.TransactionId v, v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.TransactionInfo; v = v.; if v == 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); v = new org.apache.activemq.state.Tracked; v = new org.apache.activemq.state.ConnectionStateTracker$PrepareReadonlyTransactionAction; specialinvoke v.(org.apache.activemq.state.ConnectionStateTracker,org.apache.activemq.command.TransactionInfo)>(v, v); specialinvoke v.(org.apache.activemq.state.ResponseHandler)>(v); return v; label: return null; } public org.apache.activemq.command.Response processCommitTransactionOnePhase(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.state.TransactionState v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.state.Tracked v; org.apache.activemq.command.TransactionInfo v; java.lang.Object v; org.apache.activemq.command.TransactionId v, v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.TransactionInfo; v = v.; if v == 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); v = new org.apache.activemq.state.Tracked; v = new org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction; specialinvoke v.(org.apache.activemq.state.ConnectionStateTracker,org.apache.activemq.command.TransactionInfo)>(v, v); specialinvoke v.(org.apache.activemq.state.ResponseHandler)>(v); return v; label: return null; } public org.apache.activemq.command.Response processCommitTransactionTwoPhase(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.state.TransactionState v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.state.Tracked v; org.apache.activemq.command.TransactionInfo v; java.lang.Object v; org.apache.activemq.command.TransactionId v, v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.TransactionInfo; v = v.; if v == 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); v = new org.apache.activemq.state.Tracked; v = new org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction; specialinvoke v.(org.apache.activemq.state.ConnectionStateTracker,org.apache.activemq.command.TransactionInfo)>(v, v); specialinvoke v.(org.apache.activemq.state.ResponseHandler)>(v); return v; label: return null; } public org.apache.activemq.command.Response processRollbackTransaction(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.state.TransactionState v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.state.Tracked v; org.apache.activemq.command.TransactionInfo v; java.lang.Object v; org.apache.activemq.command.TransactionId v, v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.TransactionInfo; v = v.; if v == 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); v = new org.apache.activemq.state.Tracked; v = new org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction; specialinvoke v.(org.apache.activemq.state.ConnectionStateTracker,org.apache.activemq.command.TransactionInfo)>(v, v); specialinvoke v.(org.apache.activemq.state.ResponseHandler)>(v); return v; label: return null; } public org.apache.activemq.command.Response processEndTransaction(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.state.TransactionState v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.state.Tracked v; org.apache.activemq.command.TransactionInfo v; java.lang.Object v; org.apache.activemq.command.TransactionId v, v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.TransactionInfo; v = v.; if v == 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: v = ; return v; label: return null; } public org.apache.activemq.command.Response processMessagePull(org.apache.activemq.command.MessagePull) throws java.lang.Exception { org.apache.activemq.state.ConnectionStateTracker v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.MessagePull v; org.apache.activemq.command.ActiveMQDestination v; java.util.Map v; java.lang.Object v; java.lang.String v, v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.command.MessagePull; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001::\u0001"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); if v != null goto label; virtualinvoke v.(1); label: return null; } public boolean isRestoreConsumers() { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v = v.; return v; } public void setRestoreConsumers(boolean) { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: boolean; v. = v; return; } public boolean isRestoreProducers() { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v = v.; return v; } public void setRestoreProducers(boolean) { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: boolean; v. = v; return; } public boolean isRestoreSessions() { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v = v.; return v; } public void setRestoreSessions(boolean) { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: boolean; v. = v; return; } public boolean isTrackTransactions() { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v = v.; return v; } public void setTrackTransactions(boolean) { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: boolean; v. = v; return; } public boolean isTrackTransactionProducers() { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v = v.; return v; } public void setTrackTransactionProducers(boolean) { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: boolean; v. = v; return; } public boolean isRestoreTransaction() { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v = v.; return v; } public void setRestoreTransaction(boolean) { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: boolean; v. = v; return; } public boolean isTrackMessages() { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v = v.; return v; } public void setTrackMessages(boolean) { org.apache.activemq.state.ConnectionStateTracker v; boolean v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: boolean; v. = v; return; } public int getMaxCacheSize() { int v; org.apache.activemq.state.ConnectionStateTracker v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v = v.; return v; } public void setMaxCacheSize(int) { int v; org.apache.activemq.state.ConnectionStateTracker v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: int; v. = v; return; } public long getCurrentCacheSize() { long v; org.apache.activemq.state.ConnectionStateTracker v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v = v.; return v; } public void connectionInterruptProcessingComplete(org.apache.activemq.transport.Transport, org.apache.activemq.command.ConnectionId) { org.apache.activemq.command.ConsumerId v, v; java.util.concurrent.ConcurrentMap v; java.util.Map v; int v, v, v; java.lang.String v, v; boolean v, v, v; org.slf4j.Logger v, v, v, v; java.util.Iterator v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.state.ConnectionStateTracker v; java.util.Set v; org.apache.activemq.transport.Transport v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ConsumerControl v; java.lang.Object v, v, v, v, v; v := @this: org.apache.activemq.state.ConnectionStateTracker; v := @parameter: org.apache.activemq.transport.Transport; v := @parameter: org.apache.activemq.command.ConnectionId; v = v.; v = interfaceinvoke v.(v); if v == null goto label; virtualinvoke v.