org.apache.activemq.store.kahadb.scheduler
Class JobSchedulerStoreImpl

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
All Implemented Interfaces:
JobSchedulerStore, Service

public class JobSchedulerStoreImpl
extends ServiceSupport
implements JobSchedulerStore


Nested Class Summary
protected  class JobSchedulerStoreImpl.MetaData
           
 
Field Summary
static int CLOSED_STATE
           
protected  AtomicLong journalSize
           
static int OPEN_STATE
           
 
Constructor Summary
JobSchedulerStoreImpl()
           
 
Method Summary
protected  void doStart()
           
protected  void doStop(ServiceStopper stopper)
           
 File getDirectory()
           
 JobScheduler getJobScheduler(String name)
           
 int getJournalMaxFileLength()
           
 int getJournalMaxWriteBatchSize()
           
 boolean isEnableIndexWriteAsync()
           
 boolean isFailIfDatabaseIsLocked()
           
 boolean removeJobScheduler(String name)
           
 void setDirectory(File directory)
           
 void setEnableIndexWriteAsync(boolean enableIndexWriteAsync)
           
 void setFailIfDatabaseIsLocked(boolean failIfDatabaseIsLocked)
           
 void setJournalMaxFileLength(int journalMaxFileLength)
           
 void setJournalMaxWriteBatchSize(int journalMaxWriteBatchSize)
           
 long size()
           
 String toString()
           
 
Methods inherited from class org.apache.activemq.util.ServiceSupport
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.Service
start, stop
 

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

journalSize

protected AtomicLong journalSize
Constructor Detail

JobSchedulerStoreImpl

public JobSchedulerStoreImpl()
Method Detail

getDirectory

public File getDirectory()
Specified by:
getDirectory in interface JobSchedulerStore

setDirectory

public void setDirectory(File directory)
Specified by:
setDirectory in interface JobSchedulerStore

size

public long size()
Specified by:
size in interface JobSchedulerStore

getJobScheduler

public JobScheduler getJobScheduler(String name)
                             throws Exception
Specified by:
getJobScheduler in interface JobSchedulerStore
Throws:
Exception

removeJobScheduler

public boolean removeJobScheduler(String name)
                           throws Exception
Specified by:
removeJobScheduler in interface JobSchedulerStore
Throws:
Exception

doStart

protected void doStart()
                throws Exception
Specified by:
doStart in class ServiceSupport
Throws:
Exception

doStop

protected void doStop(ServiceStopper stopper)
               throws Exception
Specified by:
doStop in class ServiceSupport
Throws:
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 String toString()
Overrides:
toString in class Object


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.