Package com.broadleafcommerce.scheduledjob.messaging.transition

Class ScheduledJobStartedEventListener

java.lang.Object

com.broadleafcommerce.scheduledjob.messaging.transition.ScheduledJobStartedEventListener

@DataRouteByKey("scheduledJob")
public class ScheduledJobStartedEventListener
extends Object

Listener to record a ScheduledJobStartedEvent to track the execution details of a scheduled job

Since:

Scheduled Job Service 2.1.4, Release Train 2.1.4, Scheduled Job Service 2.2.0, Release Train 2.2.0

Constructor Summary

Constructors

Constructor	Description
ScheduledJobStartedEventListener(ScheduledJobExecutionDetailService<ScheduledJobExecutionDetail> scheduledJobExecutionDetailService, com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentService)

Method Summary

Modifier and Type	Method	Description
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentService()
protected ScheduledJobExecutionDetailService<ScheduledJobExecutionDetail>	getScheduledJobExecutionDetailService()
void	listen(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobStartedEvent> message)
protected void	process(@NonNull org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobStartedEvent> message)	Consumes a ScheduledJobStartedEvent and updates the start-time and note of the ScheduledJobExecutionDetail

Methods inherited from class java.lang.Object

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

Constructor Details

ScheduledJobStartedEventListener

public ScheduledJobStartedEventListener(ScheduledJobExecutionDetailService<ScheduledJobExecutionDetail> scheduledJobExecutionDetailService,
 com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentService)

Method Details

listen

@StreamListener("scheduledJobStartedInputScheduledJob")
public void listen(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobStartedEvent> message)

process

protected void process(@NonNull
 @NonNull org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobStartedEvent> message)

Consumes a ScheduledJobStartedEvent and updates the start-time and note of the ScheduledJobExecutionDetail

Parameters:

message - the ScheduledJobStartedEvent message

getScheduledJobExecutionDetailService

protected ScheduledJobExecutionDetailService<ScheduledJobExecutionDetail> getScheduledJobExecutionDetailService()

getIdempotentService

protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService getIdempotentService()