public class org.apache.activemq.leveldb.LevelDBStoreFactory extends java.lang.Object implements org.apache.activemq.store.PersistenceAdapterFactory
{
private int asyncBufferSize;
private java.io.File directory;
private int flushDelay;
private int indexBlockRestartInterval;
private int indexBlockSize;
private long indexCacheSize;
private java.lang.String indexCompression;
private java.lang.String indexFactory;
private int indexMaxOpenFiles;
private int indexWriteBufferSize;
private java.lang.String logCompression;
private java.io.File logDirectory;
private long logSize;
private boolean monitorStats;
private boolean paranoidChecks;
private boolean sync;
private boolean verifyChecksums;
public void <init>()
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int asyncBufferSize> = 4194304;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("LevelDB");
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.io.File directory> = v;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int flushDelay> = 5000;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexBlockRestartInterval> = 16;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexBlockSize> = 4096;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: long indexCacheSize> = 268435456L;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String indexCompression> = "snappy";
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String indexFactory> = "org.fusesource.leveldbjni.JniDBFactory, org.iq.leveldb.impl.Iq80DBFactory";
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexMaxOpenFiles> = 1000;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexWriteBufferSize> = 6291456;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String logCompression> = "none";
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: long logSize> = 104857600L;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean sync> = 1;
return;
}
public org.apache.activemq.store.PersistenceAdapter createPersistenceAdapter() throws java.io.IOException
{
long v, v;
int v, v, v, v, v, v;
java.lang.String v, v, v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
boolean v, v, v, v;
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = new org.apache.activemq.leveldb.LevelDBStore;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void <init>()>();
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean verifyChecksums>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setVerifyChecksums(boolean)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int asyncBufferSize>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setAsyncBufferSize(int)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.io.File directory>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setDirectory(java.io.File)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int flushDelay>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setFlushDelay(int)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexBlockRestartInterval>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setIndexBlockRestartInterval(int)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexBlockSize>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setIndexBlockSize(int)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: long indexCacheSize>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setIndexCacheSize(long)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String indexCompression>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setIndexCompression(java.lang.String)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String indexFactory>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setIndexFactory(java.lang.String)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexMaxOpenFiles>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setIndexMaxOpenFiles(int)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexWriteBufferSize>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setIndexWriteBufferSize(int)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String logCompression>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setLogCompression(java.lang.String)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.io.File logDirectory>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setLogDirectory(java.io.File)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: long logSize>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setLogSize(long)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean monitorStats>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setMonitorStats(boolean)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean paranoidChecks>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setParanoidChecks(boolean)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean sync>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setSync(boolean)>(v);
return v;
}
public int getAsyncBufferSize()
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int asyncBufferSize>;
return v;
}
public void setAsyncBufferSize(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int asyncBufferSize> = v;
return;
}
public java.io.File getDirectory()
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.io.File directory>;
return v;
}
public void setDirectory(java.io.File)
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: java.io.File;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.io.File directory> = v;
return;
}
public int getFlushDelay()
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int flushDelay>;
return v;
}
public void setFlushDelay(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int flushDelay> = v;
return;
}
public int getIndexBlockRestartInterval()
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexBlockRestartInterval>;
return v;
}
public void setIndexBlockRestartInterval(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexBlockRestartInterval> = v;
return;
}
public int getIndexBlockSize()
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexBlockSize>;
return v;
}
public void setIndexBlockSize(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexBlockSize> = v;
return;
}
public long getIndexCacheSize()
{
long v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: long indexCacheSize>;
return v;
}
public void setIndexCacheSize(long)
{
long v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: long indexCacheSize> = v;
return;
}
public java.lang.String getIndexCompression()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String indexCompression>;
return v;
}
public void setIndexCompression(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String indexCompression> = v;
return;
}
public java.lang.String getIndexFactory()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String indexFactory>;
return v;
}
public void setIndexFactory(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String indexFactory> = v;
return;
}
public int getIndexMaxOpenFiles()
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexMaxOpenFiles>;
return v;
}
public void setIndexMaxOpenFiles(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexMaxOpenFiles> = v;
return;
}
public int getIndexWriteBufferSize()
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexWriteBufferSize>;
return v;
}
public void setIndexWriteBufferSize(int)
{
int v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: int;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: int indexWriteBufferSize> = v;
return;
}
public java.lang.String getLogCompression()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String logCompression>;
return v;
}
public void setLogCompression(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.lang.String logCompression> = v;
return;
}
public java.io.File getLogDirectory()
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.io.File logDirectory>;
return v;
}
public void setLogDirectory(java.io.File)
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: java.io.File;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: java.io.File logDirectory> = v;
return;
}
public long getLogSize()
{
long v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: long logSize>;
return v;
}
public void setLogSize(long)
{
long v;
org.apache.activemq.leveldb.LevelDBStoreFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: long logSize> = v;
return;
}
public boolean isMonitorStats()
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean monitorStats>;
return v;
}
public void setMonitorStats(boolean)
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean monitorStats> = v;
return;
}
public boolean isParanoidChecks()
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean paranoidChecks>;
return v;
}
public void setParanoidChecks(boolean)
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean paranoidChecks> = v;
return;
}
public boolean isSync()
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean sync>;
return v;
}
public void setSync(boolean)
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean sync> = v;
return;
}
public boolean isVerifyChecksums()
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v = v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean verifyChecksums>;
return v;
}
public void setVerifyChecksums(boolean)
{
org.apache.activemq.leveldb.LevelDBStoreFactory v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStoreFactory;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.LevelDBStoreFactory: boolean verifyChecksums> = v;
return;
}
}