Package com.broadleafcommerce.data.tracking.core.messaging

Class DefaultSandboxDeleteListener

java.lang.Object

com.broadleafcommerce.data.tracking.core.messaging.DefaultSandboxDeleteListener

public class DefaultSandboxDeleteListener
extends Object

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

Constructors

Constructor	Description
DefaultSandboxDeleteListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, CustomizedCommonSandboxableEntityRepository customizedCommonArchiveSandboxableEntityRepository, com.broadleafcommerce.common.extension.data.DataRouteReference routeReference)

Method Summary

Modifier and Type	Method	Description
protected CustomizedCommonSandboxableEntityRepository	getCustomizedCommonArchiveSandboxableEntityRepository()
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentConsumptionService()
protected com.broadleafcommerce.common.extension.data.DataRouteReference	getRouteReference()
protected List<Class<?>>	getSandboxEntityTypes(Set<String> entityTypes)
void	listen(org.springframework.messaging.Message<SandboxDeleteEvent> message)
protected void	processArchiveNonProductionEntities(org.springframework.messaging.Message<SandboxDeleteEvent> message, Set<String> entityTypes)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSandboxDeleteListener

public DefaultSandboxDeleteListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService,
                                    @Nullable
                                    CustomizedCommonSandboxableEntityRepository customizedCommonArchiveSandboxableEntityRepository,
                                    com.broadleafcommerce.common.extension.data.DataRouteReference routeReference)

Method Detail

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

protected List<Class<?>> getSandboxEntityTypes(Set<String> entityTypes)

getIdempotentConsumptionService

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

getCustomizedCommonArchiveSandboxableEntityRepository

protected CustomizedCommonSandboxableEntityRepository getCustomizedCommonArchiveSandboxableEntityRepository()

getRouteReference

protected com.broadleafcommerce.common.extension.data.DataRouteReference getRouteReference()