Package de.hybris.platform.outboundsync.activator.impl

Class DefaultDeleteOutboundSyncService

java.lang.Object

de.hybris.platform.outboundsync.activator.impl.DefaultDeleteOutboundSyncService

All Implemented Interfaces:

DeleteOutboundSyncService

public class DefaultDeleteOutboundSyncService
extends java.lang.Object
implements DeleteOutboundSyncService

Default implementation of the DeleteOutboundSyncService

Field Summary

Fields

Modifier and Type	Field	Description
protected EventService	eventService
protected ItemModelSearchService	itemModelSearchService
protected OutboundItemConsumer	outboundItemConsumer

Constructor Summary

Constructors

Constructor	Description
DefaultDeleteOutboundSyncService(@NotNull DeleteRequestSender deleteRequestSender, @NotNull ItemModelSearchService itemModelSearchService, @NotNull EventService eventService, @NotNull OutboundItemConsumer outboundItemConsumer)	Instantiates the delete sync service

Method Summary

Modifier and Type	Method	Description
protected java.util.Optional<CronJobModel>	getCronJob(PK cronJobPk)	Gets the CronJobModel from the database
protected void	publishSuccessfulCompletedEvent(PK cronJobPk, int changeItemCount)	Publish the CompletedOutboundSyncEvent with success set to true when the synchronization is done
protected void	publishSystemErrorEvent(PK cronJobPk, int changeItemCount)	Publish then SystemErrorOutboundSyncEvent if a system error occurs
protected void	publishUnSuccessfulCompletedEvent(PK cronJobPk, int changeItemCount)	Publish the CompletedOutboundSyncEvent with success set to false when the synchronization is done
void	sync(OutboundItemDTO deletedItem)	Synchronize the item deletion
protected void	syncInternal(PK cronJobPk, int changeItemCount, de.hybris.platform.outboundsync.activator.impl.BaseOutboundSyncService.Synchronizer synchronizer)	This method checks the cronjob is in the appropriate state before calling the BaseOutboundSyncService.Synchronizer.

Methods inherited from class java.lang.Object

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

Field Detail

itemModelSearchService

protected ItemModelSearchService itemModelSearchService

eventService

protected EventService eventService

outboundItemConsumer

protected OutboundItemConsumer outboundItemConsumer

Constructor Detail

DefaultDeleteOutboundSyncService

public DefaultDeleteOutboundSyncService(@NotNull
                                        @NotNull DeleteRequestSender deleteRequestSender,
                                        @NotNull
                                        @NotNull ItemModelSearchService itemModelSearchService,
                                        @NotNull
                                        @NotNull EventService eventService,
                                        @NotNull
                                        @NotNull OutboundItemConsumer outboundItemConsumer)

Instantiates the delete sync service

Parameters:

deleteRequestSender - Sender that sends the delete request

itemModelSearchService - Finder that retrieves an item model

eventService - Service to send events to update cronjob status

outboundItemConsumer - Consumer that consumes the delta detect change

Method Detail

sync

public void sync(OutboundItemDTO deletedItem)

Description copied from interface: DeleteOutboundSyncService

Synchronize the item deletion

Specified by:

sync in interface DeleteOutboundSyncService

Parameters:

deletedItem - Contains the data about the deleted item

syncInternal

protected void syncInternal(PK cronJobPk,
                            int changeItemCount,
                            de.hybris.platform.outboundsync.activator.impl.BaseOutboundSyncService.Synchronizer synchronizer)

This method checks the cronjob is in the appropriate state before calling the BaseOutboundSyncService.Synchronizer.

Here are the rules:

• If the job is aborting, an abort event is published. No synchronization will occur.
• If the job is in system error state, an system error event is published. No synchronization will occur.
• If the job is not aborted and not in system error state, synchronization will occur.

Parameters:

cronJobPk - PK of the cronjob being executed

changeItemCount - The number of changed items detected

synchronizer - Synchronizer to execute when the cronjob is in the appropriate state

publishSystemErrorEvent

protected void publishSystemErrorEvent(PK cronJobPk,
                                       int changeItemCount)

Publish then SystemErrorOutboundSyncEvent if a system error occurs

Parameters:

cronJobPk - PK of the cronjob being executed

changeItemCount - The number of changed items detected

publishSuccessfulCompletedEvent

protected void publishSuccessfulCompletedEvent(PK cronJobPk,
                                               int changeItemCount)

Publish the CompletedOutboundSyncEvent with success set to true when the synchronization is done

Parameters:

cronJobPk - PK of the cronjob being executed

changeItemCount - The number of changed items detected

publishUnSuccessfulCompletedEvent

protected void publishUnSuccessfulCompletedEvent(PK cronJobPk,
                                                 int changeItemCount)

Publish the CompletedOutboundSyncEvent with success set to false when the synchronization is done

Parameters:

cronJobPk - PK of the cronjob being executed

changeItemCount - The number of changed items detected

getCronJob

protected java.util.Optional<CronJobModel> getCronJob(PK cronJobPk)

Gets the CronJobModel from the database

Parameters:

cronJobPk - PK of the cronjob being executed

Returns:

The cronjob wrapped in an Optional if found, otherwise an Optional.empty()