com.broadleafcommerce.jobsevents.service

Class DurableConsumeWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.DurableConsumeWorkerImpl

All Implemented Interfaces:

ConsumeWorker

@Service(value="blDurableConsumeWorker")
public class DurableConsumeWorkerImpl
extends AbstractConsumerWorker

Responsible for retrieving and initiating processing of SystemEvent instances for this node. This worker specifically deals with GLOBAL_DURABLE event type.

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field and Description
protected DatabaseSystemEventNode	eventNode
protected DurableEventStatusService	statusService
protected DatabaseSystemEventDao	systemEventDao
protected org.springframework.transaction.PlatformTransactionManager	transactionManager
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil

Constructor Summary

Constructors

Constructor and Description
DurableConsumeWorkerImpl()

Method Summary

Modifier and Type	Method and Description
void	execute(org.quartz.JobExecutionContext jobExecutionContext)
void	init()

Methods inherited from class com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

populateSystemEvents

Methods inherited from class java.lang.Object

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

Field Detail

eventNode

protected DatabaseSystemEventNode eventNode

transUtil

protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil transUtil

transactionManager

protected org.springframework.transaction.PlatformTransactionManager transactionManager

systemEventDao

protected DatabaseSystemEventDao systemEventDao

statusService

protected DurableEventStatusService statusService

Constructor Detail

DurableConsumeWorkerImpl

public DurableConsumeWorkerImpl()

Method Detail

init

@PostConstruct
public void init()

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)