com.broadleafcommerce.jobsevents.service

Class DatabaseSystemEventSender

java.lang.Object

com.broadleafcommerce.jobsevents.service.DatabaseSystemEventSender

All Implemented Interfaces:

SystemEventSender

@Service(value="blSystemEventSender")
public class DatabaseSystemEventSender
extends Object
implements SystemEventSender

Author:

Jeff Fischer

See Also:

SystemEventSender

Field Summary

Fields

Modifier and Type	Field and Description
protected DatabaseSystemEventDao	databaseSystemEventDao
protected IncognitoEnvironmentDetector	detector
protected List<String>	incognitoUnboundedEventTypes
protected long	nodePurgeThresholdSeconds
protected org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor	taskExecutor
protected org.springframework.transaction.PlatformTransactionManager	transactionManager
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil

Constructor Summary

Constructors

Constructor and Description
DatabaseSystemEventSender()

Method Summary

Modifier and Type	Method and Description
protected void	addIncognitoCrossPollination(List<SystemEvent> clusterEvents, SystemEvent event, Set<String> activeNodes)
void	finalizeEvents(Long processMarker) Mass activate events based on the process marker.
protected Set<String>	findActiveNodes()
void	init()
void	sendEvents(List<SystemEvent> events) Send the events to the backing system.
protected void	sendEvents(List<SystemEvent> events, boolean guaranteed)
void	unsafeSendEvents(List<SystemEvent> events) Send the events to the backing system.

Methods inherited from class java.lang.Object

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

Field Detail

nodePurgeThresholdSeconds

@Value(value="${node.purge.threshold.seconds:60}")
protected long nodePurgeThresholdSeconds

databaseSystemEventDao

protected DatabaseSystemEventDao databaseSystemEventDao

transactionManager

protected org.springframework.transaction.PlatformTransactionManager transactionManager

transUtil

protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil transUtil

taskExecutor

protected org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor

incognitoUnboundedEventTypes

protected List<String> incognitoUnboundedEventTypes

detector

protected IncognitoEnvironmentDetector detector

Constructor Detail

DatabaseSystemEventSender

public DatabaseSystemEventSender()

Method Detail

init

@PostConstruct
public void init()

sendEvents

public void sendEvents(List<SystemEvent> events)

Description copied from interface: SystemEventSender

Send the events to the backing system.

Specified by:

sendEvents in interface SystemEventSender

unsafeSendEvents

public void unsafeSendEvents(List<SystemEvent> events)

Description copied from interface: SystemEventSender

Send the events to the backing system. This differs from SystemEventSender.sendEvents(List) in that the actual sending is performed on a separate thread. This is faster for the calling thread and avoids some event preparation overhead, but the caller will not know if the sending of the event was successful. Therefore, it is recommended to use this method for non-critical events.

Specified by:

unsafeSendEvents in interface SystemEventSender

finalizeEvents

public void finalizeEvents(Long processMarker)

Description copied from interface: SystemEventSender

Mass activate events based on the process marker.

Specified by:

finalizeEvents in interface SystemEventSender

See Also:

SystemEvent.getProcessMarker()

sendEvents

protected void sendEvents(List<SystemEvent> events,
                          boolean guaranteed)

findActiveNodes

protected Set<String> findActiveNodes()

addIncognitoCrossPollination

protected void addIncognitoCrossPollination(List<SystemEvent> clusterEvents,
                                            SystemEvent event,
                                            Set<String> activeNodes)