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

Class PurgeObsoleteSandboxDataListener

java.lang.Object

com.broadleafcommerce.data.tracking.core.messaging.PurgeObsoleteSandboxDataListener

public class PurgeObsoleteSandboxDataListener
extends Object

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

Author:

Samarth Dhruva (samarthd)

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PURGE_OBSOLETE_SANDBOX_DATA_JOBTYPE

Constructor Summary

Constructors

Constructor	Description
PurgeObsoleteSandboxDataListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, PurgeObsoleteSandboxDataHandler 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 PurgeObsoleteSandboxDataHandler	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	purge(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

PURGE_OBSOLETE_SANDBOX_DATA_JOBTYPE

public static final String PURGE_OBSOLETE_SANDBOX_DATA_JOBTYPE

See Also:

• Constant Field Values

Constructor Details

PurgeObsoleteSandboxDataListener

public PurgeObsoleteSandboxDataListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService,
 @NonNull
 PurgeObsoleteSandboxDataHandler handler,
 @Nullable
 com.broadleafcommerce.common.extension.data.DataRouteReference reference)

Method Details

listen

@StreamListener("triggeredJobEventInputPurgeSandbox")
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

purge

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

getIdempotentConsumptionService

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

getHandler

@NonNull
protected PurgeObsoleteSandboxDataHandler getHandler()

getReference

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