Class ProcessBulkUpdateRequestListener
- java.lang.Object
-
- com.broadleafcommerce.bulk.messaging.ProcessBulkUpdateRequestListener
-
public class ProcessBulkUpdateRequestListener extends Object
A listener that accepts aProcessBulkUpdateRequest
and performs the update.- Author:
- Samarth Dhruva (samarthd)
-
-
Constructor Summary
Constructors Constructor Description ProcessBulkUpdateRequestListener(BulkUpdateManager bulkUpdateManager, BulkUpdateService<BulkUpdate> bulkUpdateService, List<BulkDataRouteSupporting> routes)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected BulkUpdateManager
getBulkUpdateManager()
protected BulkUpdateService<BulkUpdate>
getBulkUpdateService()
protected List<BulkDataRouteSupporting>
getRoutes()
void
handle(ProcessBulkUpdateRequest processBulkUpdateRequest)
-
-
-
Constructor Detail
-
ProcessBulkUpdateRequestListener
public ProcessBulkUpdateRequestListener(BulkUpdateManager bulkUpdateManager, BulkUpdateService<BulkUpdate> bulkUpdateService, List<BulkDataRouteSupporting> routes)
-
-
Method Detail
-
handle
@StreamListener("processBulkUpdateRequestInput") public void handle(ProcessBulkUpdateRequest processBulkUpdateRequest)
Delegates toBulkUpdateService.setProcessingStatus(String)
andBulkUpdateManager.processBulkUpdate(BulkUpdate)
.This handler only performs the update if the return value of
BulkUpdateService.setProcessingStatus(String)
is not null. This ensures that only the microservice whose bulk update data store has the bulk update will perform it, and the update will only be performed if theBulkUpdate.status
is valid.- Parameters:
processBulkUpdateRequest
- the request containing information about the bulk update to perform- Throws:
com.broadleafcommerce.common.messaging.exception.ResourceLockException
- if a lock could not be acquired on the bulk update
-
getBulkUpdateManager
@NonNull protected BulkUpdateManager getBulkUpdateManager()
-
getBulkUpdateService
@NonNull protected BulkUpdateService<BulkUpdate> getBulkUpdateService()
-
getRoutes
@NonNull protected List<BulkDataRouteSupporting> getRoutes()
-
-