org.springframework.integration.scheduling
Class SimpleMessagingTaskScheduler

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

All Implemented Interfaces:

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

public class SimpleMessagingTaskScheduler
extends AbstractMessagingTaskScheduler
implements org.springframework.beans.factory.InitializingBean

An implementation of MessagingTaskScheduler that understands PollingSchedules.

Author:

Mark Fisher

Constructor Summary

SimpleMessagingTaskScheduler()

Method Summary

void	afterPropertiesSet()
boolean	isRunning()
java.util.concurrent.ScheduledFuture<?>	schedule(java.lang.Runnable task)
void	setCorePoolSize(int corePoolSize)
void	setErrorHandler(ErrorHandler errorHandler)
void	setExecutor(java.util.concurrent.ScheduledExecutorService executor)
void	setThreadFactory(java.util.concurrent.ThreadFactory threadFactory)
void	setThreadNamePrefix(java.lang.String threadNamePrefix)
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

Constructor Detail

SimpleMessagingTaskScheduler

public SimpleMessagingTaskScheduler()

Method Detail

setExecutor

public void setExecutor(java.util.concurrent.ScheduledExecutorService executor)

setCorePoolSize

public void setCorePoolSize(int corePoolSize)

setThreadFactory

public void setThreadFactory(java.util.concurrent.ThreadFactory threadFactory)

setThreadNamePrefix

public void setThreadNamePrefix(java.lang.String threadNamePrefix)

setErrorHandler

public void setErrorHandler(ErrorHandler errorHandler)

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

schedule

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

Specified by:

schedule in interface MessagingTaskScheduler

Specified by:

schedule in class AbstractMessagingTaskScheduler