Class CatalogBulkOperationHandler

java.lang.Object
com.broadleafcommerce.catalog.messaging.bulkoperation.CatalogBulkOperationHandler

@DataRouteByKey("catalog") public class CatalogBulkOperationHandler extends Object
Listens for the bulk operation processing message from the bulk operations service.
Since:
2.1.0-GA
  • 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

      protected List<BulkUpdateProcessor> getBulkUpdateProcessors()
    • getBulkOperationService

      protected BulkOperationService<BulkOperation> getBulkOperationService()
    • getSender

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