org.ikasan.component.endpoint.rulecheck.broker

Class ScheduledRuleCheckBroker<EVENT>

java.lang.Object

org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker<EVENT>

Type Parameters:

EVENT -

All Implemented Interfaces:

Broker<EVENT,EVENT>, Configured<RuleCheckConfiguration>, ConfiguredResource<RuleCheckConfiguration>, ManagedResource, org.quartz.Job

Direct Known Subclasses:

ErrorReportingAwareScheduledRuleCheckBroker

public class ScheduledRuleCheckBroker<EVENT>
extends Object
implements Broker<EVENT,EVENT>, ManagedResource, ConfiguredResource<RuleCheckConfiguration>, org.quartz.Job

Simple scheduled rule invoker.

Author:

Ikasan Development Team

Field Summary

Fields

Modifier and Type	Field and Description
protected ManagedResourceRecoveryManager	managedResourceRecoveryManager Recovery manager for this Managed Resource and any extending implementations of it

Constructor Summary

Constructors

Constructor and Description
ScheduledRuleCheckBroker(org.quartz.Scheduler scheduler, Rule rule) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
void	execute(org.quartz.JobExecutionContext jobExecutionContext)
RuleCheckConfiguration	getConfiguration()
String	getConfiguredResourceId()
protected org.quartz.Trigger	getCronTrigger(org.quartz.JobKey jobkey, String cronExpression) Method factory for creating a cron trigger
EVENT	invoke(EVENT event)
boolean	isCriticalOnStartup()
void	setConfiguration(RuleCheckConfiguration configuration)
void	setConfiguredResourceId(String configuredResourceId)
void	setCriticalOnStartup(boolean criticalOnStartup)
void	setJobDetail(org.quartz.JobDetail jobDetail)
void	setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)
void	startManagedResource() Start the scheduled job and triggers
void	stopManagedResource() Stop the scheduled job and triggers

Methods inherited from class java.lang.Object

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

Field Detail

managedResourceRecoveryManager

protected ManagedResourceRecoveryManager managedResourceRecoveryManager

Recovery manager for this Managed Resource and any extending implementations of it

Constructor Detail

ScheduledRuleCheckBroker

public ScheduledRuleCheckBroker(org.quartz.Scheduler scheduler,
                        Rule rule)

Constructor

Parameters:

scheduler -

Method Detail

invoke

public EVENT invoke(EVENT event)
             throws EndpointException

Specified by:

invoke in interface Broker<EVENT,EVENT>

Throws:

EndpointException

startManagedResource

public void startManagedResource()

Start the scheduled job and triggers

Specified by:

startManagedResource in interface ManagedResource

stopManagedResource

public void stopManagedResource()

Stop the scheduled job and triggers

Specified by:

stopManagedResource in interface ManagedResource

setManagedResourceRecoveryManager

public void setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)

Specified by:

setManagedResourceRecoveryManager in interface ManagedResource

isCriticalOnStartup

public boolean isCriticalOnStartup()

Specified by:

isCriticalOnStartup in interface ManagedResource

setCriticalOnStartup

public void setCriticalOnStartup(boolean criticalOnStartup)

Specified by:

setCriticalOnStartup in interface ManagedResource

getCronTrigger

protected org.quartz.Trigger getCronTrigger(org.quartz.JobKey jobkey,
                                String cronExpression)
                                     throws ParseException

Method factory for creating a cron trigger

Returns:

jobDetail

Throws:

ParseException

getConfiguredResourceId

public String getConfiguredResourceId()

Specified by:

getConfiguredResourceId in interface ConfiguredResource<RuleCheckConfiguration>

setConfiguredResourceId

public void setConfiguredResourceId(String configuredResourceId)

Specified by:

setConfiguredResourceId in interface ConfiguredResource<RuleCheckConfiguration>

getConfiguration

public RuleCheckConfiguration getConfiguration()

Specified by:

getConfiguration in interface Configured<RuleCheckConfiguration>

setConfiguration

public void setConfiguration(RuleCheckConfiguration configuration)

Specified by:

setConfiguration in interface Configured<RuleCheckConfiguration>

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)
             throws org.quartz.JobExecutionException

Specified by:

execute in interface org.quartz.Job

Throws:

org.quartz.JobExecutionException

setJobDetail

public void setJobDetail(org.quartz.JobDetail jobDetail)