Package com.broadleafcommerce.billing.job.messaging.stream

Class StreamBillingJobMessageSender

java.lang.Object

com.broadleafcommerce.messaging.AbstractMessageSender

com.broadleafcommerce.billing.job.messaging.stream.StreamBillingJobMessageSender

All Implemented Interfaces:

BillingJobMessageSender

public class StreamBillingJobMessageSender
extends AbstractMessageSender
implements BillingJobMessageSender

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<Class<?>,BiConsumer<?,com.broadleafcommerce.data.tracking.core.context.ContextInfo>>	handlers

Fields inherited from class com.broadleafcommerce.messaging.AbstractMessageSender

random, sender

Constructor Summary

Constructors

Constructor	Description
StreamBillingJobMessageSender()

Method Summary

Modifier and Type	Method	Description
protected <T> void	add(Class<T> type, BiConsumer<T,com.broadleafcommerce.data.tracking.core.context.ContextInfo> consumer)
<T> void	deadLetterRetry(T message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
void	sendToBillingProcessingRequestFinalizer(FinalizeBillingProcessingRequests message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message FinalizeBillingProcessingRequests to billing processing request finalizer BillingProcessingRequestFinalizer
void	sendToBillingProcessingRequestInitializer(InitializeBillingProcessingRequests message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message InitializeBillingProcessingRequests to billing processing request initializer BillingProcessingRequestInitializer
void	sendToBillingProcessingResultHandler(ProcessBillingEventPaymentResults message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message BillingEventPaymentProcessedEvent to billing processing result handler.
void	sendToChargeRetryBillingRequestGenerator(GenerateChargeRetryRequests message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message GenerateChargeRetryRequests to request generator ChargeRetryBillingRequestGenerator
void	sendToEventPaymentUpdater(UpdateBillingEventPayments message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message UpdateBillingEventPayments to event payment updater EventPaymentUpdater
void	sendToGrantEntitlementHandler(EntitlementProcessingRequest message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
void	sendToNewChargeBillingRequestGenerator(GenerateNewChargeRequests message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message GenerateNewChargeRequests to request generator NewChargeBillingRequestGenerator
void	sendToNewRefundBillingRequestGenerator(GenerateNewRefundRequests message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message GenerateNewRefundRequests to request generator NewRefundBillingRequestGenerator
void	sendToPaymentAccountProcessingResultUpdater(PaymentAccountProcessedMessage message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message PaymentAccountProcessedEvent to payment account processing result updater.
void	sendToPaymentProcessingResultHandler(PaymentsProcessed message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message PaymentsProcessed to payment processing result handler PaymentProcessingResultHandler
void	sendToPaymentProcessorHandler(ProcessPayments message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message ProcessPayments to the Payment Processor Handler PaymentProcessorHandler
void	sendToRefundEventUpdater(UpdateRefundEvents message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message UpdateRefundEvents to refund event updater RefundEventUpdater
void	sendToRefundRetryBillingRequestGenerator(GenerateRefundRetryRequests message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Send message GenerateRefundRetryRequests to request generator RefundRetryBillingRequestGenerator
void	sendToRevokeEntitlementHandler(EntitlementProcessingRequest message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
void	sendToTaxProcessorHandler(TaxCalculationHandlerRequests message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
void	sendToTaxProcessorResultHandler(TaxCalculationResultProcessorRequests message, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Methods inherited from class com.broadleafcommerce.messaging.AbstractMessageSender

send

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.broadleafcommerce.billing.job.messaging.BillingJobMessageSender

sendToBillingProcessingRequestFinalizer, sendToBillingProcessingRequestInitializer, sendToBillingProcessingResultHandler, sendToChargeRetryBillingRequestGenerator, sendToEventPaymentUpdater, sendToGrantEntitlementHandler, sendToNewChargeBillingRequestGenerator, sendToNewRefundBillingRequestGenerator, sendToPaymentAccountProcessingResultUpdater, sendToPaymentProcessingResultHandler, sendToPaymentProcessorHandler, sendToRefundEventUpdater, sendToRefundRetryBillingRequestGenerator, sendToRevokeEntitlementHandler, sendToTaxProcessorHandler, sendToTaxProcessorResultHandler

Field Details

handlers

protected final Map<Class<?>,BiConsumer<?,com.broadleafcommerce.data.tracking.core.context.ContextInfo>> handlers

Constructor Details

StreamBillingJobMessageSender

public StreamBillingJobMessageSender()

Method Details

add

protected <T> void add(Class<T> type,
 BiConsumer<T,com.broadleafcommerce.data.tracking.core.context.ContextInfo> consumer)

deadLetterRetry

public <T> void deadLetterRetry(T message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Specified by:

deadLetterRetry in interface BillingJobMessageSender

sendToNewChargeBillingRequestGenerator

public void sendToNewChargeBillingRequestGenerator(GenerateNewChargeRequests message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message GenerateNewChargeRequests to request generator NewChargeBillingRequestGenerator

Specified by:

sendToNewChargeBillingRequestGenerator in interface BillingJobMessageSender

sendToChargeRetryBillingRequestGenerator

public void sendToChargeRetryBillingRequestGenerator(GenerateChargeRetryRequests message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message GenerateChargeRetryRequests to request generator ChargeRetryBillingRequestGenerator

Specified by:

sendToChargeRetryBillingRequestGenerator in interface BillingJobMessageSender

sendToNewRefundBillingRequestGenerator

public void sendToNewRefundBillingRequestGenerator(GenerateNewRefundRequests message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message GenerateNewRefundRequests to request generator NewRefundBillingRequestGenerator

Specified by:

sendToNewRefundBillingRequestGenerator in interface BillingJobMessageSender

sendToRefundRetryBillingRequestGenerator

public void sendToRefundRetryBillingRequestGenerator(GenerateRefundRetryRequests message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message GenerateRefundRetryRequests to request generator RefundRetryBillingRequestGenerator

Specified by:

sendToRefundRetryBillingRequestGenerator in interface BillingJobMessageSender

sendToBillingProcessingRequestInitializer

public void sendToBillingProcessingRequestInitializer(InitializeBillingProcessingRequests message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message InitializeBillingProcessingRequests to billing processing request initializer BillingProcessingRequestInitializer

Specified by:

sendToBillingProcessingRequestInitializer in interface BillingJobMessageSender

sendToPaymentProcessorHandler

public void sendToPaymentProcessorHandler(ProcessPayments message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message ProcessPayments to the Payment Processor Handler PaymentProcessorHandler

Specified by:

sendToPaymentProcessorHandler in interface BillingJobMessageSender

sendToPaymentProcessingResultHandler

public void sendToPaymentProcessingResultHandler(PaymentsProcessed message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message PaymentsProcessed to payment processing result handler PaymentProcessingResultHandler

Specified by:

sendToPaymentProcessingResultHandler in interface BillingJobMessageSender

sendToPaymentAccountProcessingResultUpdater

public void sendToPaymentAccountProcessingResultUpdater(PaymentAccountProcessedMessage message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message PaymentAccountProcessedEvent to payment account processing result updater.

Specified by:

sendToPaymentAccountProcessingResultUpdater in interface BillingJobMessageSender

sendToBillingProcessingRequestFinalizer

public void sendToBillingProcessingRequestFinalizer(FinalizeBillingProcessingRequests message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message FinalizeBillingProcessingRequests to billing processing request finalizer BillingProcessingRequestFinalizer

Specified by:

sendToBillingProcessingRequestFinalizer in interface BillingJobMessageSender

sendToEventPaymentUpdater

public void sendToEventPaymentUpdater(UpdateBillingEventPayments message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message UpdateBillingEventPayments to event payment updater EventPaymentUpdater

Specified by:

sendToEventPaymentUpdater in interface BillingJobMessageSender

sendToRefundEventUpdater

public void sendToRefundEventUpdater(UpdateRefundEvents message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message UpdateRefundEvents to refund event updater RefundEventUpdater

Specified by:

sendToRefundEventUpdater in interface BillingJobMessageSender

sendToBillingProcessingResultHandler

public void sendToBillingProcessingResultHandler(ProcessBillingEventPaymentResults message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: BillingJobMessageSender

Send message BillingEventPaymentProcessedEvent to billing processing result handler.

Specified by:

sendToBillingProcessingResultHandler in interface BillingJobMessageSender

sendToGrantEntitlementHandler

public void sendToGrantEntitlementHandler(EntitlementProcessingRequest message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Specified by:

sendToGrantEntitlementHandler in interface BillingJobMessageSender

sendToRevokeEntitlementHandler

public void sendToRevokeEntitlementHandler(EntitlementProcessingRequest message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Specified by:

sendToRevokeEntitlementHandler in interface BillingJobMessageSender

sendToTaxProcessorHandler

public void sendToTaxProcessorHandler(TaxCalculationHandlerRequests message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Specified by:

sendToTaxProcessorHandler in interface BillingJobMessageSender

sendToTaxProcessorResultHandler

public void sendToTaxProcessorResultHandler(TaxCalculationResultProcessorRequests message,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Specified by:

sendToTaxProcessorResultHandler in interface BillingJobMessageSender