Package com.broadleafcommerce.datafeed.messaging.listener

Class IncrementalDataFeedEntityUpdateEventListener

java.lang.Object
com.broadleafcommerce.datafeed.messaging.listener.IncrementalDataFeedEntityUpdateEventListener
@DataRouteByKey("datafeed") public class IncrementalDataFeedEntityUpdateEventListener extends Object
Receives IncrementalDataFeedEntityUpdateEvent on the message consumer channel.

  • Constructor Details

    • IncrementalDataFeedEntityUpdateEventListener

      public IncrementalDataFeedEntityUpdateEventListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, IncrementalDataFeedEntityUpdateManager incrementalDataFeedEntityUpdateManager)

  • Method Details

    • listen

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

    • processMessage

      protected void processMessage(org.springframework.messaging.Message<IncrementalDataFeedEntityUpdateEvent> message)

    • getIdempotentConsumptionService

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

    • getIncrementalDataFeedEntityUpdateManager

      protected IncrementalDataFeedEntityUpdateManager getIncrementalDataFeedEntityUpdateManager()