Package com.broadleafcommerce.scheduledjob.messaging.transition

Class ScheduledJobCompletedEventListener

java.lang.Object

com.broadleafcommerce.scheduledjob.messaging.transition.ScheduledJobCompletedEventListener

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

Listener to record a ScheduledJobCompletedEvent 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

Author:

karanjariwala

Constructor Summary

Constructors

Constructor	Description
ScheduledJobCompletedEventListener(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.ScheduledJobCompletedEvent> message)
protected void	process(@NonNull org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobCompletedEvent> message)	Consumes a ScheduledJobCompletedEvent and updates the end-time and note/error of the ScheduledJobExecutionDetail

Methods inherited from class java.lang.Object

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

Constructor Details

ScheduledJobCompletedEventListener

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

Method Details

listen

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

process

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

Consumes a ScheduledJobCompletedEvent and updates the end-time and note/error of the ScheduledJobExecutionDetail

Parameters:

message - the ScheduledJobCompletedEvent message

getScheduledJobExecutionDetailService

protected ScheduledJobExecutionDetailService<ScheduledJobExecutionDetail> getScheduledJobExecutionDetailService()

getIdempotentService

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