public class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory extends org.apache.activemq.store.jdbc.DataSourceServiceSupport implements org.apache.activemq.store.PersistenceAdapterFactory
{
private static final int JOURNAL_LOCKED_WAIT_DELAY;
private static final org.slf4j.Logger LOG;
private long checkpointInterval;
private int journalLogFileSize;
private int journalLogFiles;
private org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory;
private org.apache.activeio.journal.Journal journal;
private boolean useJournal;
private boolean useQuickJournal;
private java.io.File journalArchiveDirectory;
private boolean failIfJournalIsLocked;
private int journalThreadPriority;
private org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter;
private boolean useDedicatedTaskRunner;
public void <init>()
{
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
specialinvoke v.<org.apache.activemq.store.jdbc.DataSourceServiceSupport: void <init>()>();
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: long checkpointInterval> = 300000L;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalLogFileSize> = 20971520;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalLogFiles> = 2;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean useJournal> = 1;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalThreadPriority> = 10;
v = new org.apache.activemq.store.jdbc.JDBCPersistenceAdapter;
specialinvoke v.<org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: void <init>()>();
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter> = v;
return;
}
public org.apache.activemq.store.PersistenceAdapter createPersistenceAdapter() throws java.io.IOException
{
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v, v, v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
long v;
org.apache.activeio.journal.Journal v;
java.io.File v;
org.apache.activemq.store.journal.JournalPersistenceAdapter v;
org.apache.activemq.thread.TaskRunnerFactory v;
javax.sql.DataSource v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: javax.sql.DataSource getDataSource()>();
virtualinvoke v.<org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: void setDataSource(javax.sql.DataSource)>(v);
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean useJournal>;
if v != 0 goto label;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
return v;
label:
v = new org.apache.activemq.store.journal.JournalPersistenceAdapter;
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activeio.journal.Journal getJournal()>();
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()>();
specialinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapter: void <init>(org.apache.activeio.journal.Journal,org.apache.activemq.store.PersistenceAdapter,org.apache.activemq.thread.TaskRunnerFactory)>(v, v, v);
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: java.io.File getDataDirectoryFile()>();
virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapter: void setDirectory(java.io.File)>(v);
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: long getCheckpointInterval()>();
virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapter: void setCheckpointInterval(long)>(v);
return v;
}
public int getJournalLogFiles()
{
int v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalLogFiles>;
return v;
}
public void setJournalLogFiles(int)
{
int v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: int;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalLogFiles> = v;
return;
}
public int getJournalLogFileSize()
{
int v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalLogFileSize>;
return v;
}
public void setJournalLogFileSize(int)
{
int v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: int;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalLogFileSize> = v;
return;
}
public org.apache.activemq.store.jdbc.JDBCPersistenceAdapter getJdbcAdapter()
{
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
return v;
}
public void setJdbcAdapter(org.apache.activemq.store.jdbc.JDBCPersistenceAdapter)
{
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter> = v;
return;
}
public boolean isUseJournal()
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean useJournal>;
return v;
}
public long getCheckpointInterval()
{
long v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: long checkpointInterval>;
return v;
}
public void setCheckpointInterval(long)
{
long v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: long;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: long checkpointInterval> = v;
return;
}
public void setUseJournal(boolean)
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: boolean;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean useJournal> = v;
return;
}
public boolean isUseDedicatedTaskRunner()
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean useDedicatedTaskRunner>;
return v;
}
public void setUseDedicatedTaskRunner(boolean)
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: boolean;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean useDedicatedTaskRunner> = v;
return;
}
public org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
org.apache.activemq.thread.TaskRunnerFactory v, v, v;
int v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory>;
if v != null goto label;
v = new org.apache.activemq.thread.TaskRunnerFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalThreadPriority>;
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean isUseDedicatedTaskRunner()>();
specialinvoke v.<org.apache.activemq.thread.TaskRunnerFactory: void <init>(java.lang.String,int,boolean,int,boolean)>("Persistence Adaptor Task", v, 1, 1000, v);
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory> = v;
label:
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory>;
return v;
}
public void setTaskRunnerFactory(org.apache.activemq.thread.TaskRunnerFactory)
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
org.apache.activemq.thread.TaskRunnerFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: org.apache.activemq.thread.TaskRunnerFactory;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory> = v;
return;
}
public org.apache.activeio.journal.Journal getJournal() throws java.io.IOException
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
org.apache.activeio.journal.Journal v, v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activeio.journal.Journal journal>;
if v != null goto label;
virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: void createJournal()>();
label:
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activeio.journal.Journal journal>;
return v;
}
public void setJournal(org.apache.activeio.journal.Journal)
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
org.apache.activeio.journal.Journal v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: org.apache.activeio.journal.Journal;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activeio.journal.Journal journal> = v;
return;
}
public java.io.File getJournalArchiveDirectory()
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
java.io.File v, v, v, v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: java.io.File journalArchiveDirectory>;
if v != null goto label;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean useQuickJournal>;
if v == 0 goto label;
v = new java.io.File;
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: java.io.File getDataDirectoryFile()>();
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "journal");
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: java.io.File journalArchiveDirectory> = v;
label:
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: java.io.File journalArchiveDirectory>;
return v;
}
public void setJournalArchiveDirectory(java.io.File)
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
java.io.File v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: java.io.File;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: java.io.File journalArchiveDirectory> = v;
return;
}
public boolean isUseQuickJournal()
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean useQuickJournal>;
return v;
}
public void setUseQuickJournal(boolean)
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: boolean;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean useQuickJournal> = v;
return;
}
public org.apache.activemq.store.jdbc.JDBCAdapter getAdapter() throws java.io.IOException
{
org.apache.activemq.store.jdbc.JDBCAdapter v;
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
v = virtualinvoke v.<org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: org.apache.activemq.store.jdbc.JDBCAdapter getAdapter()>();
return v;
}
public void setAdapter(org.apache.activemq.store.jdbc.JDBCAdapter)
{
org.apache.activemq.store.jdbc.JDBCAdapter v;
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: org.apache.activemq.store.jdbc.JDBCAdapter;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
virtualinvoke v.<org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: void setAdapter(org.apache.activemq.store.jdbc.JDBCAdapter)>(v);
return;
}
public org.apache.activemq.store.jdbc.Statements getStatements()
{
org.apache.activemq.store.jdbc.Statements v;
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
v = virtualinvoke v.<org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: org.apache.activemq.store.jdbc.Statements getStatements()>();
return v;
}
public void setStatements(org.apache.activemq.store.jdbc.Statements)
{
org.apache.activemq.store.jdbc.Statements v;
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: org.apache.activemq.store.jdbc.Statements;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
virtualinvoke v.<org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: void setStatements(org.apache.activemq.store.jdbc.Statements)>(v);
return;
}
public void setUseDatabaseLock(boolean)
{
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
virtualinvoke v.<org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: void setUseLock(boolean)>(v);
return;
}
public boolean isCreateTablesOnStartup()
{
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
v = virtualinvoke v.<org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: boolean isCreateTablesOnStartup()>();
return v;
}
public void setCreateTablesOnStartup(boolean)
{
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activemq.store.jdbc.JDBCPersistenceAdapter jdbcPersistenceAdapter>;
virtualinvoke v.<org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: void setCreateTablesOnStartup(boolean)>(v);
return;
}
public int getJournalThreadPriority()
{
int v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalThreadPriority>;
return v;
}
public void setJournalThreadPriority(int)
{
int v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: int;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalThreadPriority> = v;
return;
}
protected void createJournal() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activeio.journal.active.JournalImpl v, v;
int v, v, v, v;
boolean v;
org.slf4j.Logger v;
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
java.io.File v, v, v, v, v;
java.lang.InterruptedException v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v = new java.io.File;
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: java.io.File getDataDirectoryFile()>();
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "journal");
v = virtualinvoke v.<java.io.File: java.io.File getCanonicalFile()>();
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: boolean failIfJournalIsLocked>;
if v == 0 goto label;
v = new org.apache.activeio.journal.active.JournalImpl;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalLogFiles>;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalLogFileSize>;
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: java.io.File getJournalArchiveDirectory()>();
specialinvoke v.<org.apache.activeio.journal.active.JournalImpl: void <init>(java.io.File,int,int,java.io.File)>(v, v, v, v);
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activeio.journal.Journal journal> = v;
goto label;
label:
v = new org.apache.activeio.journal.active.JournalImpl;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalLogFiles>;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: int journalLogFileSize>;
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: java.io.File getJournalArchiveDirectory()>();
specialinvoke v.<org.apache.activeio.journal.active.JournalImpl: void <init>(java.io.File,int,int,java.io.File)>(v, v, v, v);
v.<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.apache.activeio.journal.Journal journal> = v;
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Journal is locked... waiting 10 seconds for the journal to be unlocked.");
label:
staticinvoke <java.lang.Thread: void sleep(long)>(10000L);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
return;
catch org.apache.activeio.journal.active.JournalLockedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
public org.apache.activemq.broker.Locker createDefaultLocker() throws java.io.IOException
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
return null;
}
public void init() throws java.lang.Exception
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
return;
}
protected void doStop(org.apache.activemq.util.ServiceStopper) throws java.lang.Exception
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
org.apache.activemq.util.ServiceStopper v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
v := @parameter: org.apache.activemq.util.ServiceStopper;
return;
}
protected void doStart() throws java.lang.Exception
{
org.apache.activemq.store.journal.JournalPersistenceAdapterFactory v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapterFactory;
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/store/journal/JournalPersistenceAdapterFactory;");
<org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: org.slf4j.Logger LOG> = v;
return;
}
}