com.broadleafcommerce.auth.user.service

Class PurgeLoginTableJobListener

java.lang.Object

com.broadleafcommerce.auth.user.service.PurgeLoginTableJobListener

public class PurgeLoginTableJobListener
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	AUTH_SERVER_NAME
static Duration	DEFAULT_PURGE_OLDER_THAN_DURATION
static String	JOB_TYPE
static String	PURGE_OLDER_THAN_DETAIL_NAME

Constructor Summary

Constructors

Constructor and Description
PurgeLoginTableJobListener(UserLoginAttemptService<UserLoginAttempt> userLoginAttemptService, AuthorizationServerService<AuthorizationServer> serverService, com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentService)

Method Summary

Modifier and Type	Method and Description
protected String	getAuthServerId(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef msg)
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentService()
protected Duration	getPurgeOlderThanDuration(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef scheduledJobRef)
protected com.broadleafcommerce.common.messaging.domain.ScheduledJobDetailRef	getRefByName(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef scheduledJobRef, String refName)
protected AuthorizationServerService<AuthorizationServer>	getServerService()
protected UserLoginAttemptService<UserLoginAttempt>	getUserLoginAttemptService()
void	listen(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)
protected void	process(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef msg)

Methods inherited from class java.lang.Object

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

Field Detail

JOB_TYPE

public static final String JOB_TYPE

See Also:

Constant Field Values

PURGE_OLDER_THAN_DETAIL_NAME

public static final String PURGE_OLDER_THAN_DETAIL_NAME

See Also:

Constant Field Values

AUTH_SERVER_NAME

public static final String AUTH_SERVER_NAME

See Also:

Constant Field Values

DEFAULT_PURGE_OLDER_THAN_DURATION

public static final Duration DEFAULT_PURGE_OLDER_THAN_DURATION

Constructor Detail

PurgeLoginTableJobListener

public PurgeLoginTableJobListener(UserLoginAttemptService<UserLoginAttempt> userLoginAttemptService,
                                  AuthorizationServerService<AuthorizationServer> serverService,
                                  com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentService)

Method Detail

listen

@StreamListener(value="triggeredJobEventInputPurgeLoginTable")
public void listen(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)

process

protected void process(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef msg)

getAuthServerId

@Nullable
protected String getAuthServerId(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef msg)

getPurgeOlderThanDuration

@NonNull
protected Duration getPurgeOlderThanDuration(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef scheduledJobRef)

getRefByName

@Nullable
protected com.broadleafcommerce.common.messaging.domain.ScheduledJobDetailRef getRefByName(@NonNull
                                                                                                     com.broadleafcommerce.common.messaging.domain.ScheduledJobRef scheduledJobRef,
                                                                                                     @NonNull
                                                                                                     String refName)

getUserLoginAttemptService

protected UserLoginAttemptService<UserLoginAttempt> getUserLoginAttemptService()

getServerService

protected AuthorizationServerService<AuthorizationServer> getServerService()

getIdempotentService

protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService getIdempotentService()