Package com.broadleafcommerce.scheduledjob.messaging.transition

Class DeploymentJobSchedulingRequestListener

java.lang.Object

com.broadleafcommerce.scheduledjob.messaging.transition.DeploymentJobSchedulingRequestListener

All Implemented Interfaces:

TrackingWorkflowJobSchedulingRequestListener

public class DeploymentJobSchedulingRequestListener
extends Object
implements TrackingWorkflowJobSchedulingRequestListener

This handler specializes in WorkflowJobSchedulingRequests and is the main component that listens for the sandbox service to send it a request to schedule a deployment job. Eventually once the job is saved in the persistent store it is eventually picked up by the SchedulerService to actually execute the job.

Author:

Nathan Moore (nathandmoore)

Constructor Summary

Constructors

Constructor

Description

DeploymentJobSchedulingRequestListener(ScheduledJobService<ScheduledJob> scheduledJobService, com.broadleafcommerce.common.extension.TypeFactory jobFactory, com.broadleafcommerce.data.tracking.core.transition.WorkflowRequestCompletionNotifier completionNotifier, com.broadleafcommerce.common.messaging.notification.NotificationManager notificationManager, ScheduledJobRepository<?> repository, com.broadleafcommerce.common.extension.data.DataRouteSupporting route, com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService)

Method Summary

Modifier and Type	Method	Description
protected void	doHandle(@NonNull org.springframework.messaging.Message<com.broadleafcommerce.data.tracking.core.transition.WorkflowJobSchedulingRequest> message)
void	handle(org.springframework.messaging.Message<com.broadleafcommerce.data.tracking.core.transition.WorkflowJobSchedulingRequest> message)	Creates a new ScheduledJob that triggers the deployment specified via the WorkflowJobSchedulingRequest then sends a WorkflowRequestCompletion when finished, after successfully creating a job or encountering an error.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DeploymentJobSchedulingRequestListener

public DeploymentJobSchedulingRequestListener(ScheduledJobService<ScheduledJob> scheduledJobService,
                                              com.broadleafcommerce.common.extension.TypeFactory jobFactory,
                                              com.broadleafcommerce.data.tracking.core.transition.WorkflowRequestCompletionNotifier completionNotifier,
                                              com.broadleafcommerce.common.messaging.notification.NotificationManager notificationManager,
                                              ScheduledJobRepository<?> repository,
                                              com.broadleafcommerce.common.extension.data.DataRouteSupporting route,
                                              com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService)

Method Detail

handle

@StreamListener("scheduleDeploymentInput")
public void handle(org.springframework.messaging.Message<com.broadleafcommerce.data.tracking.core.transition.WorkflowJobSchedulingRequest> message)

Creates a new ScheduledJob that triggers the deployment specified via the WorkflowJobSchedulingRequest then sends a WorkflowRequestCompletion when finished, after successfully creating a job or encountering an error.

Specified by:

handle in interface TrackingWorkflowJobSchedulingRequestListener

Parameters:

message - a workflow job scheduling request with info needed to create a new scheduled job

doHandle

protected void doHandle(@NonNull
                        @NonNull org.springframework.messaging.Message<com.broadleafcommerce.data.tracking.core.transition.WorkflowJobSchedulingRequest> message)