Package com.broadleafcommerce.bulkoperations.messaging

Class InitializeBulkOperationItemsListener<CI extends CatalogItem>

java.lang.Object

com.broadleafcommerce.bulkoperations.messaging.InitializeBulkOperationItemsListener<CI>

@DataRouteByKey("bulkoperations")
public class InitializeBulkOperationItemsListener<CI extends CatalogItem>
extends Object

A listener that accepts a BulkOpsInitializeItemsRequest in order to initialize bulk operation items.

Constructor Summary

Constructors

Constructor

Description

InitializeBulkOperationItemsListener(InitializeBulkOperationItemsProperties initializeBulkOperationItemsProperties, CatalogProvider<CI> catalogProvider, SearchProvider<CI> searchProvider, com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, com.broadleafcommerce.common.messaging.notification.DetachedDurableMessageSender sender, com.broadleafcommerce.bulk.v2.messaging.BulkOpsProcessRequestProducer processRequestProducer, BulkOperationsProviderProperties bulkOperationsProviderProperties, com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Summary

Modifier and Type	Method	Description
protected BulkOperationsProviderProperties	getBulkOperationsProviderProperties()
protected CatalogProvider<CI>	getCatalogProvider()
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentConsumptionService()
protected InitializeBulkOperationItemsProperties	getInitializeBulkOperationItemsProperties()
protected com.broadleafcommerce.bulk.v2.messaging.BulkOpsProcessRequestProducer	getProcessRequestProducer()
protected SearchProvider<CI>	getSearchProvider()
protected com.broadleafcommerce.common.messaging.notification.DetachedDurableMessageSender	getSender()
protected com.broadleafcommerce.common.extension.TypeFactory	getTypeFactory()
void	listen(org.springframework.messaging.Message<com.broadleafcommerce.bulk.v2.messaging.BulkOpsInitializeItemsRequest> message)
protected void	processMessage(@NonNull org.springframework.messaging.Message<com.broadleafcommerce.bulk.v2.messaging.BulkOpsInitializeItemsRequest> message)
protected void	sendProcessBulkOperationRequest(@NonNull com.broadleafcommerce.bulk.v2.messaging.BulkOpsInitializeItemsRequest request)

Methods inherited from class java.lang.Object

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

Constructor Details

InitializeBulkOperationItemsListener

public InitializeBulkOperationItemsListener(InitializeBulkOperationItemsProperties initializeBulkOperationItemsProperties,
 CatalogProvider<CI> catalogProvider,
 SearchProvider<CI> searchProvider,
 com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService,
 com.broadleafcommerce.common.messaging.notification.DetachedDurableMessageSender sender,
 com.broadleafcommerce.bulk.v2.messaging.BulkOpsProcessRequestProducer processRequestProducer,
 BulkOperationsProviderProperties bulkOperationsProviderProperties,
 com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Details

listen

@StreamListener("initializeItemsRequestInput")
public void listen(org.springframework.messaging.Message<com.broadleafcommerce.bulk.v2.messaging.BulkOpsInitializeItemsRequest> message)

processMessage

protected void processMessage(@NonNull
 @NonNull org.springframework.messaging.Message<com.broadleafcommerce.bulk.v2.messaging.BulkOpsInitializeItemsRequest> message)

sendProcessBulkOperationRequest

protected void sendProcessBulkOperationRequest(@NonNull
 @NonNull com.broadleafcommerce.bulk.v2.messaging.BulkOpsInitializeItemsRequest request)

getInitializeBulkOperationItemsProperties

protected InitializeBulkOperationItemsProperties getInitializeBulkOperationItemsProperties()

getCatalogProvider

protected CatalogProvider<CI> getCatalogProvider()

getSearchProvider

protected SearchProvider<CI> getSearchProvider()

getIdempotentConsumptionService

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

getSender

protected com.broadleafcommerce.common.messaging.notification.DetachedDurableMessageSender getSender()

getProcessRequestProducer

protected com.broadleafcommerce.bulk.v2.messaging.BulkOpsProcessRequestProducer getProcessRequestProducer()

getBulkOperationsProviderProperties

protected BulkOperationsProviderProperties getBulkOperationsProviderProperties()

getTypeFactory

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