Package com.broadleafcommerce.creditaccount.service.messaging

Class CreditExpirationJobListener

java.lang.Object

com.broadleafcommerce.creditaccount.service.messaging.CreditExpirationJobListener

@DataRouteByKey("creditAccount")
public class CreditExpirationJobListener
extends Object

Reads the credit account expired transactions and executes CreditExpirationService.processExpiredTransactions(List, ExpirationSourceInfo, ContextInfo).

Author:

Dima Myroniuk (dmyroniuk)

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BATCH_SIZE_FLD
static final String	CREDIT_ACCOUNT_TRANSACTION_EXPIRE

Constructor Summary

Constructors

Constructor	Description
CreditExpirationJobListener(TransactionService<Transaction> transactionService, CreditExpirationService creditExpirationService, com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentMessageService, com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Summary

Modifier and Type	Method	Description
protected com.broadleafcommerce.data.tracking.core.context.ContextInfo	buildContextInfoForRead(@NonNull org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)	Builds a ContextInfo object for OperationType.READ.
protected int	getBatchSize(@NonNull com.broadleafcommerce.common.messaging.domain.ScheduledJobRef jobRef)	Gets the batch size to use when fetching credit account transactions.
protected CreditExpirationService	getCreditExpirationService()
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentMessageService()
protected String	getJobExecutionId(@NonNull org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)
protected TransactionService<Transaction>	getTransactionService()
protected com.broadleafcommerce.common.extension.TypeFactory	getTypeFactory()
void	listen(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)
protected void	process(@NonNull org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)	Initiates the scheduled job to process expired transactions.

Methods inherited from class java.lang.Object

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

Field Details

CREDIT_ACCOUNT_TRANSACTION_EXPIRE

public static final String CREDIT_ACCOUNT_TRANSACTION_EXPIRE

See Also:

• Constant Field Values

BATCH_SIZE_FLD

public static final String BATCH_SIZE_FLD

See Also:

• Constant Field Values

Constructor Details

CreditExpirationJobListener

public CreditExpirationJobListener(TransactionService<Transaction> transactionService,
 CreditExpirationService creditExpirationService,
 com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentMessageService,
 com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Details

listen

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

process

protected void process(@NonNull
 @NonNull org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)

Initiates the scheduled job to process expired transactions.

Parameters:

message - the Message containing the scheduled job detail

getBatchSize

protected int getBatchSize(@NonNull
 @NonNull com.broadleafcommerce.common.messaging.domain.ScheduledJobRef jobRef)

Gets the batch size to use when fetching credit account transactions. Defaults to 50.

Parameters:

jobRef - the ScheduledJobRef containing the scheduled job details

Returns:

the batch size to use when fetching the transactions

buildContextInfoForRead

protected com.broadleafcommerce.data.tracking.core.context.ContextInfo buildContextInfoForRead(@NonNull
 @NonNull org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)

Builds a ContextInfo object for OperationType.READ.

Parameters:

message - Contains scheduled job details about the context

Returns:

a ContextInfo object for OperationType.READ

getJobExecutionId

protected String getJobExecutionId(@NonNull
 @NonNull org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)

getTransactionService

protected TransactionService<Transaction> getTransactionService()

getCreditExpirationService

protected CreditExpirationService getCreditExpirationService()

getIdempotentMessageService

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

getTypeFactory

protected com.broadleafcommerce.common.extension.TypeFactory getTypeFactory()