Package com.broadleafcommerce.data.tracking.core.messaging

Class PruneRestingNotificationStatesListener

java.lang.Object

com.broadleafcommerce.data.tracking.core.messaging.PruneRestingNotificationStatesListener

public class PruneRestingNotificationStatesListener
extends Object

A listener that accepts triggered scheduled job events of type PRUNE_RESTING_NOTIFICATION_STATES_JOBTYPE and delegates to PruneRestingNotificationStatesHandler to perform the appropriate behavior.

Author:

Samarth Dhruva (samarthd)

Field Summary

Fields

Modifier and Type	Field	Description
static String	PRUNE_RESTING_NOTIFICATION_STATES_JOBTYPE

Constructor Summary

Constructors

Constructor	Description
PruneRestingNotificationStatesListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, PruneRestingNotificationStatesHandler handler, com.broadleafcommerce.common.extension.data.DataRouteReference reference)

Method Summary

Modifier and Type	Method	Description
protected List<com.broadleafcommerce.common.extension.data.DataRouteSupporting>	findTrackingSupportingRoutes()	Identifies all data routes that support tracking domain
protected PruneRestingNotificationStatesHandler	getHandler()
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentConsumptionService()
protected com.broadleafcommerce.common.extension.data.DataRouteReference	getReference()
void	listen(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)
protected void	prune(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 Detail

PRUNE_RESTING_NOTIFICATION_STATES_JOBTYPE

public static final String PRUNE_RESTING_NOTIFICATION_STATES_JOBTYPE

See Also:

Constant Field Values

Constructor Detail

PruneRestingNotificationStatesListener

public PruneRestingNotificationStatesListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService,
                                              PruneRestingNotificationStatesHandler handler,
                                              @Nullable
                                              com.broadleafcommerce.common.extension.data.DataRouteReference reference)

Method Detail

listen

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

findTrackingSupportingRoutes

protected List<com.broadleafcommerce.common.extension.data.DataRouteSupporting> findTrackingSupportingRoutes()

Identifies all data routes that support tracking domain

Returns:

all data routes that support tracking domain

prune

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

getIdempotentConsumptionService

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

getHandler

protected PruneRestingNotificationStatesHandler getHandler()

getReference

@Nullable
protected com.broadleafcommerce.common.extension.data.DataRouteReference getReference()