public class org.apache.activemq.leveldb.LevelDBStore extends org.apache.activemq.broker.LockableServiceSupport implements org.apache.activemq.store.PersistenceAdapter, org.apache.activemq.store.TransactionStore, org.apache.activemq.store.PListStore, org.apache.activemq.store.TransactionIdTransformerAware
{
private final org.apache.activemq.openwire.OpenWireFormat wireFormat;
private final org.apache.activemq.leveldb.DBManager db;
private org.apache.activemq.leveldb.LevelDBClient client;
private java.io.File directory;
private java.io.File logDirectory;
private long logSize;
private java.lang.String indexFactory;
private boolean sync;
private boolean verifyChecksums;
private int indexMaxOpenFiles;
private int indexBlockRestartInterval;
private boolean paranoidChecks;
private int indexWriteBufferSize;
private int indexBlockSize;
private java.lang.String indexCompression;
private java.lang.String logCompression;
private long indexCacheSize;
private int flushDelay;
private int asyncBufferSize;
private boolean monitorStats;
private int autoCompactionRatio;
private boolean purgeOnStatup;
private final scala.collection.mutable.HashMap queues;
private final scala.collection.mutable.HashMap topics;
private final scala.collection.mutable.HashMap topicsById;
private final scala.collection.mutable.HashMap plists;
private final java.lang.Object lock;
private boolean snappyCompressLogs;
private org.apache.activemq.store.TransactionIdTransformer transactionIdTransformer;
private final java.util.concurrent.ConcurrentHashMap transactions;
private boolean doingRecover;
private volatile org.apache.activemq.leveldb.LevelDBStore$Transaction$ Transaction$module;
private volatile org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ LevelDBMessageStore$module;
public static void trace(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void trace(java.lang.Throwable)>(v);
return;
}
public static void trace(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void trace(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void trace(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBStore$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void trace(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void debug(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void debug(java.lang.Throwable)>(v);
return;
}
public static void debug(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void debug(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void debug(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBStore$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void debug(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void info(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void info(java.lang.Throwable)>(v);
return;
}
public static void info(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void info(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void info(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBStore$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void info(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void warn(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void warn(java.lang.Throwable)>(v);
return;
}
public static void warn(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void warn(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void warn(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBStore$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void warn(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void error(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void error(java.lang.Throwable)>(v);
return;
}
public static void error(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void error(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void error(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBStore$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void error(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void org$apache$activemq$leveldb$util$Log$_setter_$log_$eq(org.slf4j.Logger)
{
org.apache.activemq.leveldb.LevelDBStore$ v;
org.slf4j.Logger v;
v := @parameter: org.slf4j.Logger;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void org$apache$activemq$leveldb$util$Log$_setter_$log_$eq(org.slf4j.Logger)>(v);
return;
}
public static org.slf4j.Logger log()
{
org.apache.activemq.leveldb.LevelDBStore$ v;
org.slf4j.Logger v;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: org.slf4j.Logger log()>();
return v;
}
public static void waitOn(java.util.concurrent.Future)
{
java.util.concurrent.Future v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.util.concurrent.Future;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void waitOn(java.util.concurrent.Future)>(v);
return;
}
public static java.io.IOException toIOException(java.lang.Throwable)
{
java.lang.Throwable v;
java.io.IOException v;
org.apache.activemq.leveldb.LevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: java.io.IOException toIOException(java.lang.Throwable)>(v);
return v;
}
public static org.apache.activemq.store.InlineListenableFuture DONE()
{
org.apache.activemq.leveldb.LevelDBStore$ v;
org.apache.activemq.store.InlineListenableFuture v;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.store.InlineListenableFuture DONE()>();
return v;
}
public static java.util.concurrent.ThreadPoolExecutor BLOCKING_EXECUTOR()
{
org.apache.activemq.leveldb.LevelDBStore$ v;
java.util.concurrent.ThreadPoolExecutor v;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: java.util.concurrent.ThreadPoolExecutor BLOCKING_EXECUTOR()>();
return v;
}
public static java.io.File DEFAULT_DIRECTORY()
{
org.apache.activemq.leveldb.LevelDBStore$ v;
java.io.File v;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: java.io.File DEFAULT_DIRECTORY()>();
return v;
}
private org.apache.activemq.leveldb.LevelDBStore$Transaction$ Transaction$lzycompute()
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$Transaction$ v, v, v;
scala.runtime.BoxedUnit v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
entermonitor v;
label:
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$Transaction$ Transaction$module>;
if v != null goto label;
v = new org.apache.activemq.leveldb.LevelDBStore$Transaction$;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$Transaction$: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$Transaction$ Transaction$module> = v;
label:
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
exitmonitor v;
label:
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$Transaction$ Transaction$module>;
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
private org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ LevelDBMessageStore$lzycompute()
{
java.lang.Throwable v;
scala.runtime.BoxedUnit v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
entermonitor v;
label:
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ LevelDBMessageStore$module>;
if v != null goto label;
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ LevelDBMessageStore$module> = v;
label:
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
exitmonitor v;
label:
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ LevelDBMessageStore$module>;
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public final org.apache.activemq.openwire.OpenWireFormat wireFormat()
{
org.apache.activemq.openwire.OpenWireFormat v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.openwire.OpenWireFormat wireFormat>;
return v;
}
public final org.apache.activemq.leveldb.DBManager db()
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db>;
return v;
}
public final org.apache.activemq.leveldb.LevelDBClient client()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBClient client>;
return v;
}
public final void client_$eq(org.apache.activemq.leveldb.LevelDBClient)
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.leveldb.LevelDBClient;
v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBClient client> = v;
return;
}
public java.io.File directory()
{
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File directory>;
return v;
}
public void directory_$eq(java.io.File)
{
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.io.File;
v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File directory> = v;
return;
}
public void setDirectory(java.io.File)
{
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.io.File;
v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File directory> = v;
return;
}
public java.io.File logDirectory()
{
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File logDirectory>;
return v;
}
public void logDirectory_$eq(java.io.File)
{
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.io.File;
v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File logDirectory> = v;
return;
}
public void setLogDirectory(java.io.File)
{
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.io.File;
v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File logDirectory> = v;
return;
}
public long logSize()
{
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: long logSize>;
return v;
}
public void logSize_$eq(long)
{
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBStore: long logSize> = v;
return;
}
public void setLogSize(long)
{
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBStore: long logSize> = v;
return;
}
public java.lang.String indexFactory()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexFactory>;
return v;
}
public void indexFactory_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexFactory> = v;
return;
}
public void setIndexFactory(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexFactory> = v;
return;
}
public boolean sync()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: boolean sync>;
return v;
}
public void sync_$eq(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean sync> = v;
return;
}
public void setSync(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean sync> = v;
return;
}
public boolean verifyChecksums()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: boolean verifyChecksums>;
return v;
}
public void verifyChecksums_$eq(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean verifyChecksums> = v;
return;
}
public void setVerifyChecksums(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean verifyChecksums> = v;
return;
}
public int indexMaxOpenFiles()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: int indexMaxOpenFiles>;
return v;
}
public void indexMaxOpenFiles_$eq(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexMaxOpenFiles> = v;
return;
}
public void setIndexMaxOpenFiles(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexMaxOpenFiles> = v;
return;
}
public int indexBlockRestartInterval()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockRestartInterval>;
return v;
}
public void indexBlockRestartInterval_$eq(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockRestartInterval> = v;
return;
}
public void setIndexBlockRestartInterval(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockRestartInterval> = v;
return;
}
public boolean paranoidChecks()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: boolean paranoidChecks>;
return v;
}
public void paranoidChecks_$eq(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean paranoidChecks> = v;
return;
}
public void setParanoidChecks(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean paranoidChecks> = v;
return;
}
public int indexWriteBufferSize()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: int indexWriteBufferSize>;
return v;
}
public void indexWriteBufferSize_$eq(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexWriteBufferSize> = v;
return;
}
public void setIndexWriteBufferSize(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexWriteBufferSize> = v;
return;
}
public int indexBlockSize()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockSize>;
return v;
}
public void indexBlockSize_$eq(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockSize> = v;
return;
}
public void setIndexBlockSize(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockSize> = v;
return;
}
public java.lang.String indexCompression()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexCompression>;
return v;
}
public void indexCompression_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexCompression> = v;
return;
}
public void setIndexCompression(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexCompression> = v;
return;
}
public java.lang.String logCompression()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String logCompression>;
return v;
}
public void logCompression_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String logCompression> = v;
return;
}
public void setLogCompression(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String logCompression> = v;
return;
}
public long indexCacheSize()
{
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: long indexCacheSize>;
return v;
}
public void indexCacheSize_$eq(long)
{
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBStore: long indexCacheSize> = v;
return;
}
public void setIndexCacheSize(long)
{
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBStore: long indexCacheSize> = v;
return;
}
public int flushDelay()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: int flushDelay>;
return v;
}
public void flushDelay_$eq(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int flushDelay> = v;
return;
}
public void setFlushDelay(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int flushDelay> = v;
return;
}
public int asyncBufferSize()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: int asyncBufferSize>;
return v;
}
public void asyncBufferSize_$eq(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int asyncBufferSize> = v;
return;
}
public void setAsyncBufferSize(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int asyncBufferSize> = v;
return;
}
public boolean monitorStats()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: boolean monitorStats>;
return v;
}
public void monitorStats_$eq(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean monitorStats> = v;
return;
}
public void setMonitorStats(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean monitorStats> = v;
return;
}
public int autoCompactionRatio()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: int autoCompactionRatio>;
return v;
}
public void autoCompactionRatio_$eq(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int autoCompactionRatio> = v;
return;
}
public void setAutoCompactionRatio(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStore: int autoCompactionRatio> = v;
return;
}
public boolean purgeOnStatup()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: boolean purgeOnStatup>;
return v;
}
public void purgeOnStatup_$eq(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean purgeOnStatup> = v;
return;
}
public scala.collection.mutable.HashMap queues()
{
org.apache.activemq.leveldb.LevelDBStore v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap queues>;
return v;
}
public scala.collection.mutable.HashMap topics()
{
org.apache.activemq.leveldb.LevelDBStore v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topics>;
return v;
}
public scala.collection.mutable.HashMap topicsById()
{
org.apache.activemq.leveldb.LevelDBStore v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topicsById>;
return v;
}
public scala.collection.mutable.HashMap plists()
{
org.apache.activemq.leveldb.LevelDBStore v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap plists>;
return v;
}
private java.lang.Object lock()
{
java.lang.Object v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock>;
return v;
}
public void check_running()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
org.apache.activemq.broker.SuppressReplyException v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean isStopped()>();
if v == 0 goto label;
v = new org.apache.activemq.broker.SuppressReplyException;
specialinvoke v.<org.apache.activemq.broker.SuppressReplyException: void <init>(java.lang.String)>("Store has been stopped");
throw v;
label:
return;
}
public void init()
{
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
return;
}
public org.apache.activemq.store.SharedFileLocker createDefaultLocker()
{
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.store.SharedFileLocker v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = new org.apache.activemq.store.SharedFileLocker;
specialinvoke v.<org.apache.activemq.store.SharedFileLocker: void <init>()>();
virtualinvoke v.<org.apache.activemq.store.SharedFileLocker: void configure(org.apache.activemq.store.PersistenceAdapter)>(v);
return v;
}
public java.lang.String toString()
{
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
scala.collection.mutable.StringBuilder v, v, v, v;
java.lang.String v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>("LevelDB[");
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File directory()>();
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>("]");
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
return v;
}
public javax.management.ObjectName objectName()
{
org.apache.activemq.broker.BrokerService v;
java.lang.String v, v;
javax.management.ObjectName v, v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String toString()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createPersistenceAdapterName(java.lang.String,java.lang.String)>(v, v);
return v;
}
public boolean snappyCompressLogs()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: boolean snappyCompressLogs>;
return v;
}
public void snappyCompressLogs_$eq(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean snappyCompressLogs> = v;
return;
}
public void doStart()
{
scala.collection.JavaConversions$ v;
scala.collection.mutable.ArrayOps v;
org.apache.activemq.leveldb.package$ v;
org.apache.activemq.broker.BrokerService v, v, v, v, v, v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.openwire.OpenWireFormat v;
scala.collection.generic.FilterMonadic v, v;
java.lang.Object[] v, v, v;
scala.reflect.ClassTag v;
scala.collection.mutable.StringBuilder v, v, v;
java.lang.String v, v, v, v;
scala.collection.mutable.WrappedArray v, v, v;
org.apache.activemq.leveldb.LevelDBStoreTest v;
org.apache.activemq.leveldb.LevelDBStoreView v;
scala.collection.concurrent.Map v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$7 v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$8 v;
org.apache.activemq.broker.jmx.ManagementContext v, v;
org.apache.activemq.leveldb.LevelDBClient v;
boolean v, v, v, v, v;
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.LevelDBStore$ v, v, v;
javax.management.ObjectName v, v, v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$1 v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$3 v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$4 v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$5 v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$6 v;
org.apache.activemq.leveldb.DBManager v, v, v;
scala.Predef$ v, v, v, v;
int v;
org.apache.activemq.leveldb.package$SnappyTrait v;
scala.collection.mutable.HashMap v;
scala.reflect.ClassTag$ v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.openwire.OpenWireFormat wireFormat()>();
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: int getStoreOpenWireVersion()>();
virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormat: void setVersion(int)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String logCompression()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>("snappy");
if v == 0 goto label;
v = <org.apache.activemq.leveldb.package$: org.apache.activemq.leveldb.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.package$: org.apache.activemq.leveldb.package$SnappyTrait Snappy()>();
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void snappyCompressLogs_$eq(boolean)>(v);
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$1: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void debug(scala.Function,scala.collection.Seq)>(v, v);
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
if v == null goto label;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = new org.apache.activemq.leveldb.LevelDBStoreView;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStoreView: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: javax.management.ObjectName objectName()>();
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
v = staticinvoke <java.lang.Boolean: boolean getBoolean(java.lang.String)>("org.apache.activemq.leveldb.test");
if v == 0 goto label;
v = new javax.management.ObjectName;
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: javax.management.ObjectName objectName()>();
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String toString()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(",view=Test");
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = new org.apache.activemq.leveldb.LevelDBStoreTest;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStoreTest: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean purgeOnStatup()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void purgeOnStatup_$eq(boolean)>(0);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void locked_purge()>();
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$3;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$3: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void info(scala.Function,scala.collection.Seq)>(v, v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void start()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void loadCollections()>();
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.util.concurrent.ConcurrentHashMap transactions()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.concurrent.Map mapAsScalaConcurrentMap(java.util.concurrent.ConcurrentMap)>(v);
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$4;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$4: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v = interfaceinvoke v.<scala.collection.concurrent.Map: scala.collection.generic.FilterMonadic withFilter(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$5;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$5: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
interfaceinvoke v.<scala.collection.generic.FilterMonadic: void foreach(scala.Function)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topics()>();
v = <scala.reflect.ClassTag$: scala.reflect.ClassTag$ MODULE$>;
v = virtualinvoke v.<scala.reflect.ClassTag$: scala.reflect.ClassTag apply(java.lang.Class)>(class "Lscala/Tuple;");
v = virtualinvoke v.<scala.collection.mutable.HashMap: java.lang.Object toArray(scala.reflect.ClassTag)>(v);
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$6;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$6: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v = interfaceinvoke v.<scala.collection.mutable.ArrayOps: scala.collection.generic.FilterMonadic withFilter(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$7;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$7: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
interfaceinvoke v.<scala.collection.generic.FilterMonadic: void foreach(scala.Function)>(v);
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$8;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStart$8: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void debug(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public void doStop(org.apache.activemq.util.ServiceStopper)
{
java.lang.Object[] v;
org.apache.activemq.util.ServiceStopper v;
scala.collection.mutable.StringBuilder v, v, v;
org.apache.activemq.broker.jmx.ManagementContext v, v;
scala.Predef$ v;
java.lang.String v, v;
boolean v, v;
scala.collection.mutable.WrappedArray v;
org.apache.activemq.broker.BrokerService v, v, v, v;
org.apache.activemq.leveldb.LevelDBStore$ v;
javax.management.ObjectName v, v, v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStop$1 v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.util.ServiceStopper;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void stop()>();
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
if v == null goto label;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: javax.management.ObjectName objectName()>();
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void unregisterMBean(javax.management.ObjectName)>(v);
v = staticinvoke <java.lang.Boolean: boolean getBoolean(java.lang.String)>("org.apache.activemq.leveldb.test");
if v == 0 goto label;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = new javax.management.ObjectName;
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: javax.management.ObjectName objectName()>();
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String toString()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(",view=Test");
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void unregisterMBean(javax.management.ObjectName)>(v);
label:
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStop$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$doStop$1: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void info(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public org.apache.activemq.broker.BrokerService broker_service()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
return v;
}
public java.util.concurrent.Executor blocking_executor()
{
org.apache.activemq.broker.BrokerService v, v;
java.util.concurrent.Executor v;
org.apache.activemq.leveldb.LevelDBStore$ v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService broker_service()>();
if v != null goto label;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: java.util.concurrent.ThreadPoolExecutor BLOCKING_EXECUTOR()>();
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService broker_service()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()>();
label:
return v;
}
public org.apache.activemq.store.TransactionIdTransformer transactionIdTransformer()
{
org.apache.activemq.store.TransactionIdTransformer v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.store.TransactionIdTransformer transactionIdTransformer>;
return v;
}
public void transactionIdTransformer_$eq(org.apache.activemq.store.TransactionIdTransformer)
{
org.apache.activemq.store.TransactionIdTransformer v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.store.TransactionIdTransformer;
v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.store.TransactionIdTransformer transactionIdTransformer> = v;
return;
}
public void setTransactionIdTransformer(org.apache.activemq.store.TransactionIdTransformer)
{
org.apache.activemq.store.TransactionIdTransformer v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.store.TransactionIdTransformer;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void transactionIdTransformer_$eq(org.apache.activemq.store.TransactionIdTransformer)>(v);
return;
}
public void setBrokerName(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
return;
}
public void setUsageManager(org.apache.activemq.usage.SystemUsage)
{
org.apache.activemq.usage.SystemUsage v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.usage.SystemUsage;
return;
}
public void deleteAllMessages()
{
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void purgeOnStatup_$eq(boolean)>(1);
return;
}
public long getLastMessageBrokerSequenceId()
{
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
return 0L;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBTransactionStore createTransactionStore()
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBTransactionStore v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBTransactionStore;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBTransactionStore: void <init>(org.apache.activemq.leveldb.LevelDBStore,org.apache.activemq.leveldb.LevelDBStore)>(v, v);
return v;
}
public java.util.concurrent.ConcurrentHashMap transactions()
{
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: java.util.concurrent.ConcurrentHashMap transactions>;
return v;
}
public org.apache.activemq.leveldb.LevelDBStore$Transaction$ Transaction()
{
org.apache.activemq.leveldb.LevelDBStore$Transaction$ v, v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$Transaction$ Transaction$module>;
if v != null goto label;
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$Transaction$ Transaction$lzycompute()>();
goto label;
label:
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$Transaction$ Transaction$module>;
label:
return v;
}
public org.apache.activemq.leveldb.LevelDBStore$Transaction transaction(org.apache.activemq.command.TransactionId)
{
java.util.concurrent.ConcurrentHashMap v, v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.store.TransactionIdTransformer v;
org.apache.activemq.leveldb.LevelDBStore$Transaction v;
java.lang.Object v, v;
org.apache.activemq.command.TransactionId v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.TransactionId;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.store.TransactionIdTransformer transactionIdTransformer()>();
v = interfaceinvoke v.<org.apache.activemq.store.TransactionIdTransformer: org.apache.activemq.command.TransactionId transform(org.apache.activemq.command.TransactionId)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.util.concurrent.ConcurrentHashMap transactions()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new org.apache.activemq.leveldb.LevelDBStore$Transaction;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$Transaction: void <init>(org.apache.activemq.leveldb.LevelDBStore,org.apache.activemq.command.TransactionId)>(v, v);
v = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.util.concurrent.ConcurrentHashMap transactions()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object putIfAbsent(java.lang.Object,java.lang.Object)>(v, v);
if v == null goto label;
v = v;
label:
return v;
}
public void verify_running()
{
org.apache.activemq.broker.BrokerService v, v;
java.io.IOException v, v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.broker.SuppressReplyException v;
boolean v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean isStopping()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean isStopped()>();
if v == 0 goto label;
label:
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Not running");
throw v;
label:
return;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService broker_service()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService broker_service()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void handleIOException(java.io.IOException)>(v);
label:
v = new org.apache.activemq.broker.SuppressReplyException;
specialinvoke v.<org.apache.activemq.broker.SuppressReplyException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public void commit(org.apache.activemq.command.TransactionId, boolean, java.lang.Runnable, java.lang.Runnable)
{
java.lang.Throwable v;
long v;
java.lang.Runnable v, v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$commit$1 v;
org.apache.activemq.command.TransactionId v, v;
boolean v, v;
java.util.concurrent.ConcurrentHashMap v, v;
scala.runtime.BoxedUnit v, v;
org.apache.activemq.leveldb.LevelDBStore v;
java.util.concurrent.CountDownLatch v;
org.apache.activemq.store.TransactionIdTransformer v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.TransactionId;
v := @parameter: boolean;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.Runnable;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void verify_running()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.store.TransactionIdTransformer transactionIdTransformer()>();
v = interfaceinvoke v.<org.apache.activemq.store.TransactionIdTransformer: org.apache.activemq.command.TransactionId transform(org.apache.activemq.command.TransactionId)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.util.concurrent.ConcurrentHashMap transactions()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object remove(java.lang.Object)>(v);
if v != null goto label;
if v == null goto label;
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
if v != null goto label;
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
interfaceinvoke v.<java.lang.Runnable: void run()>();
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.util.concurrent.ConcurrentHashMap transactions()>();
entermonitor v;
label:
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$commit$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$commit$1: void <init>(org.apache.activemq.leveldb.LevelDBStore,java.lang.Runnable,java.util.concurrent.CountDownLatch,org.apache.activemq.leveldb.LevelDBStore$Transaction)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object withUow(scala.Function)>(v);
exitmonitor v;
label:
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$Transaction: boolean prepared()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$Transaction: long xacontainer_id()>();
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void removeTransactionContainer(long)>(v);
label:
if v != null goto label;
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
interfaceinvoke v.<java.lang.Runnable: void run()>();
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
label:
return;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public void rollback(org.apache.activemq.command.TransactionId)
{
org.apache.activemq.leveldb.LevelDBStore$$anonfun$rollback$2 v;
java.lang.Object[] v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$rollback$1 v;
long v;
scala.Predef$ v;
org.apache.activemq.command.TransactionId v, v;
boolean v;
scala.collection.mutable.WrappedArray v;
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.LevelDBStore$ v;
scala.runtime.BoxedUnit v, v;
org.apache.activemq.leveldb.LevelDBStore v;
java.util.concurrent.CountDownLatch v;
org.apache.activemq.store.TransactionIdTransformer v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.TransactionId;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void verify_running()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.store.TransactionIdTransformer transactionIdTransformer()>();
v = interfaceinvoke v.<org.apache.activemq.store.TransactionIdTransformer: org.apache.activemq.command.TransactionId transform(org.apache.activemq.command.TransactionId)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.util.concurrent.ConcurrentHashMap transactions()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object remove(java.lang.Object)>(v);
if v != null goto label;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$rollback$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$rollback$1: void <init>(org.apache.activemq.leveldb.LevelDBStore,org.apache.activemq.command.TransactionId)>(v, v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void debug(scala.Function,scala.collection.Seq)>(v, v);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$rollback$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$rollback$2: void <init>(org.apache.activemq.leveldb.LevelDBStore,java.util.concurrent.CountDownLatch,org.apache.activemq.leveldb.LevelDBStore$Transaction)>(v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object withUow(scala.Function)>(v);
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$Transaction: boolean prepared()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$Transaction: long xacontainer_id()>();
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void removeTransactionContainer(long)>(v);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
label:
return;
}
public void prepare(org.apache.activemq.command.TransactionId)
{
scala.collection.mutable.WrappedArray v;
java.lang.Object[] v;
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.LevelDBStore$ v;
scala.runtime.BoxedUnit v, v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.store.TransactionIdTransformer v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$prepare$2 v;
scala.Predef$ v;
java.lang.Object v;
org.apache.activemq.command.TransactionId v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.TransactionId;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void verify_running()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.store.TransactionIdTransformer transactionIdTransformer()>();
v = interfaceinvoke v.<org.apache.activemq.store.TransactionIdTransformer: org.apache.activemq.command.TransactionId transform(org.apache.activemq.command.TransactionId)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.util.concurrent.ConcurrentHashMap transactions()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$prepare$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$prepare$2: void <init>(org.apache.activemq.leveldb.LevelDBStore,org.apache.activemq.command.TransactionId)>(v, v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void warn(scala.Function,scala.collection.Seq)>(v, v);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$Transaction: void prepare()>();
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
label:
return;
}
public boolean doingRecover()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: boolean doingRecover>;
return v;
}
public void doingRecover_$eq(boolean)
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean doingRecover> = v;
return;
}
public void recover(org.apache.activemq.store.TransactionRecoveryListener)
{
java.lang.Throwable v;
scala.collection.concurrent.Map v;
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$recover$2 v;
scala.collection.JavaConversions$ v;
org.apache.activemq.store.TransactionRecoveryListener v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$recover$1 v;
scala.collection.generic.FilterMonadic v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.store.TransactionRecoveryListener;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void verify_running()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void doingRecover_$eq(boolean)>(1);
label:
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.util.concurrent.ConcurrentHashMap transactions()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.concurrent.Map mapAsScalaConcurrentMap(java.util.concurrent.ConcurrentMap)>(v);
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$recover$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$recover$1: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v = interfaceinvoke v.<scala.collection.concurrent.Map: scala.collection.generic.FilterMonadic withFilter(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$recover$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$recover$2: void <init>(org.apache.activemq.leveldb.LevelDBStore,org.apache.activemq.store.TransactionRecoveryListener)>(v, v);
interfaceinvoke v.<scala.collection.generic.FilterMonadic: void foreach(scala.Function)>(v);
label:
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void doingRecover_$eq(boolean)>(0);
return;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void doingRecover_$eq(boolean)>(0);
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.store.PList getPList(java.lang.String)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.Option v;
java.lang.Object v, v;
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$getPList$1 v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap plists()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option get(java.lang.Object)>(v);
exitmonitor v;
label:
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$getPList$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$getPList$1: void <init>(org.apache.activemq.leveldb.LevelDBStore,java.lang.String)>(v, v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBPList createPList(java.lang.String, long)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBPList v;
java.lang.Object v;
long v;
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
v := @parameter: long;
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBPList;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBPList: void <init>(org.apache.activemq.leveldb.LevelDBStore,java.lang.String,long)>(v, v, v);
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap plists()>();
virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option put(java.lang.Object,java.lang.Object)>(v, v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean removePList(java.lang.String)
{
scala.MatchError v;
long v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.Option v;
scala.None$ v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v;
java.lang.String v;
scala.collection.mutable.HashMap v;
boolean v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap plists()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option remove(java.lang.Object)>(v);
v = v instanceof scala.Some;
if v == 0 goto label;
v = virtualinvoke v.<scala.Some: java.lang.Object x()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBPList: long key()>();
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void destroyPList(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBPList: java.util.concurrent.atomic.AtomicLong listSize()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(0L);
v = 1;
goto label;
label:
v = <scala.None$: scala.None$ MODULE$>;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = 0;
label:
return v;
label:
v = new scala.MatchError;
specialinvoke v.<scala.MatchError: void <init>(java.lang.Object)>(v);
throw v;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore createMessageStore(org.apache.activemq.command.ActiveMQDestination)
{
scala.MatchError v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
org.apache.activemq.leveldb.LevelDBStore v;
boolean v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = v instanceof org.apache.activemq.command.ActiveMQQueue;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue)>(v);
goto label;
label:
v = v instanceof org.apache.activemq.command.ActiveMQTopic;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBTopicMessageStore createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic)>(v);
label:
return v;
label:
v = new scala.MatchError;
specialinvoke v.<scala.MatchError: void <init>(java.lang.Object)>(v);
throw v;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$createQueueMessageStore$1 v;
org.apache.activemq.command.ActiveMQQueue v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.Option v;
java.lang.Object v, v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQQueue;
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap queues()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option get(java.lang.Object)>(v);
exitmonitor v;
label:
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$createQueueMessageStore$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$createQueueMessageStore$1: void <init>(org.apache.activemq.leveldb.LevelDBStore,org.apache.activemq.command.ActiveMQQueue)>(v, v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue, long)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
java.lang.Object v;
long v;
org.apache.activemq.command.ActiveMQQueue v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQQueue;
v := @parameter: long;
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: void <init>(org.apache.activemq.leveldb.LevelDBStore,org.apache.activemq.command.ActiveMQDestination,long)>(v, v, v);
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap queues()>();
virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option put(java.lang.Object,java.lang.Object)>(v, v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public void removeQueueMessageStore(org.apache.activemq.command.ActiveMQQueue)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$removeQueueMessageStore$1 v;
scala.runtime.BoxedUnit v;
org.apache.activemq.command.ActiveMQQueue v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.Option v;
java.lang.Object v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQQueue;
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap queues()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option remove(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$removeQueueMessageStore$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$removeQueueMessageStore$1: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
virtualinvoke v.<scala.Option: void foreach(scala.Function)>(v);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
exitmonitor v;
label:
return;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBTopicMessageStore createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.Option v;
org.apache.activemq.command.ActiveMQTopic v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$createTopicMessageStore$1 v;
java.lang.Object v, v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQTopic;
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topics()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option get(java.lang.Object)>(v);
exitmonitor v;
label:
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$createTopicMessageStore$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$createTopicMessageStore$1: void <init>(org.apache.activemq.leveldb.LevelDBStore,org.apache.activemq.command.ActiveMQTopic)>(v, v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBTopicMessageStore createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic, long)
{
java.lang.Throwable v;
long v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBTopicMessageStore v;
org.apache.activemq.command.ActiveMQTopic v;
java.lang.Long v;
java.lang.Object v;
scala.collection.mutable.HashMap v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQTopic;
v := @parameter: long;
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBTopicMessageStore;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBTopicMessageStore: void <init>(org.apache.activemq.leveldb.LevelDBStore,org.apache.activemq.command.ActiveMQDestination,long)>(v, v, v);
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topics()>();
virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topicsById()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option put(java.lang.Object,java.lang.Object)>(v, v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.broker.scheduler.JobSchedulerStore createJobSchedulerStore()
{
java.lang.UnsupportedOperationException v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public void removeTopicMessageStore(org.apache.activemq.command.ActiveMQTopic)
{
org.apache.activemq.command.ActiveMQTopic v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.Option v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$removeTopicMessageStore$1 v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQTopic;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topics()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option remove(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$removeTopicMessageStore$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$removeTopicMessageStore$1: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
virtualinvoke v.<scala.Option: void foreach(scala.Function)>(v);
return;
}
public long getLogAppendPosition()
{
org.apache.activemq.leveldb.DBManager v;
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long getLogAppendPosition()>();
return v;
}
public java.util.Set getDestinations()
{
java.util.Collection v, v;
scala.collection.Iterable v, v;
org.apache.activemq.leveldb.LevelDBStore v;
java.util.HashSet v;
scala.collection.JavaConversions$ v, v;
scala.collection.mutable.HashMap v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topics()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.collection.Iterable keys()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: java.util.Collection asJavaCollection(scala.collection.Iterable)>(v);
virtualinvoke v.<java.util.HashSet: boolean addAll(java.util.Collection)>(v);
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap queues()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.collection.Iterable keys()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: java.util.Collection asJavaCollection(scala.collection.Iterable)>(v);
virtualinvoke v.<java.util.HashSet: boolean addAll(java.util.Collection)>(v);
return v;
}
public long getLastProducerSequenceId(org.apache.activemq.command.ProducerId)
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.leveldb.DBManager v;
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.ProducerId;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long getLastProducerSequenceId(org.apache.activemq.command.ProducerId)>(v);
return v;
}
public void setMaxFailoverProducersToTrack(int)
{
int v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.ActiveMQMessageAuditNoSync producerSequenceIdTracker()>();
virtualinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: void setMaximumNumberOfProducersToTrack(int)>(v);
return;
}
public int getMaxFailoverProducersToTrack()
{
int v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.ActiveMQMessageAuditNoSync producerSequenceIdTracker()>();
v = virtualinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int getMaximumNumberOfProducersToTrack()>();
return v;
}
public void setFailoverProducersAuditDepth(int)
{
int v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: int;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.ActiveMQMessageAuditNoSync producerSequenceIdTracker()>();
virtualinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: void setAuditDepth(int)>(v);
return;
}
public int getFailoverProducersAuditDepth()
{
int v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.ActiveMQMessageAuditNoSync producerSequenceIdTracker()>();
v = virtualinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int getAuditDepth()>();
return v;
}
public long size()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.DBManager v;
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long size()>();
return v;
}
public void checkpoint(boolean)
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void checkpoint(boolean)>(v);
return;
}
public java.lang.Object withUow(scala.Function)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.DBManager v;
scala.Function v;
java.lang.Object v;
org.apache.activemq.leveldb.DelayableUOW v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: scala.Function;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.DelayableUOW createUow()>();
label:
v = interfaceinvoke v.<scala.Function1: java.lang.Object apply(java.lang.Object)>(v);
label:
virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: void release()>();
return v;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: void release()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
private java.lang.String subscriptionKey(java.lang.String, java.lang.String)
{
org.apache.activemq.leveldb.LevelDBStore v;
scala.collection.mutable.StringBuilder v, v, v, v;
java.lang.String v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(":");
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
return v;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ LevelDBMessageStore()
{
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ LevelDBMessageStore$module>;
if v != null goto label;
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ LevelDBMessageStore$lzycompute()>();
goto label;
label:
v = v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$ LevelDBMessageStore$module>;
label:
return v;
}
public java.lang.Object createSubscription(org.apache.activemq.leveldb.DurableSubscription)
{
java.lang.Throwable v, v;
long v;
java.lang.Long v;
org.apache.activemq.leveldb.DurableSubscription v;
java.lang.String v, v;
scala.collection.mutable.HashMap v, v;
boolean v, v;
org.apache.activemq.command.SubscriptionInfo v, v;
scala.MatchError v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.Option v, v, v;
scala.Tuple v;
scala.None$ v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.leveldb.DurableSubscription;
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topicsById()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DurableSubscription: long topicKey()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option get(java.lang.Object)>(v);
exitmonitor v;
label:
v = v instanceof scala.Some;
if v == 0 goto label;
v = virtualinvoke v.<scala.Some: java.lang.Object x()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBTopicMessageStore: scala.collection.mutable.HashMap subscriptions()>();
v = new scala.Tuple;
v = virtualinvoke v.<org.apache.activemq.leveldb.DurableSubscription: org.apache.activemq.command.SubscriptionInfo info()>();
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getClientId()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DurableSubscription: org.apache.activemq.command.SubscriptionInfo info()>();
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getSubcriptionName()>();
specialinvoke v.<scala.Tuple2: void <init>(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option put(java.lang.Object,java.lang.Object)>(v, v);
exitmonitor v;
label:
v = v;
goto label;
label:
v = <scala.None$: scala.None$ MODULE$>;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void removeSubscription(org.apache.activemq.leveldb.DurableSubscription)>(v);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
label:
return v;
label:
v = new scala.MatchError;
specialinvoke v.<scala.MatchError: void <init>(java.lang.Object)>(v);
throw v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public scala.collection.Seq getTopicGCPositions()
{
java.lang.Throwable v;
java.util.Collection v;
scala.collection.Seq v;
org.apache.activemq.leveldb.LevelDBStore v;
java.util.ArrayList v;
org.apache.activemq.leveldb.LevelDBStore$$anonfun$getTopicGCPositions$1 v;
scala.collection.mutable.Buffer$ v;
scala.collection.JavaConversions$ v, v;
java.util.Map v;
scala.collection.mutable.Buffer v;
java.lang.Object v, v;
scala.collection.generic.CanBuildFrom v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock()>();
entermonitor v;
label:
v = new java.util.ArrayList;
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topicsById()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: java.util.Map mutableMapAsJavaMap(scala.collection.mutable.Map)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
exitmonitor v;
label:
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.mutable.Buffer asScalaBuffer(java.util.List)>(v);
v = new org.apache.activemq.leveldb.LevelDBStore$$anonfun$getTopicGCPositions$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anonfun$getTopicGCPositions$1: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v = <scala.collection.mutable.Buffer$: scala.collection.mutable.Buffer$ MODULE$>;
v = virtualinvoke v.<scala.collection.mutable.Buffer$: scala.collection.generic.CanBuildFrom canBuildFrom()>();
v = interfaceinvoke v.<scala.collection.mutable.Buffer: java.lang.Object flatMap(scala.Function,scala.collection.generic.CanBuildFrom)>(v, v);
v = interfaceinvoke v.<scala.collection.SeqLike: scala.collection.Seq toSeq()>();
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public void beginTransaction(org.apache.activemq.broker.ConnectionContext)
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
return;
}
public void commitTransaction(org.apache.activemq.broker.ConnectionContext)
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
return;
}
public void rollbackTransaction(org.apache.activemq.broker.ConnectionContext)
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
return;
}
public org.apache.activemq.leveldb.LevelDBClient createClient()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = new org.apache.activemq.leveldb.LevelDBClient;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
return v;
}
public void allowIOResumption()
{
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
return;
}
public java.io.File getDirectory()
{
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File directory()>();
return v;
}
public java.io.File getLogDirectory()
{
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File logDirectory()>();
return v;
}
public long getLogSize()
{
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: long logSize()>();
return v;
}
public java.lang.String getIndexFactory()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexFactory()>();
return v;
}
public boolean getSync()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean sync()>();
return v;
}
public boolean getVerifyChecksums()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean verifyChecksums()>();
return v;
}
public int getIndexMaxOpenFiles()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int indexMaxOpenFiles()>();
return v;
}
public int getIndexBlockRestartInterval()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockRestartInterval()>();
return v;
}
public boolean getParanoidChecks()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean paranoidChecks()>();
return v;
}
public int getIndexWriteBufferSize()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int indexWriteBufferSize()>();
return v;
}
public int getIndexBlockSize()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockSize()>();
return v;
}
public java.lang.String getIndexCompression()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexCompression()>();
return v;
}
public java.lang.String getLogCompression()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String logCompression()>();
return v;
}
public long getIndexCacheSize()
{
long v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: long indexCacheSize()>();
return v;
}
public int getFlushDelay()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int flushDelay()>();
return v;
}
public int getAsyncBufferSize()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int asyncBufferSize()>();
return v;
}
public boolean getMonitorStats()
{
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean monitorStats()>();
return v;
}
public int getAutoCompactionRatio()
{
int v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int autoCompactionRatio()>();
return v;
}
public void <init>()
{
org.apache.activemq.leveldb.LevelDBStore$$anon$6 v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.collection.mutable.HashMap$ v, v, v, v;
scala.collection.GenMap v, v, v, v;
scala.collection.immutable.Nil$ v, v, v, v;
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.LevelDBStore$ v;
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
org.apache.activemq.openwire.OpenWireFormat v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.LevelDBStore;
specialinvoke v.<org.apache.activemq.broker.LockableServiceSupport: void <init>()>();
v = new org.apache.activemq.openwire.OpenWireFormat;
specialinvoke v.<org.apache.activemq.openwire.OpenWireFormat: void <init>()>();
v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.openwire.OpenWireFormat wireFormat> = v;
v = new org.apache.activemq.leveldb.DBManager;
specialinvoke v.<org.apache.activemq.leveldb.DBManager: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBClient createClient()>();
v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBClient client> = v;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: java.io.File DEFAULT_DIRECTORY()>();
v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File directory> = v;
v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File logDirectory> = null;
v.<org.apache.activemq.leveldb.LevelDBStore: long logSize> = 104857600L;
v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexFactory> = "org.fusesource.leveldbjni.JniDBFactory, org.iq.leveldb.impl.Iq80DBFactory";
v.<org.apache.activemq.leveldb.LevelDBStore: boolean sync> = 1;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean verifyChecksums> = 0;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexMaxOpenFiles> = 1000;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockRestartInterval> = 16;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean paranoidChecks> = 0;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexWriteBufferSize> = 6291456;
v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockSize> = 4096;
v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexCompression> = "snappy";
v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String logCompression> = "none";
v.<org.apache.activemq.leveldb.LevelDBStore: long indexCacheSize> = 268435456L;
v.<org.apache.activemq.leveldb.LevelDBStore: int flushDelay> = 0;
v.<org.apache.activemq.leveldb.LevelDBStore: int asyncBufferSize> = 4194304;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean monitorStats> = 0;
v.<org.apache.activemq.leveldb.LevelDBStore: int autoCompactionRatio> = 250;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean purgeOnStatup> = 0;
v = <scala.collection.mutable.HashMap$: scala.collection.mutable.HashMap$ MODULE$>;
v = <scala.collection.immutable.Nil$: scala.collection.immutable.Nil$ MODULE$>;
v = virtualinvoke v.<scala.collection.mutable.HashMap$: scala.collection.GenMap apply(scala.collection.Seq)>(v);
v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap queues> = v;
v = <scala.collection.mutable.HashMap$: scala.collection.mutable.HashMap$ MODULE$>;
v = <scala.collection.immutable.Nil$: scala.collection.immutable.Nil$ MODULE$>;
v = virtualinvoke v.<scala.collection.mutable.HashMap$: scala.collection.GenMap apply(scala.collection.Seq)>(v);
v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topics> = v;
v = <scala.collection.mutable.HashMap$: scala.collection.mutable.HashMap$ MODULE$>;
v = <scala.collection.immutable.Nil$: scala.collection.immutable.Nil$ MODULE$>;
v = virtualinvoke v.<scala.collection.mutable.HashMap$: scala.collection.GenMap apply(scala.collection.Seq)>(v);
v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap topicsById> = v;
v = <scala.collection.mutable.HashMap$: scala.collection.mutable.HashMap$ MODULE$>;
v = <scala.collection.immutable.Nil$: scala.collection.immutable.Nil$ MODULE$>;
v = virtualinvoke v.<scala.collection.mutable.HashMap$: scala.collection.GenMap apply(scala.collection.Seq)>(v);
v.<org.apache.activemq.leveldb.LevelDBStore: scala.collection.mutable.HashMap plists> = v;
v = new java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object lock> = v;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean snappyCompressLogs> = 0;
v = new org.apache.activemq.leveldb.LevelDBStore$$anon$6;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$$anon$6: void <init>(org.apache.activemq.leveldb.LevelDBStore)>(v);
v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.store.TransactionIdTransformer transactionIdTransformer> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.activemq.leveldb.LevelDBStore: java.util.concurrent.ConcurrentHashMap transactions> = v;
v.<org.apache.activemq.leveldb.LevelDBStore: boolean doingRecover> = 0;
return;
}
}