org.springframework.integration.scheduling.spi
Class SimpleScheduleServiceProvider

java.lang.Object
  org.springframework.integration.scheduling.spi.SimpleScheduleServiceProvider

All Implemented Interfaces:

ScheduleServiceProvider

public class SimpleScheduleServiceProvider
extends java.lang.Object
implements ScheduleServiceProvider

A ScheduleServiceProvider implementation using an underlying ScheduledExecutorService.

Author:

Marius Bogoevici

Field Summary

private java.util.concurrent.ScheduledExecutorService

executor

Constructor Summary

SimpleScheduleServiceProvider(java.util.concurrent.ScheduledExecutorService executor)

Method Summary

void	execute(java.lang.Runnable runnable)
java.util.concurrent.ScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable runnable, long initialDelay, long period, java.util.concurrent.TimeUnit timeUnit)
java.util.concurrent.ScheduledFuture<?>	scheduleWithCronExpression(java.lang.Runnable runnable, java.lang.String cronExpression)
java.util.concurrent.ScheduledFuture<?>	scheduleWithFixedDelay(java.lang.Runnable runnable, long initialDelay, long delay, java.util.concurrent.TimeUnit timeUnit)
java.util.concurrent.ScheduledFuture<?>	scheduleWithInitialDelay(java.lang.Runnable runnable, long initialDelay, java.util.concurrent.TimeUnit timeUnit)
void	shutdown(boolean waitForTasksToCompleteOnShutdown)

Methods inherited from class java.lang.Object

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

Field Detail

executor

private final java.util.concurrent.ScheduledExecutorService executor

Constructor Detail

SimpleScheduleServiceProvider

public SimpleScheduleServiceProvider(java.util.concurrent.ScheduledExecutorService executor)

Method Detail

execute

public void execute(java.lang.Runnable runnable)

Specified by:

execute in interface ScheduleServiceProvider

shutdown

public void shutdown(boolean waitForTasksToCompleteOnShutdown)

Specified by:

shutdown in interface ScheduleServiceProvider

scheduleWithInitialDelay

public java.util.concurrent.ScheduledFuture<?> scheduleWithInitialDelay(java.lang.Runnable runnable,
                                                                        long initialDelay,
                                                                        java.util.concurrent.TimeUnit timeUnit)

Specified by:

scheduleWithInitialDelay in interface ScheduleServiceProvider

scheduleAtFixedRate

public java.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable runnable,
                                                                   long initialDelay,
                                                                   long period,
                                                                   java.util.concurrent.TimeUnit timeUnit)

Specified by:

scheduleAtFixedRate in interface ScheduleServiceProvider

scheduleWithFixedDelay

public java.util.concurrent.ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable runnable,
                                                                      long initialDelay,
                                                                      long delay,
                                                                      java.util.concurrent.TimeUnit timeUnit)

Specified by:

scheduleWithFixedDelay in interface ScheduleServiceProvider

scheduleWithCronExpression

public java.util.concurrent.ScheduledFuture<?> scheduleWithCronExpression(java.lang.Runnable runnable,
                                                                          java.lang.String cronExpression)
                                                                   throws java.lang.Exception

Specified by:

scheduleWithCronExpression in interface ScheduleServiceProvider

Throws:

java.lang.Exception