org.springframework.batch.integration.job
Class MessageOrientedStep

java.lang.Object
  org.springframework.batch.core.step.AbstractStep
      org.springframework.batch.integration.job.MessageOrientedStep

All Implemented Interfaces:

Step, BeanNameAware, InitializingBean

public class MessageOrientedStep
extends AbstractStep

Author:

Dave Syer

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.batch.core.step.AbstractStep

AbstractStep.FatalException

Field Summary

static String

WAITING Key in execution context for flag to say we are waiting.

Fields inherited from class org.springframework.batch.core.step.AbstractStep

JOB_INTERRUPTED

Constructor Summary

MessageOrientedStep()

Method Summary

protected void	close(ExecutionContext ctx) Do nothing.
ExitStatus	doExecute(StepExecution stepExecution)
protected void	open(ExecutionContext ctx) Do nothing.
void	setExecutionTimeout(long executionTimeout) Public setter for the execution timeout in milliseconds.
void	setExecutionTimeoutMinutes(int executionTimeoutMinutes) Public setter for the execution timeout in minutes.
void	setPollingInterval(long pollingInterval) Public setter for the polling interval in milliseconds while waiting for replies signalling the end of the step.
void	setReplyChannel(org.springframework.integration.channel.MessageChannel replyChannel) Public setter for the replyChannel.
void	setRequestChannel(org.springframework.integration.channel.MessageChannel requestChannel) Public setter for the requestChannel.

Methods inherited from class org.springframework.batch.core.step.AbstractStep

afterPropertiesSet, execute, getCompositeListener, getJobRepository, getName, getStartLimit, isAllowStartIfComplete, registerStepExecutionListener, setAllowStartIfComplete, setBeanName, setJobRepository, setName, setStartLimit, setStepExecutionListeners

Methods inherited from class java.lang.Object

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

Field Detail

WAITING

public static final String WAITING

Key in execution context for flag to say we are waiting.

Constructor Detail

MessageOrientedStep

public MessageOrientedStep()

Method Detail

setExecutionTimeoutMinutes

public void setExecutionTimeoutMinutes(int executionTimeoutMinutes)

Public setter for the execution timeout in minutes. Defaults to 30.

Parameters:

executionTimeoutMinutes - the timeout to set

setExecutionTimeout

public void setExecutionTimeout(long executionTimeout)

Public setter for the execution timeout in milliseconds. Defaults to 30 minutes.

Parameters:

executionTimeout -

setPollingInterval

public void setPollingInterval(long pollingInterval)

Public setter for the polling interval in milliseconds while waiting for replies signalling the end of the step. Defaults to 5.

Parameters:

pollingInterval - the polling interval to set

setRequestChannel

public void setRequestChannel(org.springframework.integration.channel.MessageChannel requestChannel)

Public setter for the requestChannel.

Parameters:

requestChannel - the requestChannel to set

setReplyChannel

public void setReplyChannel(org.springframework.integration.channel.MessageChannel replyChannel)

Public setter for the replyChannel.

Parameters:

replyChannel - the replyChannel to set

doExecute

public ExitStatus doExecute(StepExecution stepExecution)
                     throws JobInterruptedException,
                            UnexpectedJobExecutionException

Specified by:

doExecute in class AbstractStep

Throws:

JobInterruptedException

UnexpectedJobExecutionException

open

protected void open(ExecutionContext ctx)
             throws Exception

Do nothing.

Specified by:

open in class AbstractStep

Throws:

Exception

See Also:

AbstractStep.open(org.springframework.batch.item.ExecutionContext)

close

protected void close(ExecutionContext ctx)
              throws Exception

Do nothing.

Specified by:

close in class AbstractStep

Throws:

Exception

See Also:

AbstractStep.close(org.springframework.batch.item.ExecutionContext)