Package de.hybris.platform.servicelayer.web.session.persister

Class AsyncSessionPersisterRunnable

java.lang.Object

de.hybris.platform.servicelayer.web.session.persister.AbstractSessionPersister

de.hybris.platform.servicelayer.web.session.persister.AsyncSessionPersisterRunnable

All Implemented Interfaces:

java.lang.Runnable

public class AsyncSessionPersisterRunnable
extends AbstractSessionPersister
implements java.lang.Runnable

Constructor Summary

Constructors

Constructor	Description
AsyncSessionPersisterRunnable()

Method Summary

Modifier and Type	Method	Description
protected java.util.Collection<PersistedSession>	deduplicateQueuedSessions(java.util.List<AsyncSessionPersisterOperation> fifoSessionHolders, java.util.Set<java.lang.String> sessionsToRemove)
protected java.util.List<AsyncSessionPersisterOperation>	drainQueue()
java.util.concurrent.BlockingQueue<AsyncSessionPersisterOperation>	getQueue()
protected java.util.Collection<java.lang.String>	getStoredHttpSessionModelIds(java.util.Collection<PersistedSession> storedHttpSessionModels)
void	init()
boolean	isSessionScheduledForRemoval(java.lang.String id)
protected void	persistSessions(java.util.Collection<PersistedSession> withoutDuplicates)
protected void	persistsSessionsFromQueue()
protected boolean	processingAllowed()
protected java.util.Map<java.lang.String,StoredHttpSessionModel>	provideStoredHttpSessionModelMap(java.util.Collection<java.lang.String> ids)
protected void	removeSessions(java.util.Set<java.lang.String> ids)
void	run()
void	scheduleSessionForRemoval(java.lang.String id)
void	setDrainingAdaptiveAlgorithm(DrainingAdaptiveAlgorithm drainingAdaptiveAlgorithm)
void	setModelService(ModelService modelService)
void	setStoredHttpSessionDao(StoredHttpSessionDao storedHttpSessionDao)
void	setTenant(Tenant tenant)

Methods inherited from class de.hybris.platform.servicelayer.web.session.persister.AbstractSessionPersister

updateModelIfNecessary

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncSessionPersisterRunnable

public AsyncSessionPersisterRunnable()

Method Detail

init

@PostConstruct
public void init()

run

public void run()

Specified by:

run in interface java.lang.Runnable

processingAllowed

protected boolean processingAllowed()

persistsSessionsFromQueue

protected void persistsSessionsFromQueue()

deduplicateQueuedSessions

protected java.util.Collection<PersistedSession> deduplicateQueuedSessions(java.util.List<AsyncSessionPersisterOperation> fifoSessionHolders,
                                                                           java.util.Set<java.lang.String> sessionsToRemove)

drainQueue

protected java.util.List<AsyncSessionPersisterOperation> drainQueue()

removeSessions

protected void removeSessions(java.util.Set<java.lang.String> ids)

persistSessions

protected void persistSessions(java.util.Collection<PersistedSession> withoutDuplicates)

provideStoredHttpSessionModelMap

protected java.util.Map<java.lang.String,StoredHttpSessionModel> provideStoredHttpSessionModelMap(java.util.Collection<java.lang.String> ids)

getStoredHttpSessionModelIds

protected java.util.Collection<java.lang.String> getStoredHttpSessionModelIds(java.util.Collection<PersistedSession> storedHttpSessionModels)

getQueue

public java.util.concurrent.BlockingQueue<AsyncSessionPersisterOperation> getQueue()

isSessionScheduledForRemoval

public boolean isSessionScheduledForRemoval(java.lang.String id)

scheduleSessionForRemoval

public void scheduleSessionForRemoval(java.lang.String id)

setStoredHttpSessionDao

public void setStoredHttpSessionDao(StoredHttpSessionDao storedHttpSessionDao)

setModelService

public void setModelService(ModelService modelService)

setTenant

public void setTenant(Tenant tenant)

setDrainingAdaptiveAlgorithm

public void setDrainingAdaptiveAlgorithm(DrainingAdaptiveAlgorithm drainingAdaptiveAlgorithm)