class org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource extends java.lang.Object implements javax.transaction.xa.XAResource
{
protected org.apache.activemq.TransactionContext delegate;
final org.apache.activemq.ra.ActiveMQResourceAdapter this$0;
void <init>(org.apache.activemq.ra.ActiveMQResourceAdapter, org.apache.activemq.TransactionContext)
{
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
org.apache.activemq.TransactionContext v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v := @parameter: org.apache.activemq.ra.ActiveMQResourceAdapter;
v := @parameter: org.apache.activemq.TransactionContext;
v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate> = v;
return;
}
public void commit(javax.transaction.xa.Xid, boolean) throws javax.transaction.xa.XAException
{
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
javax.transaction.xa.Xid v;
boolean v;
org.apache.activemq.TransactionContext v, v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v := @parameter: javax.transaction.xa.Xid;
v := @parameter: boolean;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
specialinvoke v.<org.apache.activemq.ra.ActiveMQResourceAdapter: void ensureConnection(org.apache.activemq.TransactionContext)>(v);
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
virtualinvoke v.<org.apache.activemq.TransactionContext: void commit(javax.transaction.xa.Xid,boolean)>(v, v);
return;
}
public void end(javax.transaction.xa.Xid, int) throws javax.transaction.xa.XAException
{
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
int v;
javax.transaction.xa.Xid v;
org.apache.activemq.TransactionContext v, v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v := @parameter: javax.transaction.xa.Xid;
v := @parameter: int;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
specialinvoke v.<org.apache.activemq.ra.ActiveMQResourceAdapter: void ensureConnection(org.apache.activemq.TransactionContext)>(v);
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
virtualinvoke v.<org.apache.activemq.TransactionContext: void end(javax.transaction.xa.Xid,int)>(v, v);
return;
}
public void forget(javax.transaction.xa.Xid) throws javax.transaction.xa.XAException
{
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
javax.transaction.xa.Xid v;
org.apache.activemq.TransactionContext v, v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v := @parameter: javax.transaction.xa.Xid;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
specialinvoke v.<org.apache.activemq.ra.ActiveMQResourceAdapter: void ensureConnection(org.apache.activemq.TransactionContext)>(v);
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
virtualinvoke v.<org.apache.activemq.TransactionContext: void forget(javax.transaction.xa.Xid)>(v);
return;
}
public int getTransactionTimeout() throws javax.transaction.xa.XAException
{
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
int v;
org.apache.activemq.TransactionContext v, v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
specialinvoke v.<org.apache.activemq.ra.ActiveMQResourceAdapter: void ensureConnection(org.apache.activemq.TransactionContext)>(v);
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
v = virtualinvoke v.<org.apache.activemq.TransactionContext: int getTransactionTimeout()>();
return v;
}
public boolean isSameRM(javax.transaction.xa.XAResource) throws javax.transaction.xa.XAException
{
javax.transaction.xa.XAResource v;
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
boolean v, v;
org.apache.activemq.TransactionContext v, v, v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v := @parameter: javax.transaction.xa.XAResource;
if v != v goto label;
return 1;
label:
v = v instanceof org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
specialinvoke v.<org.apache.activemq.ra.ActiveMQResourceAdapter: void ensureConnection(org.apache.activemq.TransactionContext)>(v);
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
v = virtualinvoke v.<org.apache.activemq.TransactionContext: boolean isSameRM(javax.transaction.xa.XAResource)>(v);
return v;
}
public int prepare(javax.transaction.xa.Xid) throws javax.transaction.xa.XAException
{
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
int v;
javax.transaction.xa.Xid v;
org.apache.activemq.TransactionContext v, v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v := @parameter: javax.transaction.xa.Xid;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
specialinvoke v.<org.apache.activemq.ra.ActiveMQResourceAdapter: void ensureConnection(org.apache.activemq.TransactionContext)>(v);
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
v = virtualinvoke v.<org.apache.activemq.TransactionContext: int prepare(javax.transaction.xa.Xid)>(v);
return v;
}
public javax.transaction.xa.Xid[] recover(int) throws javax.transaction.xa.XAException
{
javax.transaction.xa.Xid[] v;
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
int v;
org.apache.activemq.TransactionContext v, v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v := @parameter: int;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
specialinvoke v.<org.apache.activemq.ra.ActiveMQResourceAdapter: void ensureConnection(org.apache.activemq.TransactionContext)>(v);
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
v = virtualinvoke v.<org.apache.activemq.TransactionContext: javax.transaction.xa.Xid[] recover(int)>(v);
return v;
}
public void rollback(javax.transaction.xa.Xid) throws javax.transaction.xa.XAException
{
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
javax.transaction.xa.Xid v;
org.apache.activemq.TransactionContext v, v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v := @parameter: javax.transaction.xa.Xid;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
specialinvoke v.<org.apache.activemq.ra.ActiveMQResourceAdapter: void ensureConnection(org.apache.activemq.TransactionContext)>(v);
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
virtualinvoke v.<org.apache.activemq.TransactionContext: void rollback(javax.transaction.xa.Xid)>(v);
return;
}
public boolean setTransactionTimeout(int) throws javax.transaction.xa.XAException
{
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
int v;
boolean v;
org.apache.activemq.TransactionContext v, v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v := @parameter: int;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
specialinvoke v.<org.apache.activemq.ra.ActiveMQResourceAdapter: void ensureConnection(org.apache.activemq.TransactionContext)>(v);
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
v = virtualinvoke v.<org.apache.activemq.TransactionContext: boolean setTransactionTimeout(int)>(v);
return v;
}
public void start(javax.transaction.xa.Xid, int) throws javax.transaction.xa.XAException
{
org.apache.activemq.ra.ActiveMQResourceAdapter v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
int v;
javax.transaction.xa.Xid v;
org.apache.activemq.TransactionContext v, v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
v := @parameter: javax.transaction.xa.Xid;
v := @parameter: int;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.ra.ActiveMQResourceAdapter this$0>;
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
specialinvoke v.<org.apache.activemq.ra.ActiveMQResourceAdapter: void ensureConnection(org.apache.activemq.TransactionContext)>(v);
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
virtualinvoke v.<org.apache.activemq.TransactionContext: void start(javax.transaction.xa.Xid,int)>(v, v);
return;
}
public void stop()
{
java.lang.Throwable v;
org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource v;
org.apache.activemq.ActiveMQConnection v;
org.apache.activemq.TransactionContext v;
v := @this: org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource;
label:
v = v.<org.apache.activemq.ra.ActiveMQResourceAdapter$ReconnectingXAResource: org.apache.activemq.TransactionContext delegate>;
v = virtualinvoke v.<org.apache.activemq.TransactionContext: org.apache.activemq.ActiveMQConnection getConnection()>();
virtualinvoke v.<org.apache.activemq.ActiveMQConnection: void close()>();
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch java.lang.Throwable from label to label with label;
}
}