class org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1 extends java.lang.Object implements org.apache.geronimo.transaction.manager.NamedXAResourceFactory
{
final org.apache.activemq.jms.pool.GenericResourceManager val$rm;
final javax.jms.XAConnectionFactory val$connFactory;
void <init>(org.apache.activemq.jms.pool.GenericResourceManager, javax.jms.XAConnectionFactory)
{
org.apache.activemq.jms.pool.GenericResourceManager v;
org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1 v;
javax.jms.XAConnectionFactory v;
v := @this: org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1;
v := @parameter: org.apache.activemq.jms.pool.GenericResourceManager;
v := @parameter: javax.jms.XAConnectionFactory;
v.<org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1: org.apache.activemq.jms.pool.GenericResourceManager val$rm> = v;
v.<org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1: javax.jms.XAConnectionFactory val$connFactory> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public java.lang.String getName()
{
org.apache.activemq.jms.pool.GenericResourceManager v;
org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1 v;
java.lang.String v;
v := @this: org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1;
v = v.<org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1: org.apache.activemq.jms.pool.GenericResourceManager val$rm>;
v = virtualinvoke v.<org.apache.activemq.jms.pool.GenericResourceManager: java.lang.String getResourceName()>();
return v;
}
public org.apache.geronimo.transaction.manager.NamedXAResource getNamedXAResource() throws javax.transaction.SystemException
{
org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1 v;
javax.jms.XAConnection v;
javax.jms.XASession v;
javax.transaction.xa.XAResource v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.activemq.jms.pool.GenericResourceManager v, v, v, v;
org.slf4j.Logger v, v;
javax.jms.XAConnectionFactory v, v;
java.lang.Exception v;
javax.transaction.SystemException v;
org.apache.activemq.jms.pool.GenericResourceManager$ConnectionAndWrapperNamedXAResource v;
v := @this: org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1;
label:
v = v.<org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1: org.apache.activemq.jms.pool.GenericResourceManager val$rm>;
v = virtualinvoke v.<org.apache.activemq.jms.pool.GenericResourceManager: java.lang.String getUserName()>();
if v == null goto label;
v = v.<org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1: org.apache.activemq.jms.pool.GenericResourceManager val$rm>;
v = virtualinvoke v.<org.apache.activemq.jms.pool.GenericResourceManager: java.lang.String getPassword()>();
if v == null goto label;
v = v.<org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1: javax.jms.XAConnectionFactory val$connFactory>;
v = v.<org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1: org.apache.activemq.jms.pool.GenericResourceManager val$rm>;
v = virtualinvoke v.<org.apache.activemq.jms.pool.GenericResourceManager: java.lang.String getUserName()>();
v = v.<org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1: org.apache.activemq.jms.pool.GenericResourceManager val$rm>;
v = virtualinvoke v.<org.apache.activemq.jms.pool.GenericResourceManager: java.lang.String getPassword()>();
v = interfaceinvoke v.<javax.jms.XAConnectionFactory: javax.jms.XAConnection createXAConnection(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v = v.<org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1: javax.jms.XAConnectionFactory val$connFactory>;
v = interfaceinvoke v.<javax.jms.XAConnectionFactory: javax.jms.XAConnection createXAConnection()>();
label:
v = interfaceinvoke v.<javax.jms.XAConnection: javax.jms.XASession createXASession()>();
interfaceinvoke v.<javax.jms.XAConnection: void start()>();
v = <org.apache.activemq.jms.pool.GenericResourceManager: org.slf4j.Logger LOGGER>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (javax.jms.XAConnection)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("new namedXAResource\'s connection: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = new org.apache.activemq.jms.pool.GenericResourceManager$ConnectionAndWrapperNamedXAResource;
v = interfaceinvoke v.<javax.jms.XASession: javax.transaction.xa.XAResource getXAResource()>();
v = virtualinvoke v.<org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1: java.lang.String getName()>();
specialinvoke v.<org.apache.activemq.jms.pool.GenericResourceManager$ConnectionAndWrapperNamedXAResource: void <init>(javax.transaction.xa.XAResource,java.lang.String,javax.jms.Connection)>(v, v, v);
label:
return v;
label:
v := @caughtexception;
v = new javax.transaction.SystemException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getLocalizedMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to create ConnectionAndWrapperNamedXAResource, \u0001");
specialinvoke v.<javax.transaction.SystemException: void <init>(java.lang.String)>(v);
virtualinvoke v.<javax.transaction.SystemException: java.lang.Throwable initCause(java.lang.Throwable)>(v);
v = <org.apache.activemq.jms.pool.GenericResourceManager: org.slf4j.Logger LOGGER>;
v = virtualinvoke v.<javax.transaction.SystemException: java.lang.String getLocalizedMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.Exception from label to label with label;
}
public void returnNamedXAResource(org.apache.geronimo.transaction.manager.NamedXAResource)
{
javax.jms.Connection v, v;
org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1 v;
org.slf4j.Logger v, v;
org.apache.geronimo.transaction.manager.NamedXAResource v;
java.lang.Exception v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.activemq.jms.pool.GenericResourceManager$Recovery$1;
v := @parameter: org.apache.geronimo.transaction.manager.NamedXAResource;
v = v instanceof org.apache.activemq.jms.pool.GenericResourceManager$ConnectionAndWrapperNamedXAResource;
if v == 0 goto label;
label:
v = <org.apache.activemq.jms.pool.GenericResourceManager: org.slf4j.Logger LOGGER>;
v = v.<org.apache.activemq.jms.pool.GenericResourceManager$ConnectionAndWrapperNamedXAResource: javax.jms.Connection connection>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (javax.jms.Connection)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("closing returned namedXAResource\'s connection: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = v.<org.apache.activemq.jms.pool.GenericResourceManager$ConnectionAndWrapperNamedXAResource: javax.jms.Connection connection>;
interfaceinvoke v.<javax.jms.Connection: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.jms.pool.GenericResourceManager: org.slf4j.Logger LOGGER>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.geronimo.transaction.manager.NamedXAResource)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("failed to close returned namedXAResource: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>(v, v);
label:
return;
catch java.lang.Exception from label to label with label;
}
}