Class CheckoutRollbackEventListener

java.lang.Object
com.broadleafcommerce.paymenttransaction.service.messaging.reversals.CheckoutRollbackEventListener

@DataRouteByKey("paymentTransaction") public class CheckoutRollbackEventListener extends Object
Listens of events that trigger marking payment transaction for reversal. It consumes the CheckoutRollbackEvent to identify the payment transaction to reverse and avoid updating any transactions that have DefaultTransactionManagementStates.AUTOMATIC_REVERSAL_NOT_ALLOWED or any other reversal management state.
Author:
Dima Myroniuk (dmyroniuk)
  • Constructor Details

  • Method Details

    • handle

      @StreamListener("checkoutRollbackInput") public void handle(org.springframework.messaging.Message<CheckoutRollbackEvent> message)
    • process

      protected void process(@NonNull @NonNull org.springframework.messaging.Message<CheckoutRollbackEvent> message)
    • markTransactionsAsReversalCandidates

      protected void markTransactionsAsReversalCandidates(@NonNull @NonNull List<Payment> payments, @NonNull @NonNull String requestId, @Nullable com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
    • markTransactionsAsReversalCandidates

      protected void markTransactionsAsReversalCandidates(@NonNull @NonNull List<PaymentTransaction> transactionsToMarkAsReversalCandidates, @NonNull @NonNull Payment payment, @Nullable com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
    • readAllPayments

      protected List<Payment> readAllPayments(@NonNull @NonNull String cartId, @Nullable com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
    • getPaymentService

      protected PaymentService<Payment> getPaymentService()
    • getPaymentTransactionService

      protected PaymentTransactionService<PaymentTransaction> getPaymentTransactionService()
    • getPaymentLockService

      protected PaymentLockService<Payment> getPaymentLockService()
    • getIdempotentService

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