Package com.broadleafcommerce.asset.messaging

Class ProcessAssetsListener

java.lang.Object

com.broadleafcommerce.asset.messaging.ProcessAssetsListener

public class ProcessAssetsListener
extends Object

A listener that accepts triggered scheduled job events of type JOB_TYPE and updates the attributes of all assets in the data store.

Author:

Jon Fleschler (jfleschler)

Field Summary

Fields

Modifier and Type	Field	Description
protected final AssetStorageUtils	assetStorageUtils
static final String	JOB_TYPE
protected final StorageProvider	storageProvider
protected final StorageService	storageService

Constructor Summary

Constructors

Constructor	Description
ProcessAssetsListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, AssetService<Asset> assetService, StorageProvider storageProvider, StorageService storageService, List<AssetDataRouteSupporting> routes)

Method Summary

Modifier and Type	Method	Description
protected com.broadleafcommerce.data.tracking.core.context.ContextInfo	buildContextInfo(String applicationId, String tenantId)
protected com.broadleafcommerce.data.tracking.core.context.ContextInfo	buildContextInfoForAsset(Asset asset)
protected AssetService<Asset>	getAssetService()
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentConsumptionService()
protected int	getPageSize(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef scheduledJobRef)
protected List<AssetDataRouteSupporting>	getRoutes()
protected StorageProvider	getStorageProvider()
protected StorageService	getStorageService()
protected void	handleMessage(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)
void	listen(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)	Queries the data store for all assets and updates their attributes.

Methods inherited from class java.lang.Object

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

Field Details

JOB_TYPE

public static final String JOB_TYPE

See Also:

• Constant Field Values

storageProvider

protected final StorageProvider storageProvider

storageService

protected final StorageService storageService

assetStorageUtils

protected final AssetStorageUtils assetStorageUtils

Constructor Details

ProcessAssetsListener

public ProcessAssetsListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService,
 AssetService<Asset> assetService,
 StorageProvider storageProvider,
 StorageService storageService,
 List<AssetDataRouteSupporting> routes)

Method Details

listen

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

Queries the data store for all assets and updates their attributes.

Parameters:

message - a scheduled job trigger event - will only be handled if it has type JOB_TYPE

handleMessage

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

getPageSize

protected int getPageSize(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef scheduledJobRef)

buildContextInfoForAsset

protected com.broadleafcommerce.data.tracking.core.context.ContextInfo buildContextInfoForAsset(Asset asset)

buildContextInfo

protected com.broadleafcommerce.data.tracking.core.context.ContextInfo buildContextInfo(String applicationId,
 String tenantId)

getIdempotentConsumptionService

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

getAssetService

protected AssetService<Asset> getAssetService()

getStorageProvider

protected StorageProvider getStorageProvider()

getStorageService

protected StorageService getStorageService()

getRoutes

@NonNull
protected List<AssetDataRouteSupporting> getRoutes()