Package org.frankframework.scheduler.job

Class SendMessageJob

java.lang.Object

org.frankframework.core.TransactionAttributes

org.frankframework.scheduler.AbstractJobDef

org.frankframework.scheduler.job.SendMessageJob

All Implemented Interfaces:

FrankElement, HasApplicationContext, HasName, HasTransactionAttribute, IConfigurable, IScopeProvider, NameAware, ConfigurableLifecycle, IJob, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

Direct Known Subclasses:

DatabaseJob

public class SendMessageJob
extends AbstractJobDef

Scheduled job to send messages to a FrankListener. Message may be null (or empty).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SendMessageJob.SendMessageJobSender	The sole purpose of this call is to prevent AOP wrapping around the sendMessage / sendMessageOrThrow methods.

Field Summary

Fields inherited from class org.frankframework.core.TransactionAttributes

log

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
SendMessageJob()

Method Summary

Modifier and Type	Method	Description
void	configure()	Configure this component.
void	execute()	Is wrapped around a Locker and exceptions will be managed automatically.
void	setJavaListener(String javaListener)	JavaListener to send the message to
void	setMessage(String message)	message to be sent into the pipeline

Methods inherited from class org.frankframework.scheduler.AbstractJobDef

beforeExecuteJob, decrementCountThreads, executeJob, getIbisManager, getJobDetail, getMessageKeeper, incrementCountThreads, isRunning, setCronExpression, setDescription, setInterval, setJobGroup, setLocker, setMessageKeeperSize, setName, setNumThreads, start, stop, toString

Methods inherited from class org.frankframework.core.TransactionAttributes

configureTransactionAttributes, isTransacted, isTransacted, setTransacted, setTransactionTimeout

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface org.frankframework.lifecycle.ConfigurableLifecycle

getPhase, isAutoStartup

Methods inherited from interface org.frankframework.core.HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface org.frankframework.core.HasTransactionAttribute

getTransactionAttribute, getTransactionTimeout, getTxDef, setTransactionAttribute

Methods inherited from interface org.frankframework.scheduler.job.IJob

getCronExpression, getInterval, getJobGroup, getLocker, getName, isConfigured

Methods inherited from interface org.springframework.context.SmartLifecycle

stop

Constructor Details

SendMessageJob

public SendMessageJob()

Method Details

configure

public void configure()
               throws ConfigurationException

Description copied from interface: IConfigurable

Configure this component.

configure() is called once at startup of the framework in the configure method of the owner of this IConfigurable. Purpose of this method is to check whether the static configuration of the object is correct. As much as possible class-instantiating should take place in the configure(), to improve performance.

In the case of a container, this will propagate the configure signal to all components that apply.

Specified by:

configure in interface IConfigurable

Overrides:

configure in class AbstractJobDef

Throws:

ConfigurationException - in case it was not able to configure the component.

execute

public void execute()
             throws JobExecutionException,
TimeoutException

Description copied from class: AbstractJobDef

Is wrapped around a Locker and exceptions will be managed automatically.

Specified by:

execute in class AbstractJobDef

Throws:

JobExecutionException - when the implementation fails to execute

TimeoutException - when the TransactionTimeout has been reached

setJavaListener

@Mandatory
public void setJavaListener(String javaListener)

JavaListener to send the message to

setMessage

@Optional
public void setMessage(String message)

message to be sent into the pipeline