public class org.apache.activemq.store.kahadb.TempMessageDatabase extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
public static final int CLOSED_STATE;
public static final int OPEN_STATE;
protected org.apache.activemq.store.kahadb.disk.index.BTreeIndex destinations;
protected org.apache.activemq.store.kahadb.disk.page.PageFile pageFile;
protected java.io.File directory;
boolean enableIndexWriteAsync;
int setIndexWriteBatchSize;
protected java.util.concurrent.atomic.AtomicBoolean started;
protected java.util.concurrent.atomic.AtomicBoolean opened;
protected final java.lang.Object indexMutex;
private final java.util.HashSet journalFilesBeingReplicated;
private final java.util.HashMap storedDestinations;
protected final java.util.LinkedHashMap inflightTransactions;
protected final java.util.LinkedHashMap preparedTransactions;
public void <init>()
{
java.util.concurrent.atomic.AtomicBoolean v, v;
java.util.HashMap v;
java.util.HashSet v;
java.util.LinkedHashMap v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
int v;
java.lang.Object v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: boolean enableIndexWriteAsync> = 1;
v = <org.apache.activemq.store.kahadb.disk.page.PageFile: int DEFAULT_WRITE_BATCH_SIZE>;
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: int setIndexWriteBatchSize> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.concurrent.atomic.AtomicBoolean started> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.concurrent.atomic.AtomicBoolean opened> = v;
v = new java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.HashSet journalFilesBeingReplicated> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.HashMap storedDestinations> = v;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.LinkedHashMap inflightTransactions> = v;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.LinkedHashMap preparedTransactions> = v;
return;
}
public void start() throws java.lang.Exception
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.util.concurrent.atomic.AtomicBoolean v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.concurrent.atomic.AtomicBoolean started>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void load()>();
label:
return;
}
public void stop() throws java.lang.Exception
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.util.concurrent.atomic.AtomicBoolean v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.concurrent.atomic.AtomicBoolean started>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(1, 0);
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void unload()>();
label:
return;
}
private void loadPageFile() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
org.apache.activemq.store.kahadb.TempMessageDatabase$1 v;
java.lang.Object v;
java.util.HashMap v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile getPageFile()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void load()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = new org.apache.activemq.store.kahadb.TempMessageDatabase$1;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$1: void <init>(org.apache.activemq.store.kahadb.TempMessageDatabase,org.apache.activemq.store.kahadb.disk.page.PageFile)>(v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void flush()>();
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.HashMap storedDestinations>;
virtualinvoke v.<java.util.HashMap: void clear()>();
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 open() throws java.io.IOException
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.util.concurrent.atomic.AtomicBoolean v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.concurrent.atomic.AtomicBoolean opened>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void loadPageFile()>();
label:
return;
}
public void load() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Object v;
org.apache.activemq.store.kahadb.disk.page.PageFile v, v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void open()>();
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void unload()>();
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void delete()>();
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void loadPageFile()>();
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 close() throws java.io.IOException, java.lang.InterruptedException
{
java.lang.Throwable v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.Object v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.concurrent.atomic.AtomicBoolean opened>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(1, 0);
if v == 0 goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void unload()>();
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 unload() throws java.io.IOException, java.lang.InterruptedException
{
java.lang.Throwable v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Object v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: boolean isLoaded()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void close()>();
label:
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 processAdd(org.apache.activemq.store.kahadb.data.KahaAddMessageCommand, org.apache.activemq.command.TransactionId, org.apache.activemq.util.ByteSequence) throws java.io.IOException
{
java.lang.Throwable v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation v;
java.util.ArrayList v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
org.apache.activemq.store.kahadb.TempMessageDatabase$2 v;
java.lang.Object v, v;
org.apache.activemq.command.TransactionId v;
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaAddMessageCommand;
v := @parameter: org.apache.activemq.command.TransactionId;
v := @parameter: org.apache.activemq.util.ByteSequence;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.ArrayList getInflightTx(org.apache.activemq.command.TransactionId)>(v);
v = new org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation: void <init>(org.apache.activemq.store.kahadb.TempMessageDatabase,org.apache.activemq.store.kahadb.data.KahaAddMessageCommand,org.apache.activemq.util.ByteSequence)>(v, v, v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = new org.apache.activemq.store.kahadb.TempMessageDatabase$2;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$2: void <init>(org.apache.activemq.store.kahadb.TempMessageDatabase,org.apache.activemq.store.kahadb.data.KahaAddMessageCommand,org.apache.activemq.util.ByteSequence)>(v, v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(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;
catch java.lang.Throwable from label to label with label;
}
public void processRemove(org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand, org.apache.activemq.command.TransactionId) throws java.io.IOException
{
java.lang.Throwable v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase$RemoveOpperation v;
java.util.ArrayList v;
org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
org.apache.activemq.store.kahadb.TempMessageDatabase$3 v;
java.lang.Object v, v;
org.apache.activemq.command.TransactionId v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand;
v := @parameter: org.apache.activemq.command.TransactionId;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.ArrayList getInflightTx(org.apache.activemq.command.TransactionId)>(v);
v = new org.apache.activemq.store.kahadb.TempMessageDatabase$RemoveOpperation;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$RemoveOpperation: void <init>(org.apache.activemq.store.kahadb.TempMessageDatabase,org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand)>(v, v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = new org.apache.activemq.store.kahadb.TempMessageDatabase$3;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$3: void <init>(org.apache.activemq.store.kahadb.TempMessageDatabase,org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand)>(v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(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;
catch java.lang.Throwable from label to label with label;
}
public void process(org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Object v;
org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
org.apache.activemq.store.kahadb.TempMessageDatabase$4 v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = new org.apache.activemq.store.kahadb.TempMessageDatabase$4;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$4: void <init>(org.apache.activemq.store.kahadb.TempMessageDatabase,org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand)>(v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(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 process(org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand v;
java.lang.Object v;
org.apache.activemq.store.kahadb.TempMessageDatabase$5 v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = new org.apache.activemq.store.kahadb.TempMessageDatabase$5;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$5: void <init>(org.apache.activemq.store.kahadb.TempMessageDatabase,org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand)>(v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(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 processCommit(org.apache.activemq.command.TransactionId) throws java.io.IOException
{
java.lang.Throwable v;
java.util.LinkedHashMap v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Object v, v;
org.apache.activemq.command.TransactionId v;
org.apache.activemq.store.kahadb.TempMessageDatabase$6 v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.command.TransactionId;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.LinkedHashMap inflightTransactions>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object remove(java.lang.Object)>(v);
if v != null goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.LinkedHashMap preparedTransactions>;
virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object remove(java.lang.Object)>(v);
if v != null goto label;
exitmonitor v;
label:
return;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = new org.apache.activemq.store.kahadb.TempMessageDatabase$6;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$6: void <init>(org.apache.activemq.store.kahadb.TempMessageDatabase,java.util.ArrayList)>(v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(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;
catch java.lang.Throwable from label to label with label;
}
public void processPrepare(org.apache.activemq.command.TransactionId)
{
java.lang.Throwable v;
java.util.LinkedHashMap v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Object v, v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.command.TransactionId;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.LinkedHashMap inflightTransactions>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.LinkedHashMap preparedTransactions>;
virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
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 processRollback(org.apache.activemq.command.TransactionId)
{
java.lang.Throwable v;
java.util.LinkedHashMap v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Object v, v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.command.TransactionId;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.Object indexMutex>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.LinkedHashMap inflightTransactions>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object remove(java.lang.Object)>(v);
if v != null goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.LinkedHashMap preparedTransactions>;
virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object remove(java.lang.Object)>(v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void upadateIndex(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaAddMessageCommand, org.apache.activemq.util.ByteSequence) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v;
long v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Long v, v;
java.lang.String v, v, v;
org.apache.activemq.util.ByteSequence v;
boolean v;
org.apache.activemq.store.kahadb.data.KahaDestination v;
org.apache.activemq.store.kahadb.TempMessageDatabase$MessageRecord v;
java.util.TreeMap v;
java.lang.Object v;
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaAddMessageCommand;
v := @parameter: org.apache.activemq.util.ByteSequence;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaAddMessageCommand: org.apache.activemq.store.kahadb.data.KahaDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: 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 subscriptions>;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: java.util.TreeMap ackPositions>;
v = virtualinvoke v.<java.util.TreeMap: boolean isEmpty()>();
if v == 0 goto label;
return;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: long nextMessageId>;
v = v + 1L;
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: long nextMessageId> = v;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaAddMessageCommand: java.lang.String getMessageId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object put(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object,java.lang.Object)>(v, v, v);
if v != null goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex orderIndex>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = new org.apache.activemq.store.kahadb.TempMessageDatabase$MessageRecord;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaAddMessageCommand: java.lang.String getMessageId()>();
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$MessageRecord: void <init>(java.lang.String,org.apache.activemq.util.ByteSequence)>(v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object put(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object,java.lang.Object)>(v, v, v);
goto label;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaAddMessageCommand: java.lang.String getMessageId()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object put(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object,java.lang.Object)>(v, v, v);
label:
return;
}
private void updateIndex(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination v;
org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.String v, v, v;
boolean v;
org.apache.activemq.store.kahadb.data.KahaDestination v;
java.lang.Object v, v, v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand: org.apache.activemq.store.kahadb.data.KahaDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: 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 = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand: boolean hasSubscriptionKey()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand: java.lang.String getMessageId()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object remove(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object)>(v, v);
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex orderIndex>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object remove(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand: java.lang.String getMessageId()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object get(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object)>(v, v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand: java.lang.String getSubscriptionKey()>();
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object put(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object,java.lang.Object)>(v, v, v);
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void removeAckByteSequence(org.apache.activemq.store.kahadb.disk.page.Transaction,org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination,java.lang.String,java.lang.Long)>(v, v, v, v);
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void addAckByteSequence(org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination,java.lang.Long,java.lang.String)>(v, v, v);
label:
return;
}
private void updateIndex(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.HashMap v;
long v, v, v, v;
org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand v;
org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.String v;
org.apache.activemq.store.kahadb.data.KahaDestination v, v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand: org.apache.activemq.store.kahadb.data.KahaDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: 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>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void clear(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex orderIndex>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void unload(org.apache.activemq.store.kahadb.disk.page.Transaction)>(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: long getPageId()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void free(long)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void clear(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void unload(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: long getPageId()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void free(long)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptions>;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptions>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void clear(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptions>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void unload(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptions>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: long getPageId()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void free(long)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void clear(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void unload(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: long getPageId()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void free(long)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand: org.apache.activemq.store.kahadb.data.KahaDestination getDestination()>();
v = specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.String key(org.apache.activemq.store.kahadb.data.KahaDestination)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.HashMap storedDestinations>;
virtualinvoke v.<java.util.HashMap: java.lang.Object remove(java.lang.Object)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.index.BTreeIndex destinations>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object remove(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object)>(v, v);
return;
}
private void updateIndex(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v;
org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand v;
long v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Long v, v;
java.lang.String v, v;
boolean v, v;
org.apache.activemq.store.kahadb.data.KahaDestination v;
java.lang.Object v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand: org.apache.activemq.store.kahadb.data.KahaDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: 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 = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand: boolean hasSubscriptionInfo()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand: java.lang.String getSubscriptionKey()>();
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptions>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object put(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object,java.lang.Object)>(v, v, v);
v = -1L;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand: boolean getRetroactive()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: long nextMessageId>;
v = v - 1L;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object put(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object,java.lang.Object)>(v, v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void addAckByteSequence(org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination,java.lang.Long,java.lang.String)>(v, v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand: java.lang.String getSubscriptionKey()>();
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptions>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object remove(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object)>(v, v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object remove(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object)>(v, v);
if v == null goto label;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void removeAckByteSequence(org.apache.activemq.store.kahadb.disk.page.Transaction,org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination,java.lang.String,java.lang.Long)>(v, v, v, v);
label:
return;
}
public java.util.HashSet getJournalFilesBeingReplicated()
{
java.util.HashSet v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.HashSet journalFilesBeingReplicated>;
return v;
}
protected org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination getStoredDestination(org.apache.activemq.store.kahadb.data.KahaDestination, org.apache.activemq.store.kahadb.disk.page.Transaction) throws java.io.IOException
{
org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType v, v, v, v;
org.apache.activemq.store.kahadb.data.KahaDestination v;
java.util.HashMap v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Object v;
java.lang.String v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v = specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.lang.String key(org.apache.activemq.store.kahadb.data.KahaDestination)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.HashMap storedDestinations>;
v = virtualinvoke v.<java.util.HashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType getType()>();
v = <org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType TOPIC>;
if v == v goto label;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType getType()>();
v = <org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType TEMP_TOPIC>;
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination loadStoredDestination(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.String,boolean)>(v, v, v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.HashMap storedDestinations>;
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return v;
}
private org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination loadStoredDestination(org.apache.activemq.store.kahadb.disk.page.Transaction, java.lang.String, boolean) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.store.kahadb.disk.page.PageFile v, v, v, v;
boolean v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase$KahaSubscriptionCommandMarshaller v;
java.util.HashMap v;
long v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.String v;
java.util.Map$Entry v;
java.util.Iterator v;
org.apache.activemq.store.kahadb.TempMessageDatabase$MessageKeysMarshaller v;
org.apache.activemq.store.kahadb.disk.page.Page v, v, v, v;
org.apache.activemq.store.kahadb.disk.util.StringMarshaller v, v, v;
java.util.TreeMap v;
java.lang.Object v, v, v, v, v;
org.apache.activemq.store.kahadb.disk.util.LongMarshaller v, v, v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.index.BTreeIndex destinations>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object get(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object)>(v, v);
if v != null goto label;
v = new org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: void <init>()>();
v = v;
v = new org.apache.activemq.store.kahadb.disk.index.BTreeIndex;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: org.apache.activemq.store.kahadb.disk.page.Page allocate()>();
specialinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void <init>(org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v);
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex orderIndex> = v;
v = new org.apache.activemq.store.kahadb.disk.index.BTreeIndex;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: org.apache.activemq.store.kahadb.disk.page.Page allocate()>();
specialinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void <init>(org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v);
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex> = v;
if v == 0 goto label;
v = new org.apache.activemq.store.kahadb.disk.index.BTreeIndex;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: org.apache.activemq.store.kahadb.disk.page.Page allocate()>();
specialinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void <init>(org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v);
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptions> = v;
v = new org.apache.activemq.store.kahadb.disk.index.BTreeIndex;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: org.apache.activemq.store.kahadb.disk.page.Page allocate()>();
specialinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void <init>(org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v);
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks> = v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.index.BTreeIndex destinations>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object put(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object,java.lang.Object)>(v, v, v);
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex orderIndex>;
v = <org.apache.activemq.store.kahadb.disk.util.LongMarshaller: org.apache.activemq.store.kahadb.disk.util.LongMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setKeyMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex orderIndex>;
v = <org.apache.activemq.store.kahadb.TempMessageDatabase$MessageKeysMarshaller: org.apache.activemq.store.kahadb.TempMessageDatabase$MessageKeysMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setValueMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex orderIndex>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void load(org.apache.activemq.store.kahadb.disk.page.Transaction)>(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.Map$Entry getLast(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
if v == null goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v + 1L;
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: long nextMessageId> = v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
v = <org.apache.activemq.store.kahadb.disk.util.StringMarshaller: org.apache.activemq.store.kahadb.disk.util.StringMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setKeyMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
v = <org.apache.activemq.store.kahadb.disk.util.LongMarshaller: org.apache.activemq.store.kahadb.disk.util.LongMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setValueMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void load(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
if v == 0 goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptions>;
v = <org.apache.activemq.store.kahadb.disk.util.StringMarshaller: org.apache.activemq.store.kahadb.disk.util.StringMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setKeyMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptions>;
v = <org.apache.activemq.store.kahadb.TempMessageDatabase$KahaSubscriptionCommandMarshaller: org.apache.activemq.store.kahadb.TempMessageDatabase$KahaSubscriptionCommandMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setValueMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptions>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void load(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks>;
v = <org.apache.activemq.store.kahadb.disk.util.StringMarshaller: org.apache.activemq.store.kahadb.disk.util.StringMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setKeyMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks>;
v = <org.apache.activemq.store.kahadb.disk.util.LongMarshaller: org.apache.activemq.store.kahadb.disk.util.LongMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setValueMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void load(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: java.util.TreeMap ackPositions> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: java.util.HashMap subscriptionCursors> = v;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex subscriptionAcks>;
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 = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void addAckByteSequence(org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination,java.lang.Long,java.lang.String)>(v, v, v);
goto label;
label:
return v;
}
private void addAckByteSequence(org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination, java.lang.Long, java.lang.String)
{
org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination v;
java.util.HashSet v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.util.TreeMap v, v;
java.lang.Long v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination;
v := @parameter: java.lang.Long;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: java.util.TreeMap ackPositions>;
v = virtualinvoke v.<java.util.TreeMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: java.util.TreeMap ackPositions>;
virtualinvoke v.<java.util.TreeMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
virtualinvoke v.<java.util.HashSet: boolean add(java.lang.Object)>(v);
return;
}
private void removeAckByteSequence(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination, java.lang.String, java.lang.Long) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination v;
java.util.ArrayList v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Long v;
int v;
java.lang.String v, v;
boolean v, v, v;
java.util.Iterator v, v, v;
java.util.Collection v;
java.util.TreeMap v, v, v;
java.lang.Object v, v, v, v, v, v, v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v := @parameter: org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Long;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: java.util.TreeMap ackPositions>;
v = virtualinvoke v.<java.util.TreeMap: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
virtualinvoke v.<java.util.HashSet: boolean remove(java.lang.Object)>(v);
v = virtualinvoke v.<java.util.HashSet: boolean isEmpty()>();
if v == 0 goto label;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: java.util.TreeMap ackPositions>;
v = virtualinvoke v.<java.util.TreeMap: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: java.util.TreeMap ackPositions>;
virtualinvoke v.<java.util.TreeMap: java.lang.Object remove(java.lang.Object)>(v);
if v != v goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
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 = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Long: int compareTo(java.lang.Long)>(v);
if v > 0 goto label;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<java.util.ArrayList: java.util.Iterator iterator()>();
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.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex messageIdIndex>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$MessageRecord: java.lang.String messageId>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object remove(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object)>(v, v);
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$StoredDestination: org.apache.activemq.store.kahadb.disk.index.BTreeIndex orderIndex>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.lang.Object remove(org.apache.activemq.store.kahadb.disk.page.Transaction,java.lang.Object)>(v, v);
goto label;
label:
return;
}
private java.lang.String key(org.apache.activemq.store.kahadb.data.KahaDestination)
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType v;
org.apache.activemq.store.kahadb.data.KahaDestination v;
int v;
java.lang.String v, v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType getType()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType: int getNumber()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,java.lang.String)>(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[])>("\u0001:\u0001");
return v;
}
private java.util.ArrayList getInflightTx(org.apache.activemq.command.TransactionId)
{
java.util.LinkedHashMap v, v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.lang.Object v;
org.apache.activemq.command.TransactionId v;
java.util.ArrayList v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.command.TransactionId;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.LinkedHashMap inflightTransactions>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.util.LinkedHashMap inflightTransactions>;
virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return v;
}
private org.apache.activemq.store.kahadb.disk.page.PageFile createPageFile()
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
int v;
java.io.File v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = new org.apache.activemq.store.kahadb.disk.page.PageFile;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.io.File directory>;
specialinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void <init>(java.io.File,java.lang.String)>(v, "temp-db");
v = virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: boolean isEnableIndexWriteAsync()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void setEnableWriteThread(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: int getIndexWriteBatchSize()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void setWriteBatchSize(int)>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void setEnableDiskSyncs(boolean)>(0);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void setEnableRecoveryFile(boolean)>(0);
return v;
}
public java.io.File getDirectory()
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.io.File directory>;
return v;
}
public void setDirectory(java.io.File)
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: java.io.File;
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: java.io.File directory> = v;
return;
}
public void setIndexWriteBatchSize(int)
{
int v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: int;
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: int setIndexWriteBatchSize> = v;
return;
}
public int getIndexWriteBatchSize()
{
int v;
org.apache.activemq.store.kahadb.TempMessageDatabase v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: int setIndexWriteBatchSize>;
return v;
}
public void setEnableIndexWriteAsync(boolean)
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: boolean;
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: boolean enableIndexWriteAsync> = v;
return;
}
boolean isEnableIndexWriteAsync()
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: boolean enableIndexWriteAsync>;
return v;
}
public org.apache.activemq.store.kahadb.disk.page.PageFile getPageFile()
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
org.apache.activemq.store.kahadb.disk.page.PageFile v, v, v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
if v != null goto label;
v = specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile createPageFile()>();
v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile> = v;
label:
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
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/store/kahadb/TempMessageDatabase;");
<org.apache.activemq.store.kahadb.TempMessageDatabase: org.slf4j.Logger LOG> = v;
return;
}
}