org.apache.activemq.broker.scheduler

Class JobSchedulerStore

java.lang.Object

org.apache.activemq.util.ServiceSupport

org.apache.activemq.broker.scheduler.JobSchedulerStore

All Implemented Interfaces:

Service

public class JobSchedulerStore
extends ServiceSupport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	JobSchedulerStore.MetaData

Field Summary

Fields

Modifier and Type	Field and Description
static int	CLOSED_STATE
static int	OPEN_STATE

Constructor Summary

Constructors

Constructor and Description
JobSchedulerStore()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop(ServiceStopper stopper)
java.io.File	getDirectory()
JobScheduler	getJobScheduler(java.lang.String name)
int	getJournalMaxFileLength()
int	getJournalMaxWriteBatchSize()
boolean	isEnableIndexWriteAsync()
boolean	isFailIfDatabaseIsLocked()
boolean	removeJobScheduler(java.lang.String name)
void	setDirectory(java.io.File directory)
void	setEnableIndexWriteAsync(boolean enableIndexWriteAsync)
void	setFailIfDatabaseIsLocked(boolean failIfDatabaseIsLocked)
void	setJournalMaxFileLength(int journalMaxFileLength)
void	setJournalMaxWriteBatchSize(int journalMaxWriteBatchSize)
long	size()
java.lang.String	toString()

Methods inherited from class org.apache.activemq.util.ServiceSupport

addServiceListener, dispose, isStarted, isStopped, isStopping, removeServiceListener, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

CLOSED_STATE

public static final int CLOSED_STATE

See Also:

Constant Field Values

OPEN_STATE

public static final int OPEN_STATE

See Also:

Constant Field Values

Constructor Detail

JobSchedulerStore

public JobSchedulerStore()

Method Detail

getDirectory

public java.io.File getDirectory()

setDirectory

public void setDirectory(java.io.File directory)

size

public long size()

getJobScheduler

public JobScheduler getJobScheduler(java.lang.String name)
                             throws java.lang.Exception

Throws:

java.lang.Exception

removeJobScheduler

public boolean removeJobScheduler(java.lang.String name)
                           throws java.lang.Exception

Throws:

java.lang.Exception

doStart

protected void doStart()
                throws java.lang.Exception

Specified by:

doStart in class ServiceSupport

Throws:

java.lang.Exception

doStop

protected void doStop(ServiceStopper stopper)
               throws java.lang.Exception

Specified by:

doStop in class ServiceSupport

Throws:

java.lang.Exception

isFailIfDatabaseIsLocked

public boolean isFailIfDatabaseIsLocked()

setFailIfDatabaseIsLocked

public void setFailIfDatabaseIsLocked(boolean failIfDatabaseIsLocked)

getJournalMaxFileLength

public int getJournalMaxFileLength()

setJournalMaxFileLength

public void setJournalMaxFileLength(int journalMaxFileLength)

getJournalMaxWriteBatchSize

public int getJournalMaxWriteBatchSize()

setJournalMaxWriteBatchSize

public void setJournalMaxWriteBatchSize(int journalMaxWriteBatchSize)

isEnableIndexWriteAsync

public boolean isEnableIndexWriteAsync()

setEnableIndexWriteAsync

public void setEnableIndexWriteAsync(boolean enableIndexWriteAsync)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object