Package com.hybris.ymkt.clickstream.listeners

Class ClickStreamListener

java.lang.Object

de.hybris.platform.servicelayer.event.impl.AbstractEventListener<AbstractTrackingEvent>

com.hybris.ymkt.clickstream.listeners.ClickStreamListener

All Implemented Interfaces:

java.util.EventListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<AbstractTrackingEvent>

public class ClickStreamListener
extends AbstractEventListener<AbstractTrackingEvent>

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.Set<java.lang.String>	allowedEvents
protected java.util.concurrent.ConcurrentLinkedQueue<AbstractTrackingEvent>	batchQueue
protected int	batchSize
protected ClickStreamService	clickStreamService
protected FlexibleSearchService	flexibleSearchService
protected static java.util.function.Predicate<java.lang.String>	STRING_IS_EMPTY
protected static java.util.function.Predicate<java.lang.String>	STRING_IS_NOT_EMPTY
protected UserContextService	userContextService
protected YmktConsentService	ymktConsentService

Constructor Summary

Constructors

Constructor	Description
ClickStreamListener()

Method Summary

Modifier and Type	Method	Description
protected AbstractTrackingEvent	enrich(AbstractTrackingEvent event)
protected boolean	filterByAllowedEvents(AbstractTrackingEvent event)
protected boolean	filterByConsent(AbstractTrackingEvent event)
protected boolean	filterByProductEvents(AbstractTrackingEvent event)
protected void	onEvent(AbstractTrackingEvent event)	This method is called by ApplicationListener.onApplicationEvent(ApplicationEvent) and processes the given event.
protected java.util.Optional<java.util.List<AbstractTrackingEvent>>	prepareBatchEvents()
void	setAllowedEvents(java.util.List<java.lang.String> allowedEvents)
void	setBatchSize(int batchSize)
void	setClickStreamService(ClickStreamService clickStreamService)
void	setFlexibleSearchService(FlexibleSearchService flexibleSearchService)
void	setUserContextService(UserContextService userContextService)
void	setYmktConsentService(YmktConsentService ymktConsentService)

Methods inherited from class de.hybris.platform.servicelayer.event.impl.AbstractEventListener

afterPropertiesSet, onApplicationEvent, setApplicationContext, setClusterService, setTenantService

Methods inherited from class java.lang.Object

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

Field Detail

STRING_IS_EMPTY

protected static final java.util.function.Predicate<java.lang.String> STRING_IS_EMPTY

STRING_IS_NOT_EMPTY

protected static final java.util.function.Predicate<java.lang.String> STRING_IS_NOT_EMPTY

allowedEvents

protected final java.util.Set<java.lang.String> allowedEvents

batchQueue

protected final java.util.concurrent.ConcurrentLinkedQueue<AbstractTrackingEvent> batchQueue

batchSize

protected int batchSize

clickStreamService

protected ClickStreamService clickStreamService

flexibleSearchService

protected FlexibleSearchService flexibleSearchService

userContextService

protected UserContextService userContextService

ymktConsentService

protected YmktConsentService ymktConsentService

Constructor Detail

ClickStreamListener

public ClickStreamListener()

Method Detail

enrich

protected AbstractTrackingEvent enrich(AbstractTrackingEvent event)

filterByAllowedEvents

protected boolean filterByAllowedEvents(AbstractTrackingEvent event)

filterByConsent

protected boolean filterByConsent(AbstractTrackingEvent event)

filterByProductEvents

protected boolean filterByProductEvents(AbstractTrackingEvent event)

onEvent

protected void onEvent(AbstractTrackingEvent event)

Description copied from class: AbstractEventListener

This method is called by ApplicationListener.onApplicationEvent(ApplicationEvent) and processes the given event.

Specified by:

onEvent in class AbstractEventListener<AbstractTrackingEvent>

Parameters:

event - the event to be processed

See Also:

ApplicationListener.onApplicationEvent(ApplicationEvent)

prepareBatchEvents

protected java.util.Optional<java.util.List<AbstractTrackingEvent>> prepareBatchEvents()

setAllowedEvents

public void setAllowedEvents(java.util.List<java.lang.String> allowedEvents)

setBatchSize

public void setBatchSize(int batchSize)

setClickStreamService

public void setClickStreamService(ClickStreamService clickStreamService)

setFlexibleSearchService

public void setFlexibleSearchService(FlexibleSearchService flexibleSearchService)

setUserContextService

public void setUserContextService(UserContextService userContextService)

setYmktConsentService

public void setYmktConsentService(YmktConsentService ymktConsentService)