org.apache.activemq.broker.scheduler
Class JobSchedulerStore

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.broker.scheduler.JobSchedulerStore
All Implemented Interfaces:
Service

public class JobSchedulerStore
extends ServiceSupport


Nested Class Summary
protected  class JobSchedulerStore.MetaData
           
 
Field Summary
static int CLOSED_STATE
           
static int OPEN_STATE
           
 
Constructor Summary
JobSchedulerStore()
           
 
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
 

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 File getDirectory()

setDirectory

public void setDirectory(File directory)

size

public long size()

getJobScheduler

public JobScheduler getJobScheduler(String name)
                             throws Exception
Throws:
Exception

removeJobScheduler

public boolean removeJobScheduler(String name)
                           throws Exception
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-2012 The Apache Software Foundation. All Rights Reserved.