com.broadleafcommerce.enterprise.workflow.admin.service.behavior.simple

Class SimpleSystemEventServiceImpl

java.lang.Object

com.broadleafcommerce.enterprise.workflow.admin.service.behavior.simple.SimpleSystemEventServiceImpl

All Implemented Interfaces:

SimpleSystemEventService

@Service(value="blSimpleSystemEventService")
public class SimpleSystemEventServiceImpl
extends Object
implements SimpleSystemEventService

Author:

Jeff Fischer

See Also:

SimpleSystemEventService

Nested Class Summary

Nested classes/interfaces inherited from interface com.broadleafcommerce.enterprise.workflow.admin.service.behavior.simple.SimpleSystemEventService

SimpleSystemEventService.InvalidationInfo, SimpleSystemEventService.SolrInfo

Field Summary

Fields

Modifier and Type	Field and Description
protected SimpleCloneDao	cloneDao
protected SimpleTransitionDao	dao
protected com.broadleafcommerce.jobsevents.service.SystemEventCompressionHelper	helper
protected com.broadleafcommerce.jobsevents.service.consumer.CacheInvalidationHelper	invalidationHelper
protected org.broadleafcommerce.common.sandbox.SandBoxHelper	sandBoxHelper
protected com.broadleafcommerce.jobsevents.service.DatabaseSystemEventSender	sender
protected SimpleTableMetadataDao	simpleTableMetadataDao
protected SimpleSystemEventDao	systemEventDao

Constructor Summary

Constructors

Constructor and Description
SimpleSystemEventServiceImpl()

Method Summary

Modifier and Type	Method and Description
protected void	addEventDetail(com.broadleafcommerce.jobsevents.domain.SystemEvent event, String name, String value, String longValue, String friendlyName)
void	compressAndSend(List<com.broadleafcommerce.jobsevents.domain.SystemEvent> compress)
List<com.broadleafcommerce.jobsevents.domain.SystemEvent>	createCacheInvalidationEvents(Long id, Class<?> clazz, Long siteId, Long siteDisc, Long catalogDisc, com.broadleafcommerce.jobsevents.service.type.EventWorkerType workerType, Long sandboxId, boolean shouldCreateSolrEvent)
protected List<com.broadleafcommerce.jobsevents.domain.SystemEvent>	createSolrEvent(Map<Long,Set<SimpleSystemEventService.SolrInfo>> infosBySandbox) Create invalidation events targeted at solr incremental indexing
protected com.broadleafcommerce.jobsevents.domain.SystemEvent	createStandardEvent(String id, String entityType, Long targetSandBox, String region, Long currentProfile, Long currentCatalog, Long site, com.broadleafcommerce.jobsevents.service.type.EventWorkerType workerType) Create invalidation events targeted at Hibernate Level 2 cache.
void	emitCacheInvalidationEvents(Map<String,List<SimpleSystemEventService.InvalidationInfo>> infosByTable) Emit standard cache invalidation and solr invalidation messages.
void	emitCacheInvalidationEvents(Map<String,List<SimpleSystemEventService.InvalidationInfo>> infosByTable, boolean onlyForUpdates)
protected void	establishBroadleafRequestContextState(org.broadleafcommerce.common.web.BroadleafRequestContext copy, Long siteId, Long catalogId, com.broadleafcommerce.jobsevents.domain.SystemEvent event)
protected void	establishSolrInfoIfApplicable(Map<Long,Set<SimpleSystemEventService.SolrInfo>> infosBySandbox, SimpleSystemEventService.InvalidationInfo invalidationInfo)
protected Map<Class<?>,List<SimpleSystemEventService.InvalidationInfo>>	getInfoByType(Map<String,List<SimpleSystemEventService.InvalidationInfo>> infosByTable)
protected SimpleSolrTransactionSynchronizationAdapter	getSimpleSolrTransactionSynchronizationAdapter(List<com.broadleafcommerce.jobsevents.domain.SystemEvent> solrCacheEvents)
protected void	populateRelatedProductInformationIfApplicable(Map<Class<?>,List<SimpleSystemEventService.InvalidationInfo>> infoByType)
protected void	populateSolrSystemEvent(org.broadleafcommerce.common.web.BroadleafRequestContext copy, List<com.broadleafcommerce.jobsevents.domain.SystemEvent> events, Long siteId, Set<SimpleSystemEventService.SolrInfo> infos, Long sandbox, Long catalogId)

Methods inherited from class java.lang.Object

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

Field Detail

dao

protected SimpleTransitionDao dao

simpleTableMetadataDao

protected SimpleTableMetadataDao simpleTableMetadataDao

systemEventDao

protected SimpleSystemEventDao systemEventDao

helper

protected com.broadleafcommerce.jobsevents.service.SystemEventCompressionHelper helper

invalidationHelper

protected com.broadleafcommerce.jobsevents.service.consumer.CacheInvalidationHelper invalidationHelper

sender

protected com.broadleafcommerce.jobsevents.service.DatabaseSystemEventSender sender

cloneDao

protected SimpleCloneDao cloneDao

sandBoxHelper

protected org.broadleafcommerce.common.sandbox.SandBoxHelper sandBoxHelper

Constructor Detail

SimpleSystemEventServiceImpl

public SimpleSystemEventServiceImpl()

Method Detail

emitCacheInvalidationEvents

public void emitCacheInvalidationEvents(Map<String,List<SimpleSystemEventService.InvalidationInfo>> infosByTable)

Description copied from interface: SimpleSystemEventService

Emit standard cache invalidation and solr invalidation messages.

Specified by:

emitCacheInvalidationEvents in interface SimpleSystemEventService

Parameters:

infosByTable - The list of changes by table driving the need for cache invalidation on the storefront and admin nodes

emitCacheInvalidationEvents

public void emitCacheInvalidationEvents(Map<String,List<SimpleSystemEventService.InvalidationInfo>> infosByTable,
                                        boolean onlyForUpdates)

Specified by:

emitCacheInvalidationEvents in interface SimpleSystemEventService

establishSolrInfoIfApplicable

protected void establishSolrInfoIfApplicable(Map<Long,Set<SimpleSystemEventService.SolrInfo>> infosBySandbox,
                                             SimpleSystemEventService.InvalidationInfo invalidationInfo)

getInfoByType

protected Map<Class<?>,List<SimpleSystemEventService.InvalidationInfo>> getInfoByType(Map<String,List<SimpleSystemEventService.InvalidationInfo>> infosByTable)

populateRelatedProductInformationIfApplicable

protected void populateRelatedProductInformationIfApplicable(Map<Class<?>,List<SimpleSystemEventService.InvalidationInfo>> infoByType)

createSolrEvent

protected List<com.broadleafcommerce.jobsevents.domain.SystemEvent> createSolrEvent(Map<Long,Set<SimpleSystemEventService.SolrInfo>> infosBySandbox)

Create invalidation events targeted at solr incremental indexing

Parameters:

infosBySandbox -

Returns:

The solr invalidation event

populateSolrSystemEvent

protected void populateSolrSystemEvent(org.broadleafcommerce.common.web.BroadleafRequestContext copy,
                                       List<com.broadleafcommerce.jobsevents.domain.SystemEvent> events,
                                       Long siteId,
                                       Set<SimpleSystemEventService.SolrInfo> infos,
                                       Long sandbox,
                                       Long catalogId)

establishBroadleafRequestContextState

protected void establishBroadleafRequestContextState(org.broadleafcommerce.common.web.BroadleafRequestContext copy,
                                                     Long siteId,
                                                     Long catalogId,
                                                     com.broadleafcommerce.jobsevents.domain.SystemEvent event)

createStandardEvent

protected com.broadleafcommerce.jobsevents.domain.SystemEvent createStandardEvent(String id,
                                                                                  String entityType,
                                                                                  Long targetSandBox,
                                                                                  String region,
                                                                                  Long currentProfile,
                                                                                  Long currentCatalog,
                                                                                  Long site,
                                                                                  com.broadleafcommerce.jobsevents.service.type.EventWorkerType workerType)

Create invalidation events targeted at Hibernate Level 2 cache. Could possibly drive other cache invalidation as well.

Parameters:

id - The primary key value of the entity to remove from L2 cache

entityType - The fully qualified classname of the entity implementation

targetSandBox - The sandbox in which the item to remove from cache resides

region - The Hibernate L2 cache region

currentProfile - The profile in play during the deployment of the entity, if applicable

currentCatalog - The catalog in play during the deployment of the entity, if applicable

site - The site identifier in play during the deployment of the entity

workerType - The type of node that should consume the event. See EventWorkerType.

Returns:

The L2 cache invalidation event

addEventDetail

protected void addEventDetail(com.broadleafcommerce.jobsevents.domain.SystemEvent event,
                              String name,
                              String value,
                              String longValue,
                              String friendlyName)

getSimpleSolrTransactionSynchronizationAdapter

@Lookup(value="blSimpleSolrTransactionSynchronizationAdapter")
protected SimpleSolrTransactionSynchronizationAdapter getSimpleSolrTransactionSynchronizationAdapter(List<com.broadleafcommerce.jobsevents.domain.SystemEvent> solrCacheEvents)

createCacheInvalidationEvents

public List<com.broadleafcommerce.jobsevents.domain.SystemEvent> createCacheInvalidationEvents(Long id,
                                                                                               Class<?> clazz,
                                                                                               Long siteId,
                                                                                               Long siteDisc,
                                                                                               Long catalogDisc,
                                                                                               com.broadleafcommerce.jobsevents.service.type.EventWorkerType workerType,
                                                                                               Long sandboxId,
                                                                                               boolean shouldCreateSolrEvent)

Specified by:

createCacheInvalidationEvents in interface SimpleSystemEventService

compressAndSend

public void compressAndSend(List<com.broadleafcommerce.jobsevents.domain.SystemEvent> compress)

Specified by:

compressAndSend in interface SimpleSystemEventService