public class org.apache.activemq.TransactionContext extends java.lang.Object implements javax.transaction.xa.XAResource { public static final java.lang.String xaErrorCodeMarker; private static final org.slf4j.Logger LOG; private static final java.util.HashMap ENDED_XA_TRANSACTION_CONTEXTS; private org.apache.activemq.ActiveMQConnection connection; private final org.apache.activemq.util.LongSequenceGenerator localTransactionIdGenerator; private java.util.List synchronizations; private javax.transaction.xa.Xid associatedXid; private org.apache.activemq.command.TransactionId transactionId; private org.apache.activemq.LocalTransactionEventListener localTransactionEventListener; private int beforeEndIndex; private volatile boolean rollbackOnly; public void () { org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; specialinvoke v.()>(); v. = null; return; } public void (org.apache.activemq.ActiveMQConnection) { org.apache.activemq.ActiveMQConnection v; org.apache.activemq.util.LongSequenceGenerator v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: org.apache.activemq.ActiveMQConnection; specialinvoke v.()>(); v. = v; v = virtualinvoke v.(); v. = v; return; } public boolean isInXATransaction() { java.lang.Throwable v; java.util.Iterator v; java.util.Collection v; java.util.HashMap v, v; java.lang.Object v; org.apache.activemq.command.TransactionId v, v; boolean v, v, v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; return 1; label: v = ; entermonitor v; label: v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; exitmonitor v; label: return 1; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return 0; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void setRollbackOnly(boolean) { boolean v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: boolean; v. = v; return; } public boolean isRollbackOnly() { boolean v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; return v; } public boolean isInLocalTransaction() { org.apache.activemq.command.TransactionId v, v; boolean v, v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public boolean isInTransaction() { org.apache.activemq.command.TransactionId v; boolean v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; if v == null goto label; v = 1; goto label; label: v = 0; label: return v; } public org.apache.activemq.LocalTransactionEventListener getLocalTransactionEventListener() { org.apache.activemq.LocalTransactionEventListener v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; return v; } public void setLocalTransactionEventListener(org.apache.activemq.LocalTransactionEventListener) { org.apache.activemq.LocalTransactionEventListener v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: org.apache.activemq.LocalTransactionEventListener; v. = v; return; } public void addSynchronization(org.apache.activemq.transaction.Synchronization) { java.util.List v, v; org.apache.activemq.transaction.Synchronization v; java.util.ArrayList v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: org.apache.activemq.transaction.Synchronization; v = v.; if v != null goto label; v = new java.util.ArrayList; specialinvoke v.(int)>(10); v. = v; label: v = v.; interfaceinvoke v.(v); return; } private void afterRollback() throws javax.jms.JMSException { java.lang.Throwable v, v; org.slf4j.Logger v; javax.jms.JMSException v; java.util.List v, v, v, v; int v, v; java.lang.Object v, v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; if v != null goto label; return; label: v = null; v = v.; v = interfaceinvoke v.(); v = 0; label: if v >= v goto label; label: v = v.; v = interfaceinvoke v.(v); virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = v.; v = interfaceinvoke v.(v); interfaceinvoke v.("Exception from afterRollback on {}", v, v); if v != null goto label; v = v; label: v = v + 1; goto label; label: v. = null; if v == null goto label; v = staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } private void afterCommit() throws javax.jms.JMSException { java.lang.Throwable v, v; org.slf4j.Logger v; javax.jms.JMSException v; java.util.List v, v, v, v; int v, v; java.lang.Object v, v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; if v != null goto label; return; label: v = null; v = v.; v = interfaceinvoke v.(); v = 0; label: if v >= v goto label; label: v = v.; v = interfaceinvoke v.(v); virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = v.; v = interfaceinvoke v.(v); interfaceinvoke v.("Exception from afterCommit on {}", v, v); if v != null goto label; v = v; label: v = v + 1; goto label; label: v. = null; if v == null goto label; v = staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } private void beforeEnd() throws javax.jms.JMSException { java.lang.Throwable v; javax.jms.JMSException v, v; java.util.List v, v, v; int v, v, v, v; java.lang.Object v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; if v != null goto label; return; label: v = v.; v = interfaceinvoke v.(); label: v = v.; if v >= v goto label; v = v.; v = v.; v = v + 1; v. = v; v = interfaceinvoke v.(v); virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = staticinvoke (v); throw v; label: return; catch javax.jms.JMSException from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.activemq.command.TransactionId getTransactionId() { org.apache.activemq.command.TransactionId v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; return v; } public void begin() throws javax.jms.JMSException { org.apache.activemq.command.LocalTransactionId v; javax.jms.TransactionInProgressException v; long v; org.apache.activemq.command.TransactionId v, v, v; boolean v; org.apache.activemq.TransactionContext v; org.slf4j.Logger v; org.apache.activemq.command.ConnectionId v, v; org.apache.activemq.ActiveMQConnection v, v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.util.LongSequenceGenerator v; org.apache.activemq.LocalTransactionEventListener v, v; v := @this: org.apache.activemq.TransactionContext; v = virtualinvoke v.(); if v == 0 goto label; v = new javax.jms.TransactionInProgressException; specialinvoke v.(java.lang.String)>("Cannot start local transaction. XA transaction is already in progress."); throw v; label: v = v.; if v != null goto label; v. = null; v. = 0; virtualinvoke v.(0); v = new org.apache.activemq.command.LocalTransactionId; v = specialinvoke v.(); v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.ConnectionId,long)>(v, v); v. = v; v = new org.apache.activemq.command.TransactionInfo; v = specialinvoke v.(); v = v.; specialinvoke v.(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 0); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: v = ; v = v.; interfaceinvoke v.("Begin:{}", v); label: return; } public void rollback() throws javax.jms.JMSException { javax.jms.TransactionInProgressException v; java.lang.Integer v; int v, v; org.apache.activemq.command.TransactionId v, v, v; boolean v, v; org.apache.activemq.TransactionContext v; org.slf4j.Logger v, v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.ActiveMQConnection v, v, v; java.util.List v, v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.LocalTransactionEventListener v, v; javax.jms.TransactionRolledBackException v; v := @this: org.apache.activemq.TransactionContext; v = virtualinvoke v.(); if v == 0 goto label; v = new javax.jms.TransactionInProgressException; specialinvoke v.(java.lang.String)>("Cannot rollback() if an XA transaction is already in progress "); throw v; label: specialinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("rollback processing error", v); label: v = v.; if v == null goto label; v = ; v = v.; v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); goto label; label: v = 0; label: v = staticinvoke (v); interfaceinvoke v.("Rollback: {} syncCount: {}", v, v); v = new org.apache.activemq.command.TransactionInfo; v = specialinvoke v.(); v = v.; specialinvoke v.(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 4); v. = null; v = v.; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = 0; label: virtualinvoke v.(v, v); v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: specialinvoke v.(); return; catch javax.jms.TransactionRolledBackException from label to label with label; } public void commit() throws javax.jms.JMSException { java.lang.Throwable v; javax.jms.TransactionInProgressException v; java.lang.Integer v; int v; java.lang.String v; org.apache.activemq.command.TransactionId v, v, v, v, v, v; boolean v, v; org.apache.activemq.TransactionContext v; org.slf4j.Logger v, v, v, v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.ActiveMQConnection v; javax.jms.JMSException v, v; java.util.List v, v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.LocalTransactionEventListener v, v, v, v; javax.jms.TransactionRolledBackException v, v; v := @this: org.apache.activemq.TransactionContext; v = virtualinvoke v.(); if v == 0 goto label; v = new javax.jms.TransactionInProgressException; specialinvoke v.(java.lang.String)>("Cannot commit() if an XA transaction is already in progress "); throw v; label: specialinvoke v.(); label: goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: v = v.; if v == null goto label; v = v.; if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Commit of \u failed due to rollback only request; typically due to failover with pending acks"); label: virtualinvoke v.(); label: v = ; interfaceinvoke v.(v); v = new javax.jms.TransactionRolledBackException; specialinvoke v.(java.lang.String)>(v); throw v; label: v := @caughtexception; v = ; interfaceinvoke v.(v); v = new javax.jms.TransactionRolledBackException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; if v == null goto label; v = ; v = v.; v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); goto label; label: v = 0; label: v = staticinvoke (v); interfaceinvoke v.("Commit: {} syncCount: {}", v, v); v = new org.apache.activemq.command.TransactionInfo; v = specialinvoke v.(); v = v.; specialinvoke v.(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 2); v. = null; label: v = v.; virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: specialinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("commit failed for transaction {}", v, v); v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: specialinvoke v.(); throw v; label: return; catch javax.jms.JMSException from label to label with label; catch java.lang.Throwable from label to label with label; catch javax.jms.JMSException from label to label with label; } public void start(javax.transaction.xa.Xid, int) throws javax.transaction.xa.XAException { org.slf4j.Logger v; int v, v, v; javax.transaction.xa.XAException v, v; java.lang.String v; javax.transaction.xa.Xid v, v; boolean v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: javax.transaction.xa.Xid; v := @parameter: int; v = ; v = staticinvoke (v); interfaceinvoke v.("Start: {}, flags: {}", v, v); v = virtualinvoke v.(); if v == 0 goto label; v = new javax.transaction.xa.XAException; v = (int) -6; specialinvoke v.(int)>(v); throw v; label: v = v.; if v == null goto label; v = new javax.transaction.xa.XAException; v = (int) -6; specialinvoke v.(int)>(v); throw v; label: v. = null; v. = 0; virtualinvoke v.(0); specialinvoke v.(v); return; } private org.apache.activemq.command.ConnectionId getConnectionId() { org.apache.activemq.command.ConnectionInfo v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.ActiveMQConnection v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public void end(javax.transaction.xa.Xid, int) throws javax.transaction.xa.XAException { int v, v, v, v, v, v; java.lang.String v; javax.transaction.xa.Xid v, v, v; boolean v, v, v; org.apache.activemq.TransactionContext v; org.slf4j.Logger v; javax.transaction.xa.XAException v, v, v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: javax.transaction.xa.Xid; v := @parameter: int; v = ; v = staticinvoke (v); interfaceinvoke v.("End: {}, flags: {}", v, v); v = virtualinvoke v.(); if v == 0 goto label; v = new javax.transaction.xa.XAException; v = (int) -6; specialinvoke v.(int)>(v); throw v; label: v = v & 570425344; if v == 0 goto label; v = v.; v = specialinvoke v.(v, v); if v != 0 goto label; v = new javax.transaction.xa.XAException; v = (int) -6; specialinvoke v.(int)>(v); throw v; label: specialinvoke v.(); goto label; label: v = v & 67108864; if v != 67108864 goto label; v = v.; v = specialinvoke v.(v, v); if v == 0 goto label; specialinvoke v.(); goto label; label: v = new javax.transaction.xa.XAException; v = (int) -5; specialinvoke v.(int)>(v); throw v; label: return; } private void invokeBeforeEnd() throws javax.transaction.xa.XAException { java.lang.Throwable v; javax.transaction.xa.XAException v, v, v; javax.jms.JMSException v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; label: specialinvoke v.(); label: specialinvoke v.(null); label: goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = staticinvoke (v); throw v; label: v := @caughtexception; label: specialinvoke v.(null); label: goto label; label: v := @caughtexception; throw v; label: throw v; label: return; catch javax.transaction.xa.XAException from label to label with label; catch javax.jms.JMSException from label to label with label; catch java.lang.Throwable from label to label with label; catch javax.transaction.xa.XAException from label to label with label; } private boolean equals(javax.transaction.xa.Xid, javax.transaction.xa.Xid) { byte[] v, v, v, v; int v, v; javax.transaction.xa.Xid v, v; boolean v, v, v, v, v, v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: javax.transaction.xa.Xid; v := @parameter: javax.transaction.xa.Xid; if v != v goto label; return 1; label: if v != null goto label; v = 1; goto label; label: v = 0; label: if v != null goto label; v = 1; goto label; label: v = 0; label: v = v ^ v; if v == 0 goto label; return 0; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != v goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v, v); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v, v); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public int prepare(javax.transaction.xa.Xid) throws javax.transaction.xa.XAException { boolean v, v, v, v, v; org.apache.activemq.ActiveMQConnection v; javax.jms.JMSException v; javax.transaction.xa.XAException v, v, v; java.lang.Throwable v, v, v; org.apache.activemq.command.Response v; java.lang.Object[] v; java.util.HashMap v, v, v, v; int v, v, v; org.apache.activemq.command.XATransactionId v; java.lang.String v, v; javax.transaction.xa.Xid v, v; org.apache.activemq.TransactionContext v; org.slf4j.Logger v, v, v, v, v; java.util.Iterator v, v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.TransactionInfo v; java.lang.Object v, v, v, v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: javax.transaction.xa.Xid; v = ; interfaceinvoke v.("Prepare: {}", v); if v == null goto label; v = v.; v = specialinvoke v.(v, v); if v == 0 goto label; label: v = new javax.transaction.xa.XAException; v = (int) -6; specialinvoke v.(int)>(v); throw v; label: v = new org.apache.activemq.command.XATransactionId; specialinvoke v.(javax.transaction.xa.Xid)>(v); v = v.; if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("prepare of: \u failed because it was marked rollback only; typically due to failover with pending acks"); interfaceinvoke v.(v); v = new javax.transaction.xa.XAException; specialinvoke v.(int)>(103); throw v; label: v = new org.apache.activemq.command.TransactionInfo; v = specialinvoke v.(); specialinvoke v.(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 1); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); if 3 != v goto label; v = ; entermonitor v; label: v = ; v = virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("firing afterCommit callbacks on XA_RDONLY from prepare: {}", v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(); goto label; label: v = virtualinvoke v.(); label: return v; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("prepare of: \u failed with: \u0001"); interfaceinvoke v.(v, v); v = ; entermonitor v; label: v = ; v = virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: specialinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("failed to firing afterRollback callbacks on prepare failure, txid: {}, context: {}", v); goto label; label: v = staticinvoke (v); throw v; catch java.lang.Throwable from label to label with label; catch javax.jms.JMSException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void rollback(javax.transaction.xa.Xid) throws javax.transaction.xa.XAException { java.lang.Throwable v; java.util.HashMap v, v; int v; org.apache.activemq.command.XATransactionId v; java.lang.String v; org.apache.activemq.command.TransactionId v; javax.transaction.xa.Xid v, v; boolean v, v, v; org.apache.activemq.TransactionContext v; org.slf4j.Logger v, v, v; java.util.Iterator v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.ActiveMQConnection v, v, v; javax.jms.JMSException v; java.lang.Exception v; org.apache.activemq.command.TransactionInfo v; javax.transaction.xa.XAException v, v; java.lang.Object v, v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: javax.transaction.xa.Xid; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Rollback: \u0001"); interfaceinvoke v.(v); label: if v != null goto label; v = new javax.transaction.xa.XAException; v = (int) -6; specialinvoke v.(int)>(v); throw v; label: v = v.; v = specialinvoke v.(v, v); if v == 0 goto label; v = v.; goto label; label: v = new org.apache.activemq.command.XATransactionId; specialinvoke v.(javax.transaction.xa.Xid)>(v); v = v; label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); v = new org.apache.activemq.command.TransactionInfo; v = specialinvoke v.(); specialinvoke v.(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 4); v = v.; virtualinvoke v.(v); v = ; entermonitor v; label: v = ; v = virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: specialinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("ignoring exception from after rollback on ended transaction: {}", v, v); goto label; label: v := @caughtexception; v = staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; catch javax.jms.JMSException from label to label with label; } public void commit(javax.transaction.xa.Xid, boolean) throws javax.transaction.xa.XAException { byte v; boolean v, v, v, v, v; org.apache.activemq.ActiveMQConnection v, v, v; javax.jms.JMSException v; java.lang.Exception v; javax.transaction.xa.XAException v, v, v; java.lang.Throwable v, v, v; java.lang.Object[] v; java.util.HashMap v, v, v, v; int v; java.lang.Boolean v; org.apache.activemq.command.XATransactionId v; java.lang.String v, v; javax.transaction.xa.Xid v, v; org.apache.activemq.TransactionContext v; org.slf4j.Logger v, v, v, v, v; java.util.Iterator v, v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.TransactionInfo v; java.lang.Object v, v, v, v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: javax.transaction.xa.Xid; v := @parameter: boolean; v = ; v = staticinvoke (v); interfaceinvoke v.("Commit: {}, onePhase={}", v, v); if v == null goto label; v = v.; v = specialinvoke v.(v, v); if v == 0 goto label; label: v = new javax.transaction.xa.XAException; v = (int) -6; specialinvoke v.(int)>(v); throw v; label: v = new org.apache.activemq.command.XATransactionId; specialinvoke v.(javax.transaction.xa.Xid)>(v); v = v.; if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("commit of: \u failed because it was marked rollback only; typically due to failover with pending acks"); interfaceinvoke v.(v); v = new javax.transaction.xa.XAException; specialinvoke v.(int)>(103); throw v; label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); v = new org.apache.activemq.command.TransactionInfo; v = specialinvoke v.(); if v == 0 goto label; v = 2; goto label; label: v = 3; label: specialinvoke v.(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, v); v = v.; virtualinvoke v.(v); v = ; entermonitor v; label: v = ; v = virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: specialinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("ignoring exception from after completion on ended transaction: {}", v, v); goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("commit of: \u failed with: \u0001"); interfaceinvoke v.(v, v); if v == 0 goto label; v = ; entermonitor v; label: v = ; v = virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: specialinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("failed to firing afterRollback callbacks commit failure, txid: {}, context: {}", v); goto label; label: v = staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; catch javax.jms.JMSException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void forget(javax.transaction.xa.Xid) throws javax.transaction.xa.XAException { java.lang.Throwable v; java.util.HashMap v, v; int v; org.apache.activemq.command.XATransactionId v; org.apache.activemq.command.TransactionId v; javax.transaction.xa.Xid v, v; boolean v; org.apache.activemq.TransactionContext v; org.slf4j.Logger v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.ActiveMQConnection v; javax.jms.JMSException v; org.apache.activemq.command.TransactionInfo v; javax.transaction.xa.XAException v, v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: javax.transaction.xa.Xid; v = ; interfaceinvoke v.("Forget: {}", v); if v != null goto label; v = new javax.transaction.xa.XAException; v = (int) -6; specialinvoke v.(int)>(v); throw v; label: v = v.; v = specialinvoke v.(v, v); if v == 0 goto label; v = v.; goto label; label: v = new org.apache.activemq.command.XATransactionId; specialinvoke v.(javax.transaction.xa.Xid)>(v); v = v; label: v = new org.apache.activemq.command.TransactionInfo; v = specialinvoke v.(); specialinvoke v.(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 6); label: v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = staticinvoke (v); throw v; label: v = ; entermonitor v; label: v = ; virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch javax.jms.JMSException from label to label with label; catch java.lang.Throwable from label to label with label; } public boolean isSameRM(javax.transaction.xa.XAResource) throws javax.transaction.xa.XAException { java.lang.Throwable v, v; javax.transaction.xa.XAResource v; javax.transaction.xa.XAException v; java.lang.String v, v; boolean v, v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: javax.transaction.xa.XAResource; if v != null goto label; return 0; label: v = v instanceof org.apache.activemq.TransactionContext; if v != 0 goto label; return 0; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); label: return v; label: v := @caughtexception; v = new javax.transaction.xa.XAException; specialinvoke v.(java.lang.String)>("Could not get resource manager id."); v = virtualinvoke v.(v); throw v; catch java.lang.Throwable from label to label with label; } public javax.transaction.xa.Xid[] recover(int) throws javax.transaction.xa.XAException { org.apache.activemq.command.Response v; java.lang.Integer v, v; org.apache.activemq.command.XATransactionId[] v; org.apache.activemq.command.DataStructure[] v; int v, v, v; boolean v; org.apache.activemq.TransactionContext v; org.slf4j.Logger v, v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.ActiveMQConnection v, v, v; javax.jms.JMSException v; org.apache.activemq.command.TransactionInfo v; javax.transaction.xa.XAException v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: int; v = ; v = staticinvoke (v); interfaceinvoke v.("recover({})", v); if 0 != v goto label; v = newarray (org.apache.activemq.command.XATransactionId)[0]; goto label; label: v = new org.apache.activemq.command.TransactionInfo; v = specialinvoke v.(); specialinvoke v.(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, null, 5); label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = v instanceof org.apache.activemq.command.XATransactionId[]; if v != 0 goto label; v = lengthof v; v = newarray (org.apache.activemq.command.XATransactionId)[v]; v = lengthof v; staticinvoke (v, 0, v, 0, v); label: goto label; label: v := @caughtexception; v = staticinvoke (v); throw v; label: v = ; v = staticinvoke (v); interfaceinvoke v.("recover({})={}", v, v); return v; catch javax.jms.JMSException from label to label with label; } public int getTransactionTimeout() throws javax.transaction.xa.XAException { org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; return 0; } public boolean setTransactionTimeout(int) throws javax.transaction.xa.XAException { int v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: int; return 0; } protected java.lang.String getResourceManagerId() throws javax.jms.JMSException { java.lang.String v; org.apache.activemq.ActiveMQConnection v; org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v = v.; v = virtualinvoke v.(); return v; } private void setXid(javax.transaction.xa.Xid) throws javax.transaction.xa.XAException { boolean v; org.apache.activemq.ActiveMQConnection v, v, v, v; javax.jms.JMSException v, v, v; javax.transaction.xa.XAException v, v, v; java.lang.Throwable v; java.util.HashMap v, v, v; java.util.ArrayList v; org.apache.activemq.command.XATransactionId v; org.apache.activemq.command.TransactionId v, v, v, v, v, v, v; javax.transaction.xa.Xid v; org.apache.activemq.TransactionContext v; org.slf4j.Logger v, v; org.apache.activemq.command.ConnectionId v, v; org.apache.activemq.command.TransactionInfo v, v; java.lang.Object v; v := @this: org.apache.activemq.TransactionContext; v := @parameter: javax.transaction.xa.Xid; label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; specialinvoke v.(); v = staticinvoke (v); throw v; label: if v == null goto label; v. = v; v = new org.apache.activemq.command.XATransactionId; specialinvoke v.(javax.transaction.xa.Xid)>(v); v. = v; v = new org.apache.activemq.command.TransactionInfo; v = specialinvoke v.(); v = v.; specialinvoke v.(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 0); label: v = v.; virtualinvoke v.(v); v = ; v = v.; interfaceinvoke v.("{} started XA transaction {}", v, v); label: goto label; label: v := @caughtexception; specialinvoke v.(); v = staticinvoke (v); throw v; label: v = v.; if v == null goto label; v = new org.apache.activemq.command.TransactionInfo; v = specialinvoke v.(); v = v.; specialinvoke v.(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 7); label: v = v.; virtualinvoke v.(v); v = ; v = v.; interfaceinvoke v.("{} ended XA transaction {}", v, v); label: goto label; label: v := @caughtexception; specialinvoke v.(); v = staticinvoke (v); throw v; label: v = ; entermonitor v; label: v = ; v = v.; v = virtualinvoke v.(v); if v != null goto label; v = new java.util.ArrayList; specialinvoke v.(int)>(3); v = v; v = ; v = v.; virtualinvoke v.(v, v); label: v = interfaceinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: specialinvoke v.(); label: return; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; catch java.lang.Throwable from label to label with label; } private void disassociate() { org.apache.activemq.TransactionContext v; v := @this: org.apache.activemq.TransactionContext; v. = null; v. = null; return; } public static javax.transaction.xa.XAException toXAException(javax.jms.JMSException) { java.lang.Throwable v, v, v; javax.jms.JMSException v; int v, v, v, v, v; javax.transaction.xa.XAException v, v; java.lang.String v, v, v; boolean v; v := @parameter: javax.jms.JMSException; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = v instanceof javax.transaction.xa.XAException; if v == 0 goto label; v = virtualinvoke v.(); v = new javax.transaction.xa.XAException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = v.; v.