Package com.broadleafcommerce.common.messaging

Class PersistenceMessageNotificationHandler

java.lang.Object

com.broadleafcommerce.common.messaging.notification.DefaultNotificationHandler

com.broadleafcommerce.common.messaging.PersistenceMessageNotificationHandler

All Implemented Interfaces:

NotificationHandler, org.springframework.core.Ordered

public class PersistenceMessageNotificationHandler
extends DefaultNotificationHandler

The NotificationHandler implementation specifically for sending PersistenceMessage via PersistenceProducer.

Author:

Samarth Dhruva (samarthd)

Field Summary

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor

Description

PersistenceMessageNotificationHandler(ChannelSupplier persistenceProducerSupplier, DurableNotificationProperties properties, List<IgnoredNotificationStateRepository> ignoredRepositories, MessageFactory<?> messageFactory, MessageSerializationHelper helper, List<PersistenceMessageAckedHandler> persistenceMessageAckedHandlers, com.broadleafcommerce.common.extension.data.DataRouteReference dataRouteReference)

Method Summary

Modifier and Type	Method	Description
void	afterSuccessfulAcknowledgement(@NonNull Object nativeId, @NonNull NotificationStateAware notificationStateAware, NotificationStateRepository repository)	Invokes each PersistenceMessageAckedHandler.
protected List<PersistenceMessageAckedHandler>	getHandlersInScope(Object persistedDomainEntity)
protected List<PersistenceMessageAckedHandler>	getPersistenceMessageAckedHandlers()

Methods inherited from class com.broadleafcommerce.common.messaging.notification.DefaultNotificationHandler

createMessageSafely, createMessageSupplier, getChannelModifier, getWaitTimeExp, handle, notify, sendRemote, sendRemoteMessageSafely, unwrapNotificationState

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.broadleafcommerce.common.messaging.notification.NotificationHandler

getOrder

Constructor Detail

PersistenceMessageNotificationHandler

public PersistenceMessageNotificationHandler(ChannelSupplier persistenceProducerSupplier,
                                             DurableNotificationProperties properties,
                                             List<IgnoredNotificationStateRepository> ignoredRepositories,
                                             MessageFactory<?> messageFactory,
                                             MessageSerializationHelper helper,
                                             @Nullable
                                             List<PersistenceMessageAckedHandler> persistenceMessageAckedHandlers,
                                             @Nullable
                                             com.broadleafcommerce.common.extension.data.DataRouteReference dataRouteReference)

Method Detail

afterSuccessfulAcknowledgement

public void afterSuccessfulAcknowledgement(@NonNull @NonNull
                                           @NonNull Object nativeId,
                                           @NonNull @NonNull
                                           @NonNull NotificationStateAware notificationStateAware,
                                           @NonNull
                                           NotificationStateRepository repository)

Invokes each PersistenceMessageAckedHandler.

Parameters:

nativeId - the native id of the notificationStateAware entity

notificationStateAware - the containing entity of the notification state for which a message was successfully sent

repository - the repository corresponding to the notificationStateAware entity

getHandlersInScope

protected List<PersistenceMessageAckedHandler> getHandlersInScope(Object persistedDomainEntity)

getPersistenceMessageAckedHandlers

protected List<PersistenceMessageAckedHandler> getPersistenceMessageAckedHandlers()