org.springframework.integration.scheduling
Class SimpleMessagingTaskScheduler

java.lang.Object
  org.springframework.integration.scheduling.AbstractMessagingTaskScheduler
      org.springframework.integration.scheduling.SimpleMessagingTaskScheduler

All Implemented Interfaces:

org.springframework.context.Lifecycle, org.springframework.core.task.TaskExecutor, MessagingTaskScheduler, org.springframework.scheduling.SchedulingTaskExecutor

public class SimpleMessagingTaskScheduler
extends AbstractMessagingTaskScheduler

An implementation of MessagingTaskScheduler that understands PollingSchedules.

Author:

Mark Fisher

Nested Class Summary

private class

SimpleMessagingTaskScheduler.MessagingTaskRunner

Field Summary

private ErrorHandler	errorHandler
private java.util.concurrent.ScheduledExecutorService	executor
private java.lang.Object	lifecycleMonitor
private org.apache.commons.logging.Log	logger
private java.util.Set<java.lang.Runnable>	pendingTasks
private boolean	running

Constructor Summary

SimpleMessagingTaskScheduler(java.util.concurrent.ScheduledExecutorService executor)

Method Summary

boolean	isRunning()
java.util.concurrent.ScheduledFuture<?>	schedule(java.lang.Runnable task)
void	setErrorHandler(ErrorHandler errorHandler)
void	start()
void	stop()

Methods inherited from class org.springframework.integration.scheduling.AbstractMessagingTaskScheduler

execute, prefersShortLivedTasks

Methods inherited from class java.lang.Object

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

Field Detail

logger

private final org.apache.commons.logging.Log logger

executor

private final java.util.concurrent.ScheduledExecutorService executor

errorHandler

private volatile ErrorHandler errorHandler

pendingTasks

private final java.util.Set<java.lang.Runnable> pendingTasks

running

private volatile boolean running

lifecycleMonitor

private final java.lang.Object lifecycleMonitor

Constructor Detail

SimpleMessagingTaskScheduler

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

Method Detail

setErrorHandler

public void setErrorHandler(ErrorHandler errorHandler)

isRunning

public boolean isRunning()

start

public void start()

stop

public void stop()

schedule

public java.util.concurrent.ScheduledFuture<?> schedule(java.lang.Runnable task)

Specified by:

schedule in interface MessagingTaskScheduler

Specified by:

schedule in class AbstractMessagingTaskScheduler