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
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Collection<PersistedSession>deduplicateQueuedSessions(List<AsyncSessionPersisterOperation> fifoSessionHolders, Set<String> sessionsToRemove) protected List<AsyncSessionPersisterOperation>getQueue()protected Collection<String>getStoredHttpSessionModelIds(Collection<PersistedSession> storedHttpSessionModels) voidinit()booleanprotected voidpersistSessions(Collection<PersistedSession> withoutDuplicates) protected voidprotected booleanprotected Map<String,StoredHttpSessionModel> protected voidremoveSessions(Set<String> ids) voidrun()voidvoidsetDrainingAdaptiveAlgorithm(DrainingAdaptiveAlgorithm drainingAdaptiveAlgorithm) voidsetModelService(ModelService modelService) voidsetStoredHttpSessionDao(StoredHttpSessionDao storedHttpSessionDao) voidMethods inherited from class de.hybris.platform.servicelayer.web.session.persister.AbstractSessionPersister
updateModelIfNecessary
-
Constructor Details
-
AsyncSessionPersisterRunnable
public AsyncSessionPersisterRunnable()
-
-
Method Details
-
init
@PostConstruct public void init() -
run
public void run() -
processingAllowed
protected boolean processingAllowed() -
persistsSessionsFromQueue
protected void persistsSessionsFromQueue() -
deduplicateQueuedSessions
protected Collection<PersistedSession> deduplicateQueuedSessions(List<AsyncSessionPersisterOperation> fifoSessionHolders, Set<String> sessionsToRemove) -
drainQueue
-
removeSessions
-
persistSessions
-
provideStoredHttpSessionModelMap
protected Map<String,StoredHttpSessionModel> provideStoredHttpSessionModelMap(Collection<String> ids) -
getStoredHttpSessionModelIds
protected Collection<String> getStoredHttpSessionModelIds(Collection<PersistedSession> storedHttpSessionModels) -
getQueue
-
isSessionScheduledForRemoval
-
scheduleSessionForRemoval
-
setStoredHttpSessionDao
-
setModelService
-
setTenant
-
setDrainingAdaptiveAlgorithm
-