Field Detail

• QUARTZ_JMX

  public static final java.lang.String QUARTZ_JMX

  See Also:

  Constant Field Values

• QUARTZ_MAKE_SCHEDULER_THREAD_DAEMON

  public static final java.lang.String QUARTZ_MAKE_SCHEDULER_THREAD_DAEMON

  See Also:

  Constant Field Values

• OPENEJB_TIMEOUT_JOB_NAME

  public static final java.lang.String OPENEJB_TIMEOUT_JOB_NAME

  See Also:

  Constant Field Values

• OPENEJB_TIMEOUT_JOB_GROUP_NAME

  public static final java.lang.String OPENEJB_TIMEOUT_JOB_GROUP_NAME

  See Also:

  Constant Field Values

• EJB_TIMER_RETRY_ATTEMPTS

  public static final java.lang.String EJB_TIMER_RETRY_ATTEMPTS

  See Also:

  Constant Field Values

• OPENEJB_QUARTZ_USE_TCCL

  public static final java.lang.String OPENEJB_QUARTZ_USE_TCCL

  See Also:

  Constant Field Values

Constructor Detail

• EjbTimerServiceImpl

  public EjbTimerServiceImpl(BeanContext deployment,
                             TimerStore timerStore)

• EjbTimerServiceImpl

  public EjbTimerServiceImpl(BeanContext deployment,
                             TransactionManager transactionManager,
                             TimerStore timerStore,
                             int retryAttempts)

Method Detail

• getDefaultTransactionManager

  public static TransactionManager getDefaultTransactionManager()

• getDefaultScheduler

  public static Scheduler getDefaultScheduler(BeanContext deployment)

• stop

  public void stop()

  Specified by:

  stop in interface EjbTimerService

• shutdown

  public static void shutdown()

• start

  public void start()
             throws TimerStoreException

  Specified by:

  start in interface EjbTimerService

  Throws:

  TimerStoreException

• getTransactionManager

  public TransactionManager getTransactionManager()

• schedule

  public void schedule(TimerData timerData)
                throws TimerStoreException

  Called from TimerData and start when a timer should be scheduled with the java.util.Timer.

  Parameters:

  timerData - the timer to schedule

  Throws:

  TimerStoreException

• cancelled

  public void cancelled(TimerData timerData)

  Call back from TimerData and ejbTimeout when a timer has been cancelled (or is complete) and should be removed from stores.

  Parameters:

  timerData - the timer that was cancelled

• addTimerData

  public void addTimerData(TimerData timerData)

  Returns a timerData to the TimerStore, if a cancel() is rolled back.

  Parameters:

  timerData - the timer to be returned to the timer store

• getTimer

  public Timer getTimer(long timerId)

  Specified by:

  getTimer in interface EjbTimerService

• getTimers

  public java.util.Collection<Timer> getTimers(java.lang.Object primaryKey)
                                        throws java.lang.IllegalStateException

  Specified by:

  getTimers in interface EjbTimerService

  Throws:

  java.lang.IllegalStateException

• createTimer

  public Timer createTimer(java.lang.Object primaryKey,
                           java.lang.reflect.Method timeoutMethod,
                           long duration,
                           TimerConfig timerConfig)
                    throws java.lang.IllegalArgumentException,
                           java.lang.IllegalStateException,
                           EJBException

  Specified by:

  createTimer in interface EjbTimerService

  Throws:

  java.lang.IllegalArgumentException

  java.lang.IllegalStateException

  EJBException

• createTimer

  public Timer createTimer(java.lang.Object primaryKey,
                           java.lang.reflect.Method timeoutMethod,
                           long initialDuration,
                           long intervalDuration,
                           TimerConfig timerConfig)
                    throws java.lang.IllegalArgumentException,
                           java.lang.IllegalStateException,
                           EJBException

  Specified by:

  createTimer in interface EjbTimerService

  Throws:

  java.lang.IllegalArgumentException

  java.lang.IllegalStateException

  EJBException

• createTimer

  public Timer createTimer(java.lang.Object primaryKey,
                           java.lang.reflect.Method timeoutMethod,
                           java.util.Date expiration,
                           TimerConfig timerConfig)
                    throws java.lang.IllegalArgumentException,
                           java.lang.IllegalStateException,
                           EJBException

  Specified by:

  createTimer in interface EjbTimerService

  Throws:

  java.lang.IllegalArgumentException

  java.lang.IllegalStateException

  EJBException

• createTimer

  public Timer createTimer(java.lang.Object primaryKey,
                           java.lang.reflect.Method timeoutMethod,
                           java.util.Date initialExpiration,
                           long intervalDuration,
                           TimerConfig timerConfig)
                    throws java.lang.IllegalArgumentException,
                           java.lang.IllegalStateException,
                           EJBException

  Specified by:

  createTimer in interface EjbTimerService

  Throws:

  java.lang.IllegalArgumentException

  java.lang.IllegalStateException

  EJBException

• createTimer

  public Timer createTimer(java.lang.Object primaryKey,
                           java.lang.reflect.Method timeoutMethod,
                           ScheduleExpression scheduleExpression,
                           TimerConfig timerConfig)

  Specified by:

  createTimer in interface EjbTimerService

• getTimerStore

  public TimerStore getTimerStore()

  Specified by:

  getTimerStore in interface EjbTimerService

• isStarted

  public boolean isStarted()

  Specified by:

  isStarted in interface EjbTimerService

• getScheduler

  public Scheduler getScheduler()

• ejbTimeout

  public void ejbTimeout(TimerData timerData)

  This method calls the ejbTimeout method and starts a transaction if the timeout is transacted. This method will retry failed ejbTimeout calls until retryAttempts is exceeded.

  Parameters:

  timerData - the timer to call.