public class org.apache.activemq.util.TransactionTemplate extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
private org.apache.activemq.store.PersistenceAdapter persistenceAdapter;
private org.apache.activemq.broker.ConnectionContext context;
public void <init>(org.apache.activemq.store.PersistenceAdapter, org.apache.activemq.broker.ConnectionContext)
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.PersistenceAdapter v;
org.apache.activemq.util.TransactionTemplate v;
v := @this: org.apache.activemq.util.TransactionTemplate;
v := @parameter: org.apache.activemq.store.PersistenceAdapter;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.util.TransactionTemplate: org.apache.activemq.store.PersistenceAdapter persistenceAdapter> = v;
v.<org.apache.activemq.util.TransactionTemplate: org.apache.activemq.broker.ConnectionContext context> = v;
return;
}
public void run(org.apache.activemq.util.Callback) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.util.Callback v;
org.apache.activemq.util.TransactionTemplate v;
java.io.IOException v, v;
java.lang.RuntimeException v;
org.apache.activemq.broker.ConnectionContext v, v;
java.lang.String v;
org.apache.activemq.store.PersistenceAdapter v, v;
v := @this: org.apache.activemq.util.TransactionTemplate;
v := @parameter: org.apache.activemq.util.Callback;
v = v.<org.apache.activemq.util.TransactionTemplate: org.apache.activemq.store.PersistenceAdapter persistenceAdapter>;
v = v.<org.apache.activemq.util.TransactionTemplate: org.apache.activemq.broker.ConnectionContext context>;
interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: void beginTransaction(org.apache.activemq.broker.ConnectionContext)>(v);
label:
interfaceinvoke v.<org.apache.activemq.util.Callback: void execute()>();
label:
v = v.<org.apache.activemq.util.TransactionTemplate: org.apache.activemq.store.PersistenceAdapter persistenceAdapter>;
v = v.<org.apache.activemq.util.TransactionTemplate: org.apache.activemq.broker.ConnectionContext context>;
interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: void commitTransaction(org.apache.activemq.broker.ConnectionContext)>(v);
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Throwable)>(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[])>("Persistence task failed: \u0001");
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.RuntimeException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.broker.ConnectionContext getContext()
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.util.TransactionTemplate v;
v := @this: org.apache.activemq.util.TransactionTemplate;
v = v.<org.apache.activemq.util.TransactionTemplate: org.apache.activemq.broker.ConnectionContext context>;
return v;
}
public org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()
{
org.apache.activemq.store.PersistenceAdapter v;
org.apache.activemq.util.TransactionTemplate v;
v := @this: org.apache.activemq.util.TransactionTemplate;
v = v.<org.apache.activemq.util.TransactionTemplate: org.apache.activemq.store.PersistenceAdapter persistenceAdapter>;
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/util/TransactionTemplate;");
<org.apache.activemq.util.TransactionTemplate: org.slf4j.Logger LOG> = v;
return;
}
}