Package com.broadleafcommerce.datafeed.messaging.listener

Class DataFeedExecutionRequestScheduledJobListener

java.lang.Object

com.broadleafcommerce.datafeed.messaging.listener.DataFeedExecutionRequestScheduledJobListener

@DataRouteByKey("datafeed")
public class DataFeedExecutionRequestScheduledJobListener
extends Object

A listener that accepts triggered scheduled job events of type DATA_FEED_EXECUTION_REQUEST_JOBTYPE.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DATA_FEED_EXECUTION_REQUEST_JOBTYPE	The scheduled job must have this as its ScheduledJobRef.getType() in order to be handled by this listener.
static final String	DATA_FEED_PROCESS_ID_SCHEDULED_JOB_DETAIL_NAME	ScheduledJobRef.getDetails() must contain an entry with this as the ScheduledJobDetailRef.getName(), and must provide an appropriate DataFeedProcess.getId() as its value.

Constructor Summary

Constructors

Constructor	Description
DataFeedExecutionRequestScheduledJobListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, DataFeedProcessExecutionManager dataFeedProcessExecutionManager, com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Summary

Modifier and Type	Method	Description
protected DataFeedProcessExecutionManager	getDataFeedProcessExecutionManager()
protected Optional<String>	getDataFeedProcessId(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef scheduledJobRef)	Gets the data feed process ID whose execution is requested.
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentConsumptionService()
protected com.broadleafcommerce.common.extension.TypeFactory	getTypeFactory()
void	listen(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)
protected void	processMessage(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)

Methods inherited from class java.lang.Object

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

Field Details

DATA_FEED_EXECUTION_REQUEST_JOBTYPE

public static final String DATA_FEED_EXECUTION_REQUEST_JOBTYPE

The scheduled job must have this as its ScheduledJobRef.getType() in order to be handled by this listener.

See Also:

• Constant Field Values

DATA_FEED_PROCESS_ID_SCHEDULED_JOB_DETAIL_NAME

public static final String DATA_FEED_PROCESS_ID_SCHEDULED_JOB_DETAIL_NAME

ScheduledJobRef.getDetails() must contain an entry with this as the ScheduledJobDetailRef.getName(), and must provide an appropriate DataFeedProcess.getId() as its value.

See Also:

• Constant Field Values

Constructor Details

DataFeedExecutionRequestScheduledJobListener

public DataFeedExecutionRequestScheduledJobListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService,
 DataFeedProcessExecutionManager dataFeedProcessExecutionManager,
 com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Details

listen

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

processMessage

protected void processMessage(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)

getDataFeedProcessId

protected Optional<String> getDataFeedProcessId(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef scheduledJobRef)

Gets the data feed process ID whose execution is requested.

Parameters:

scheduledJobRef - the scheduled job payload

Returns:

the data feed process ID whose execution is requested, if found

getIdempotentConsumptionService

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

getDataFeedProcessExecutionManager

protected DataFeedProcessExecutionManager getDataFeedProcessExecutionManager()

getTypeFactory

protected com.broadleafcommerce.common.extension.TypeFactory getTypeFactory()