Package com.broadleafcommerce.dataimport.messaging

Class ProcessImportRequestListener

java.lang.Object
com.broadleafcommerce.dataimport.messaging.ProcessImportRequestListener
@DataRouteByKey("import") public class ProcessImportRequestListener extends Object
Receives the process import event on the message channel to start the import
Author:
Phillip Verheyden (phillipuniverse)

  • Constructor Details

    • ProcessImportRequestListener

      public ProcessImportRequestListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, ImportManager manager)

  • Method Details

    • listen

      @StreamListener("processImportRequestInput") public void listen(org.springframework.messaging.Message<ProcessImportRequest> message)

    • startImport

      protected void startImport(org.springframework.messaging.Message<ProcessImportRequest> processImportRequest)

    • getIdempotentConsumptionService

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

    • getManager

      protected ImportManager getManager()