Class CatalogBulkOperationHandler
java.lang.Object
com.broadleafcommerce.catalog.messaging.bulkoperation.CatalogBulkOperationHandler
Listens for the bulk operation processing message from the bulk operations service.
- Since:
- 2.1.0-GA
-
Constructor Summary
ConstructorDescriptionCatalogBulkOperationHandler
(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, List<BulkUpdateProcessor> bulkUpdateProcessors, BulkOperationService<BulkOperation> bulkOperationService, com.broadleafcommerce.common.messaging.notification.DetachedDurableMessageSender sender) -
Method Summary
Modifier and TypeMethodDescriptionprotected BulkOperationService<BulkOperation>
protected List<BulkUpdateProcessor>
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService
protected com.broadleafcommerce.common.messaging.notification.DetachedDurableMessageSender
void
listen
(org.springframework.messaging.Message<com.broadleafcommerce.bulk.v2.messaging.BulkOpsProcessRequest> message) protected void
processMessage
(@NonNull org.springframework.messaging.Message<com.broadleafcommerce.bulk.v2.messaging.BulkOpsProcessRequest> message)
-
Constructor Details
-
CatalogBulkOperationHandler
public CatalogBulkOperationHandler(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, List<BulkUpdateProcessor> bulkUpdateProcessors, BulkOperationService<BulkOperation> bulkOperationService, com.broadleafcommerce.common.messaging.notification.DetachedDurableMessageSender sender)
-
-
Method Details
-
listen
@StreamListener("processBulkOperationRequestInput") public void listen(org.springframework.messaging.Message<com.broadleafcommerce.bulk.v2.messaging.BulkOpsProcessRequest> message) -
processMessage
protected void processMessage(@NonNull @NonNull org.springframework.messaging.Message<com.broadleafcommerce.bulk.v2.messaging.BulkOpsProcessRequest> message) -
getIdempotentConsumptionService
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService getIdempotentConsumptionService() -
getBulkUpdateProcessors
-
getBulkOperationService
-
getSender
protected com.broadleafcommerce.common.messaging.notification.DetachedDurableMessageSender getSender()
-