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:

Runnable

public class AsyncSessionPersisterRunnable
extends AbstractSessionPersister
implements Runnable

Constructor Summary

Constructors

Constructor and Description
AsyncSessionPersisterRunnable()

Method Summary

Modifier and Type	Method and Description
protected Collection<PersistedSession>	deduplicateQueuedSessions(List<AsyncSessionPersisterOperation> fifoSessionHolders, Set<String> sessionsToRemove)
protected List<AsyncSessionPersisterOperation>	drainQueue()
BlockingQueue<AsyncSessionPersisterOperation>	getQueue()
void	init()
protected void	persistSessions(Collection<PersistedSession> withoutDuplicates)
protected void	persistsSessionsFromQueue()
protected boolean	processingAllowed()
protected void	removeSessions(Set<String> ids)
void	run()
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 Runnable

processingAllowed

protected boolean processingAllowed()

persistsSessionsFromQueue

protected void persistsSessionsFromQueue()

deduplicateQueuedSessions

protected Collection<PersistedSession> deduplicateQueuedSessions(List<AsyncSessionPersisterOperation> fifoSessionHolders,
                                                                 Set<String> sessionsToRemove)

drainQueue

protected List<AsyncSessionPersisterOperation> drainQueue()

removeSessions

protected void removeSessions(Set<String> ids)

persistSessions

protected void persistSessions(Collection<PersistedSession> withoutDuplicates)

getQueue

public BlockingQueue<AsyncSessionPersisterOperation> getQueue()

setStoredHttpSessionDao

public void setStoredHttpSessionDao(StoredHttpSessionDao storedHttpSessionDao)

setModelService

public void setModelService(ModelService modelService)

setTenant

public void setTenant(Tenant tenant)