public class org.apache.activemq.broker.TransportConnection extends java.lang.Object implements org.apache.activemq.broker.Connection, org.apache.activemq.thread.Task, org.apache.activemq.state.CommandVisitor { private static final org.slf4j.Logger LOG; private static final org.slf4j.Logger TRANSPORTLOG; private static final org.slf4j.Logger SERVICELOG; protected final org.apache.activemq.broker.Broker broker; protected final org.apache.activemq.broker.BrokerService brokerService; protected final org.apache.activemq.broker.TransportConnector connector; protected final java.util.Map brokerConnectionStates; protected org.apache.activemq.command.BrokerInfo brokerInfo; protected final java.util.List dispatchQueue; protected org.apache.activemq.thread.TaskRunner taskRunner; protected final java.util.concurrent.atomic.AtomicReference transportException; protected java.util.concurrent.atomic.AtomicBoolean dispatchStopped; private final org.apache.activemq.transport.Transport transport; private org.apache.activemq.security.MessageAuthorizationPolicy messageAuthorizationPolicy; private org.apache.activemq.command.WireFormatInfo wireFormatInfo; private boolean inServiceException; private final org.apache.activemq.broker.region.ConnectionStatistics statistics; private boolean manageable; private boolean slow; private boolean markedCandidate; private boolean blockedCandidate; private boolean blocked; private boolean connected; private boolean active; private static final int NEW; private static final int STARTING; private static final int STARTED; private static final int PENDING_STOP; private final java.util.concurrent.atomic.AtomicInteger status; private long timeStamp; private final java.util.concurrent.atomic.AtomicBoolean stopping; private final java.util.concurrent.CountDownLatch stopped; private final java.util.concurrent.atomic.AtomicBoolean asyncException; private final java.util.Map producerExchanges; private final java.util.Map consumerExchanges; private final java.util.concurrent.CountDownLatch dispatchStoppedLatch; private org.apache.activemq.broker.ConnectionContext context; private boolean networkConnection; private boolean faultTolerantConnection; private final java.util.concurrent.atomic.AtomicInteger protocolVersion; private org.apache.activemq.network.DemandForwardingBridge duplexBridge; private final org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory; private final org.apache.activemq.thread.TaskRunnerFactory stopTaskRunnerFactory; private org.apache.activemq.broker.TransportConnectionStateRegister connectionStateRegister; private final java.util.concurrent.locks.ReentrantReadWriteLock serviceLock; private java.lang.String duplexNetworkConnectorId; public void (org.apache.activemq.broker.TransportConnector, org.apache.activemq.transport.Transport, org.apache.activemq.broker.Broker, org.apache.activemq.thread.TaskRunnerFactory, org.apache.activemq.thread.TaskRunnerFactory) { org.apache.activemq.broker.TransportConnection$1 v; org.apache.activemq.security.MessageAuthorizationPolicy v; org.apache.activemq.broker.SingleTransportConnectionStateRegister v; java.util.concurrent.atomic.AtomicInteger v, v; java.util.Map v; boolean v; org.apache.activemq.broker.BrokerService v, v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.transport.Transport v, v, v, v; java.util.concurrent.CountDownLatch v, v; org.apache.activemq.broker.region.ConnectorStatistics v; org.apache.activemq.thread.TaskRunnerFactory v, v; org.apache.activemq.broker.region.ConnectionStatistics v, v; java.util.concurrent.atomic.AtomicBoolean v, v, v; java.util.HashMap v, v; java.util.concurrent.locks.ReentrantReadWriteLock v; java.util.concurrent.atomic.AtomicReference v; org.apache.activemq.broker.Broker v, v; org.apache.activemq.broker.TransportConnector v; java.util.LinkedList v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.broker.TransportConnector; v := @parameter: org.apache.activemq.transport.Transport; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; 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 org.apache.activemq.broker.region.ConnectionStatistics; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(12); v. = v; v = new org.apache.activemq.broker.SingleTransportConnectionStateRegister; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v. = v; v. = v; v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(class "Lorg/apache/activemq/broker/region/RegionBroker;"); v = virtualinvoke v.(); v. = v; if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; label: v. = v; v. = v; v. = v; v = v.; v = v instanceof org.apache.activemq.broker.BrokerServiceAware; if v == 0 goto label; v = v.; v = v.; interfaceinvoke v.(v); label: v = v.; v = new org.apache.activemq.broker.TransportConnection$1; specialinvoke v.(org.apache.activemq.broker.TransportConnection)>(v); interfaceinvoke v.(v); v. = 1; return; } public int getDispatchQueueSize() { java.lang.Throwable v; java.util.List v, v; org.apache.activemq.broker.TransportConnection v; int v; v := @this: org.apache.activemq.broker.TransportConnection; v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(); exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } public void serviceTransportException(java.io.IOException) { java.lang.Object[] v; java.util.concurrent.atomic.AtomicBoolean v; java.util.concurrent.atomic.AtomicReference v; java.util.concurrent.atomic.AtomicInteger v; org.apache.activemq.broker.TransportConnector v; int v; java.lang.String v, v; boolean v, v, v, v, v; org.apache.activemq.broker.TransportConnection v; org.slf4j.Logger v, v, v, v, v; java.io.IOException v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: java.io.IOException; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 3 goto label; v = v.; virtualinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v[2] = v; interfaceinvoke v.("{} failed: {}", v); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = specialinvoke v.(v); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("{} failed", v, v); goto label; label: v = ; v = virtualinvoke v.(); interfaceinvoke v.("{} failed: {}", v, v); label: virtualinvoke v.(v); label: return; } private boolean suppressed(java.io.IOException) { org.apache.activemq.broker.TransportConnection v; java.io.IOException v; org.apache.activemq.broker.TransportConnector v; int v, v; java.lang.String v; boolean v, v, v, v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: java.io.IOException; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v instanceof java.net.SocketException; if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.("reset"); v = (int) -1; if v != v goto label; label: v = v instanceof java.io.EOFException; if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } public void serviceExceptionAsync(java.io.IOException) { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.broker.TransportConnection$2 v; java.util.concurrent.atomic.AtomicBoolean v; java.io.IOException v; boolean v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: java.io.IOException; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; v = new org.apache.activemq.broker.TransportConnection$2; specialinvoke v.(org.apache.activemq.broker.TransportConnection,java.lang.String,java.io.IOException)>(v, "Async Exception Handler", v); virtualinvoke v.(); label: return; } public void serviceException(java.lang.Throwable) { java.lang.Throwable v, v; java.util.concurrent.atomic.AtomicBoolean v, v; java.util.concurrent.atomic.AtomicReference v; java.util.concurrent.atomic.AtomicInteger v; java.lang.Thread v; int v; java.lang.String v, v; boolean v, v, v, v, v; org.apache.activemq.broker.TransportConnection v; org.slf4j.Logger v, v, v, v; org.apache.activemq.command.ConnectionError v, v; java.lang.InterruptedException v; java.lang.Class v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: java.lang.Throwable; v = v instanceof java.io.IOException; if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v != class "Lorg/apache/activemq/broker/BrokerStoppedException;" goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("Broker has been stopped. Notifying client and closing his connection."); v = new org.apache.activemq.command.ConnectionError; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); label: staticinvoke (500L); label: goto label; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); label: virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v != 0 goto label; v. = 1; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Async error occurred: {}", v, v); goto label; label: v = ; v = virtualinvoke v.(); interfaceinvoke v.("Async error occurred", v); label: v = new org.apache.activemq.command.ConnectionError; specialinvoke v.()>(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v != 3 goto label; virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); label: v. = 0; goto label; label: v := @caughtexception; v. = 0; throw v; label: return; catch java.lang.InterruptedException from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.activemq.command.Response service(org.apache.activemq.command.Command) { org.apache.activemq.broker.ConnectionContext v, v, v; java.util.concurrent.atomic.AtomicInteger v; java.net.URI v; boolean v, v, v, v, v, v, v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.transport.Transport v; java.lang.Throwable v, v, v, v; org.apache.activemq.command.Response v, v; java.lang.Object[] v, v; java.util.concurrent.atomic.AtomicReference v; org.apache.activemq.broker.TransportConnector v; int v, v; java.lang.String v, v, v, v, v; org.slf4j.Logger v, v, v, v; org.apache.activemq.command.Command v; org.apache.activemq.command.ExceptionResponse v, v; java.lang.Class v; java.lang.Object v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.Command; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("activemq.connector", v); v = null; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v == 3 goto label; v = interfaceinvoke v.(v); goto label; label: v = new org.apache.activemq.command.ExceptionResponse; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.lang.Throwable)>(v); v = v; label: goto label; label: v := @caughtexception; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == class "Lorg/apache/activemq/broker/BrokerStoppedException;" goto label; v = ; v = newarray (java.lang.Object)[4]; if v == 0 goto label; v = "sync"; goto label; label: v = "async"; label: v[0] = v; v[1] = v; v = virtualinvoke v.(); v[2] = v; v[3] = v; interfaceinvoke v.("Error occurred while processing {} command: {}, exception: {}", v); label: v = v instanceof org.apache.activemq.broker.SuppressReplyException; if v != 0 goto label; v = virtualinvoke v.(); v = v instanceof org.apache.activemq.broker.SuppressReplyException; if v == 0 goto label; label: v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Suppressing reply to: {} on: {}, cause: {}", v); v = 0; label: if v == 0 goto label; v = v instanceof java.lang.SecurityException; if v != 0 goto label; v = virtualinvoke v.(); v = v instanceof java.lang.SecurityException; if v == 0 goto label; label: v = ; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("Security Error occurred on connection to: {}, {}", v, v); label: v = new org.apache.activemq.command.ExceptionResponse; specialinvoke v.(java.lang.Throwable)>(v); v = v; goto label; label: specialinvoke v.(v, v); virtualinvoke v.(v); label: if v == 0 goto label; if v != null goto label; v = new org.apache.activemq.command.Response; specialinvoke v.()>(); v = v; label: virtualinvoke v.(v); label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(0); v = null; label: v. = null; label: staticinvoke ("activemq.connector"); return v; catch java.lang.Throwable from label to label with label; } private void forceRollbackOnlyOnFailedAsyncTransactionOp(java.lang.Throwable, org.apache.activemq.command.Command) { java.lang.Throwable v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.broker.TransportConnection v; org.slf4j.Logger v; org.apache.activemq.command.Command v; org.apache.activemq.transaction.Transaction v; boolean v, v, v, v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: java.lang.Throwable; v := @parameter: org.apache.activemq.command.Command; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v instanceof java.io.IOException; if v != 0 goto label; v = specialinvoke v.(v); if v == 0 goto label; v = specialinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("on async exception, force rollback of transaction for: {}", v, v); virtualinvoke v.(v); label: return; } private org.apache.activemq.transaction.Transaction getActiveTransaction(org.apache.activemq.command.Command) { org.apache.activemq.command.ConsumerId v; java.util.concurrent.ConcurrentMap v, v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.command.TransactionId v, v; boolean v, v; org.apache.activemq.broker.TransportConnection v; org.slf4j.Logger v; org.apache.activemq.command.Command v; org.apache.activemq.broker.ConsumerBrokerExchange v; java.lang.Exception v; org.apache.activemq.command.ProducerId v; java.lang.Object v; org.apache.activemq.broker.ProducerBrokerExchange v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.Command; label: v = v instanceof org.apache.activemq.command.Message; if v == 0 goto label; v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); goto label; label: v = v instanceof org.apache.activemq.command.MessageAck; if v == 0 goto label; v = virtualinvoke v.(); v = specialinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("failed to find active transaction for command: {}", v, v); label: return v; catch java.lang.Exception from label to label with label; } private boolean isInTransaction(org.apache.activemq.command.Command) { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.Command v; boolean v, v, v, v, v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.Command; v = v instanceof org.apache.activemq.command.Message; if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; label: v = v instanceof org.apache.activemq.command.MessageAck; if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } public org.apache.activemq.command.Response processKeepAlive(org.apache.activemq.command.KeepAliveInfo) throws java.lang.Exception { org.apache.activemq.command.KeepAliveInfo v; org.apache.activemq.broker.TransportConnection v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.KeepAliveInfo; return null; } public org.apache.activemq.command.Response processRemoveSubscription(org.apache.activemq.command.RemoveSubscriptionInfo) throws java.lang.Exception { org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.RemoveSubscriptionInfo v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.ConnectionId v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.RemoveSubscriptionInfo; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); return null; } public org.apache.activemq.command.Response processWireFormat(org.apache.activemq.command.WireFormatInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; java.util.concurrent.atomic.AtomicInteger v; int v; org.apache.activemq.command.WireFormatInfo v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.WireFormatInfo; v. = v; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return null; } public org.apache.activemq.command.Response processShutdown(org.apache.activemq.command.ShutdownInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ShutdownInfo v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.ShutdownInfo; virtualinvoke v.(); return null; } public org.apache.activemq.command.Response processFlush(org.apache.activemq.command.FlushCommand) throws java.lang.Exception { org.apache.activemq.command.FlushCommand v; org.apache.activemq.broker.TransportConnection v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.FlushCommand; return null; } public org.apache.activemq.command.Response processBeginTransaction(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.state.TransactionState v; org.apache.activemq.command.ConnectionId v; java.lang.NullPointerException v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.command.TransactionId v, v, v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.TransactionInfo; v = virtualinvoke v.(); v = virtualinvoke v.(v); v. = null; if v == null goto label; v = virtualinvoke v.(); v. = v; label: if v != null goto label; v = new java.lang.NullPointerException; specialinvoke v.(java.lang.String)>("Context is null"); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: return null; } public int getActiveTransactionCount() { org.apache.activemq.broker.TransportConnection v; java.util.Iterator v; java.util.Collection v; java.util.List v; org.apache.activemq.broker.TransportConnectionStateRegister v; int v, v; java.lang.Object v; boolean v; v := @this: org.apache.activemq.broker.TransportConnection; v = 0; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v + v; goto label; label: return v; } public java.lang.Long getOldestActiveTransactionDuration() { long v, v, v, v, v; org.apache.activemq.broker.TransportConnectionStateRegister v; byte v; java.lang.Long v; boolean v, v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.state.TransactionState v; java.util.Iterator v, v; java.util.Collection v; java.util.List v; java.lang.Object v, v; v := @this: org.apache.activemq.broker.TransportConnection; v = null; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v >= 0 goto label; label: v = v; goto label; label: if v != null goto label; return null; label: v = staticinvoke (); v = virtualinvoke v.(); v = v - v; v = staticinvoke (v); return v; } public org.apache.activemq.command.Response processEndTransaction(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.TransactionInfo v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.TransactionInfo; return null; } public org.apache.activemq.command.Response processPrepareTransaction(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { java.lang.IllegalStateException v; java.lang.NullPointerException v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v, v; int v, v; java.lang.String v; org.apache.activemq.command.TransactionId v, v, v, v; boolean v; org.apache.activemq.command.IntegerResponse v, v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.state.TransactionState v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.TransactionInfo v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.TransactionInfo; v = virtualinvoke v.(); v = virtualinvoke v.(v); v. = null; if v == null goto label; v = virtualinvoke v.(); v. = v; label: if v != null goto label; v = new java.lang.NullPointerException; specialinvoke v.(java.lang.String)>("Context is null"); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != null goto label; v = new java.lang.IllegalStateException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot prepare a transaction that had not been started or previously returned XA_RDONLY: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(1); v = v.; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); virtualinvoke v.(v); if v != 3 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = new org.apache.activemq.command.IntegerResponse; specialinvoke v.(int)>(v); return v; label: v = new org.apache.activemq.command.IntegerResponse; v = virtualinvoke v.(); specialinvoke v.(int)>(v); return v; } public org.apache.activemq.command.Response processCommitTransactionOnePhase(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.command.TransactionId v, v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.TransactionInfo; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v, 1); return null; } public org.apache.activemq.command.Response processCommitTransactionTwoPhase(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.command.TransactionId v, v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.TransactionInfo; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v, 0); return null; } public org.apache.activemq.command.Response processRollbackTransaction(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.command.TransactionId v, v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.TransactionInfo; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); return null; } public org.apache.activemq.command.Response processForgetTransaction(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.command.TransactionId v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.TransactionInfo; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); return null; } public org.apache.activemq.command.Response processRecoverTransactions(org.apache.activemq.command.TransactionInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.TransactionId[] v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.command.DataArrayResponse v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.TransactionInfo; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = v.; v = v.; v = interfaceinvoke v.(v); v = new org.apache.activemq.command.DataArrayResponse; specialinvoke v.(org.apache.activemq.command.DataStructure[])>(v); return v; } public org.apache.activemq.command.Response processMessage(org.apache.activemq.command.Message) throws java.lang.Exception { org.apache.activemq.command.ProducerId v; org.apache.activemq.broker.Broker v; org.apache.activemq.command.Message v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.broker.ProducerBrokerExchange v; boolean v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.Message; v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); label: return null; } public org.apache.activemq.command.Response processMessageAck(org.apache.activemq.command.MessageAck) throws java.lang.Exception { org.apache.activemq.broker.Broker v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.MessageAck v; org.slf4j.Logger v; org.apache.activemq.broker.ConsumerBrokerExchange v; org.apache.activemq.command.ConsumerId v; boolean v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.MessageAck; v = virtualinvoke v.(); v = specialinvoke v.(v); if v == null goto label; v = v.; interfaceinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("no matching consumer {}, ignoring ack {}", v, v); label: return null; } public org.apache.activemq.command.Response processMessagePull(org.apache.activemq.command.MessagePull) throws java.lang.Exception { org.apache.activemq.command.Response v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.MessagePull v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.MessagePull; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); return v; } public org.apache.activemq.command.Response processMessageDispatchNotification(org.apache.activemq.command.MessageDispatchNotification) throws java.lang.Exception { org.apache.activemq.broker.Broker v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.MessageDispatchNotification v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.MessageDispatchNotification; v = v.; interfaceinvoke v.(v); return null; } public org.apache.activemq.command.Response processAddDestination(org.apache.activemq.command.DestinationInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.DestinationInfo v; boolean v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.DestinationInfo; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(v); label: return null; } public org.apache.activemq.command.Response processRemoveDestination(org.apache.activemq.command.DestinationInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.DestinationInfo v; boolean v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.DestinationInfo; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: return null; } public org.apache.activemq.command.Response processAddProducer(org.apache.activemq.command.ProducerInfo) throws java.lang.Exception { java.lang.IllegalStateException v, v, v, v; org.apache.activemq.broker.Broker v, v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.state.SessionState v; org.apache.activemq.broker.TransportConnector v, v; int v, v, v; java.lang.String v, v, v; boolean v, v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.SessionId v; java.util.Set v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ProducerId v, v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.command.ProducerInfo v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.ProducerInfo; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != null goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot add a producer to a connection that had not been registered: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(v); if v != null goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot add a producer to a session that had not been registered: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = specialinvoke v.(v); v = v.; v = virtualinvoke v.(); if v < v goto label; v = new java.lang.IllegalStateException; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Can\'t add producer on connection \u0001: at maximum limit: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: return null; catch java.lang.IllegalStateException from label to label with label; } public org.apache.activemq.command.Response processRemoveProducer(org.apache.activemq.command.ProducerId) throws java.lang.Exception { java.lang.IllegalStateException v, v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.SessionId v; org.apache.activemq.command.ProducerId v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.TransportConnectionState v; org.apache.activemq.state.ProducerState v; org.apache.activemq.state.SessionState v; org.apache.activemq.command.ProducerInfo v; java.lang.String v, v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.ProducerId; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); if v != null goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot remove a producer from a session that had not been registered: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(v); if v != null goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot remove a producer that had not been registered: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: specialinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); return null; } public org.apache.activemq.command.Response processAddConsumer(org.apache.activemq.command.ConsumerInfo) throws java.lang.Exception { java.lang.IllegalStateException v, v, v, v; org.apache.activemq.command.ConsumerId v, v, v; org.apache.activemq.broker.Broker v, v, v; org.apache.activemq.broker.ConnectionContext v, v; org.apache.activemq.state.SessionState v; org.apache.activemq.broker.TransportConnector v, v; int v, v, v; java.lang.String v, v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v, v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.SessionId v; java.util.Set v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.TransportConnectionState v; v := @this: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != null goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot add a consumer to a connection that had not been registered: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(v); if v != null goto label; v = new java.lang.IllegalStateException; v = v.; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u Cannot add a consumer to a session that had not been registered: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = staticinvoke