class org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2 extends java.lang.Object implements org.apache.activemq.store.kahadb.disk.page.Transaction$Closure
{
final org.apache.activemq.store.MessageRecoveryListener val$listener;
final org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore this$1;
void <init>(org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore, org.apache.activemq.store.MessageRecoveryListener)
{
org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2 v;
org.apache.activemq.store.MessageRecoveryListener v;
org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2;
v := @parameter: org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore;
v := @parameter: org.apache.activemq.store.MessageRecoveryListener;
v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2: org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore this$1> = v;
v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2: org.apache.activemq.store.MessageRecoveryListener val$listener> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void execute(org.apache.activemq.store.kahadb.disk.page.Transaction) throws java.lang.Exception
{
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v;
org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination v;
org.apache.activemq.util.ByteSequence v;
boolean v;
java.util.Iterator v;
org.apache.activemq.store.kahadb.data.KahaDestination v;
org.apache.activemq.store.kahadb.TempKahaDBStore v, v;
org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore v, v, v;
org.apache.activemq.wireformat.WireFormat v;
java.lang.Object v, v, v;
org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2 v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
org.apache.activemq.store.MessageRecoveryListener v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2: org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore this$1>;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore: org.apache.activemq.store.kahadb.TempKahaDBStore this$0>;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2: org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore this$1>;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore: org.apache.activemq.store.kahadb.data.KahaDestination dest>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination getStoredDestination(org.apache.activemq.store.kahadb.data.KahaDestination,org.apache.activemq.store.kahadb.disk.page.Transaction)>(v, v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex orderIndex>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.util.Iterator iterator(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2: org.apache.activemq.store.MessageRecoveryListener val$listener>;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore$2: org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore this$1>;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore: org.apache.activemq.store.kahadb.TempKahaDBStore this$0>;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.wireformat.WireFormat wireFormat>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$MessageRecord: org.apache.activemq.util.ByteSequence data>;
v = interfaceinvoke v.<org.apache.activemq.wireformat.WireFormat: java.lang.Object unmarshal(org.apache.activemq.util.ByteSequence)>(v);
interfaceinvoke v.<org.apache.activemq.store.MessageRecoveryListener: boolean recoverMessage(org.apache.activemq.command.Message)>(v);
goto label;
label:
return;
}
}