class org.apache.activemq.store.journal.JournalMessageStore$1 extends org.apache.activemq.transaction.Synchronization
{
final boolean val$debug;
final org.apache.activemq.command.MessageId val$id;
final org.apache.activeio.journal.RecordLocation val$location;
final org.apache.activemq.broker.ConnectionContext val$context;
final org.apache.activemq.command.Message val$message;
final org.apache.activemq.store.journal.JournalMessageStore this$0;
void <init>(org.apache.activemq.store.journal.JournalMessageStore, boolean, org.apache.activemq.command.MessageId, org.apache.activeio.journal.RecordLocation, org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message)
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.journal.JournalMessageStore v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.store.journal.JournalMessageStore$1 v;
org.apache.activeio.journal.RecordLocation v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalMessageStore$1;
v := @parameter: org.apache.activemq.store.journal.JournalMessageStore;
v := @parameter: boolean;
v := @parameter: org.apache.activemq.command.MessageId;
v := @parameter: org.apache.activeio.journal.RecordLocation;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.store.journal.JournalMessageStore this$0> = v;
v.<org.apache.activemq.store.journal.JournalMessageStore$1: boolean val$debug> = v;
v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.command.MessageId val$id> = v;
v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activeio.journal.RecordLocation val$location> = v;
v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.broker.ConnectionContext val$context> = v;
v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.command.Message val$message> = v;
specialinvoke v.<org.apache.activemq.transaction.Synchronization: void <init>()>();
return;
}
public void afterCommit() throws java.lang.Exception
{
java.lang.Throwable v;
org.slf4j.Logger v;
org.apache.activemq.store.journal.JournalMessageStore v, v, v;
org.apache.activemq.command.MessageId v;
java.util.Set v;
org.apache.activemq.store.journal.JournalMessageStore$1 v;
org.apache.activeio.journal.RecordLocation v, v, v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
java.lang.String v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalMessageStore$1;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: boolean val$debug>;
if v == 0 goto label;
v = <org.apache.activemq.store.journal.JournalMessageStore: org.slf4j.Logger LOG>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.command.MessageId val$id>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activeio.journal.RecordLocation val$location>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.MessageId,org.apache.activeio.journal.RecordLocation)>(v, 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[])>("Transacted message add commit for: \u, at: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.store.journal.JournalMessageStore this$0>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.store.journal.JournalMessageStore this$0>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore: java.util.Set inFlightTxLocations>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activeio.journal.RecordLocation val$location>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.store.journal.JournalMessageStore this$0>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.broker.ConnectionContext val$context>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.command.Message val$message>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activeio.journal.RecordLocation val$location>;
virtualinvoke v.<org.apache.activemq.store.journal.JournalMessageStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,org.apache.activeio.journal.RecordLocation)>(v, v, v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void afterRollback() throws java.lang.Exception
{
java.lang.Throwable v;
org.slf4j.Logger v;
org.apache.activemq.store.journal.JournalMessageStore v, v;
org.apache.activemq.command.MessageId v;
java.util.Set v;
org.apache.activemq.store.journal.JournalMessageStore$1 v;
org.apache.activeio.journal.RecordLocation v, v;
org.apache.activemq.command.Message v;
java.lang.String v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalMessageStore$1;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: boolean val$debug>;
if v == 0 goto label;
v = <org.apache.activemq.store.journal.JournalMessageStore: org.slf4j.Logger LOG>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.command.MessageId val$id>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activeio.journal.RecordLocation val$location>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.MessageId,org.apache.activeio.journal.RecordLocation)>(v, 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[])>("Transacted message add rollback for: \u, at: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.store.journal.JournalMessageStore this$0>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.store.journal.JournalMessageStore this$0>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore: java.util.Set inFlightTxLocations>;
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activeio.journal.RecordLocation val$location>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<org.apache.activemq.store.journal.JournalMessageStore$1: org.apache.activemq.command.Message val$message>;
virtualinvoke v.<org.apache.activemq.command.Message: int decrementReferenceCount()>();
return;
catch java.lang.Throwable from label to label with label;
}
}