Package com.broadleafcommerce.sandbox.messaging.job

Class DefaultTriggeredSandboxJobEventListener

java.lang.Object
com.broadleafcommerce.sandbox.messaging.job.DefaultTriggeredSandboxJobEventListener
All Implemented Interfaces:
TriggeredSandboxJobEventListener
@DataRouteByKey("sandbox") public class DefaultTriggeredSandboxJobEventListener extends Object implements TriggeredSandboxJobEventListener
Author:
Chad Harchar (charchar), Nathan Moore (nathandmoore)

  • Field Details

  • Constructor Details

    • DefaultTriggeredSandboxJobEventListener

      public DefaultTriggeredSandboxJobEventListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, List<TriggeredSandboxJobEventHandler> triggeredJobEventHandlers)

  • Method Details

    • handle

      @StreamListener("triggeredJobEventInputDeploy") public void handle(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)
      Description copied from interface: TriggeredSandboxJobEventListener
      Responsible for executing actions in response to a scheduled job such as kicking off a new WorkflowDeployRequest.
      Specified by:
      handle in interface TriggeredSandboxJobEventListener
      Parameters:
      message - a ScheduledJobRef message received over the TriggeredJobEvent input channel

    • handleMessage

      protected void handleMessage(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)

    • getIdempotentConsumptionService

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

    • getTriggeredJobEventHandlers

      protected List<TriggeredSandboxJobEventHandler> getTriggeredJobEventHandlers()