Package org.ikasan.job.orchestration.rest.client

Class JobInitiationServiceImpl

java.lang.Object

org.ikasan.rest.client.ModuleRestService

org.ikasan.job.orchestration.rest.client.JobInitiationServiceImpl

All Implemented Interfaces:

org.ikasan.spec.scheduled.job.service.JobInitiationService

public class JobInitiationServiceImpl
extends org.ikasan.rest.client.ModuleRestService
implements org.ikasan.spec.scheduled.job.service.JobInitiationService

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FLOW_SCHEDULE_FIRE_NOW_URL
static final String	JOB_DRY_RUN_MODE_URL
static final String	SCHEDULER_JOB_INITIATION_URL

Fields inherited from class org.ikasan.rest.client.ModuleRestService

basicToken, MODULE_REST_PASSWORD_PROPERTY, MODULE_REST_USERNAME_PROPERTY, restTemplate

Constructor Summary

Constructors

Constructor	Description
JobInitiationServiceImpl(org.springframework.core.env.Environment environment, org.springframework.http.client.HttpComponentsClientHttpRequestFactory httpComponentsClientHttpRequestFactory, int fileJobSubmissionWaitTimeSeconds)

Method Summary

Modifier and Type	Method	Description
void	raiseFileEventSchedulerJob(String contextUrl, String agentName, org.ikasan.spec.scheduled.job.model.SchedulerJob job, String correlationId)
void	raiseQuartzSchedulerJob(String contextUrl, String agentName, org.ikasan.spec.scheduled.job.model.SchedulerJob job, String correlationId)
void	raiseSchedulerJobInitiationEvent(String contextUrl, org.ikasan.spec.scheduled.event.model.SchedulerJobInitiationEvent event)

Methods inherited from class org.ikasan.rest.client.ModuleRestService

createHttpHeaders

Methods inherited from class java.lang.Object

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

Field Details

SCHEDULER_JOB_INITIATION_URL

public static final String SCHEDULER_JOB_INITIATION_URL

See Also:

• Constant Field Values

FLOW_SCHEDULE_FIRE_NOW_URL

public static final String FLOW_SCHEDULE_FIRE_NOW_URL

See Also:

• Constant Field Values

JOB_DRY_RUN_MODE_URL

public static final String JOB_DRY_RUN_MODE_URL

See Also:

• Constant Field Values

Constructor Details

JobInitiationServiceImpl

public JobInitiationServiceImpl(org.springframework.core.env.Environment environment,
 org.springframework.http.client.HttpComponentsClientHttpRequestFactory httpComponentsClientHttpRequestFactory,
 int fileJobSubmissionWaitTimeSeconds)

Method Details

raiseSchedulerJobInitiationEvent

public void raiseSchedulerJobInitiationEvent(String contextUrl,
 org.ikasan.spec.scheduled.event.model.SchedulerJobInitiationEvent event)

Specified by:

raiseSchedulerJobInitiationEvent in interface org.ikasan.spec.scheduled.job.service.JobInitiationService

raiseQuartzSchedulerJob

public void raiseQuartzSchedulerJob(String contextUrl,
 String agentName,
 org.ikasan.spec.scheduled.job.model.SchedulerJob job,
 String correlationId)

Specified by:

raiseQuartzSchedulerJob in interface org.ikasan.spec.scheduled.job.service.JobInitiationService

raiseFileEventSchedulerJob

public void raiseFileEventSchedulerJob(String contextUrl,
 String agentName,
 org.ikasan.spec.scheduled.job.model.SchedulerJob job,
 String correlationId)

Specified by:

raiseFileEventSchedulerJob in interface org.ikasan.spec.scheduled.job.service.JobInitiationService