Class DefaultSandboxDeleteListener
java.lang.Object
com.broadleafcommerce.data.tracking.core.messaging.DefaultSandboxDeleteListener
Listen for
SandboxDeleteEvent
to come in through the
SandboxDeleteConsumer
sandbox message channel. This archives the sandboxed entities from
the SandboxDeleteEvent.getEntityTypesByRouteKeys()
map.- Author:
- Dima Myroniuk (dmyroniuk)
-
Constructor Summary
ConstructorDescriptionDefaultSandboxDeleteListener
(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, CustomizedCommonSandboxableEntityRepository customizedCommonArchiveSandboxableEntityRepository, com.broadleafcommerce.common.extension.data.DataRouteReference routeReference) -
Method Summary
Modifier and TypeMethodDescriptionprotected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService
protected com.broadleafcommerce.common.extension.data.DataRouteReference
getSandboxEntityTypes
(Set<String> entityTypes) void
listen
(org.springframework.messaging.Message<SandboxDeleteEvent> message) protected void
processArchiveNonProductionEntities
(org.springframework.messaging.Message<SandboxDeleteEvent> message, Set<String> entityTypes)
-
Constructor Details
-
DefaultSandboxDeleteListener
public DefaultSandboxDeleteListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, @Nullable CustomizedCommonSandboxableEntityRepository customizedCommonArchiveSandboxableEntityRepository, com.broadleafcommerce.common.extension.data.DataRouteReference routeReference)
-
-
Method Details
-
listen
@StreamListener("sandboxDeleteInput") public void listen(org.springframework.messaging.Message<SandboxDeleteEvent> message) -
processArchiveNonProductionEntities
protected void processArchiveNonProductionEntities(org.springframework.messaging.Message<SandboxDeleteEvent> message, Set<String> entityTypes) -
getSandboxEntityTypes
-
getIdempotentConsumptionService
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService getIdempotentConsumptionService() -
getCustomizedCommonArchiveSandboxableEntityRepository
protected CustomizedCommonSandboxableEntityRepository getCustomizedCommonArchiveSandboxableEntityRepository() -
getRouteReference
protected com.broadleafcommerce.common.extension.data.DataRouteReference getRouteReference()
-