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

Class DefaultOutboundSyncService

java.lang.Object

de.hybris.platform.outboundsync.activator.impl.DefaultOutboundSyncService

All Implemented Interfaces:

OutboundSyncService

public class DefaultOutboundSyncService
extends java.lang.Object
implements OutboundSyncService

Default implementation of OutboundSyncService that uses OutboundServiceFacade for sending changes to the destinations.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
DefaultOutboundSyncService()

Method Summary

Modifier and Type	Method	Description
protected void	consumeChanges(OutboundItemDTOGroup outboundItemDTOGroup)
protected ItemModel	findItemByPk(PK pk)
protected java.util.Optional<CronJobModel>	getCronJob(PK cronJobPk)	Gets the CronJobModel from the database
protected ItemModelSearchService	getItemModelSearchService()
protected ModelService	getModelService()	Deprecated, for removal: This API element is subject to removal in a future version. This method will be removed without alternative
OutboundItemConsumer	getOutboundItemConsumer()
protected OutboundItemFactory	getOutboundItemFactory()
OutboundServiceFacade	getOutboundServiceFacade()
protected SyncRetryService	getSyncRetryService()
protected void	handleError(OutboundItemDTOGroup outboundItemDTOGroup)
protected void	handleResponse(org.springframework.http.ResponseEntity<java.util.Map> responseEntity, OutboundItemDTOGroup outboundItemDTOGroup)
protected void	handleSuccessfulSync(OutboundItemDTOGroup outboundItemDTOGroup)
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	setEventService(EventService eventService)
void	setItemModelSearchService(ItemModelSearchService itemModelSearchService)
void	setModelService(ModelService modelService)	Deprecated, for removal: This API element is subject to removal in a future version. Use setItemModelSearchService(ItemModelSearchService) instead
void	setOutboundItemConsumer(OutboundItemConsumer outboundItemConsumer)
void	setOutboundItemFactory(OutboundItemFactory factory)
void	setOutboundServiceFacade(OutboundServiceFacade outboundServiceFacade)
void	setSyncRetryService(SyncRetryService syncRetryService)
void	sync(java.util.Collection<OutboundItemDTO> outboundItemDTOs)	Consumes a DTO with the item changed information and handles the message based on the change type.
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

DefaultOutboundSyncService

public DefaultOutboundSyncService()

Method Detail

sync

public void sync(java.util.Collection<OutboundItemDTO> outboundItemDTOs)

Description copied from interface: OutboundSyncService

Consumes a DTO with the item changed information and handles the message based on the change type.

Specified by:

sync in interface OutboundSyncService

Parameters:

outboundItemDTOs - A collection of DTOs with the information about the changes in the item.

handleError

protected void handleError(OutboundItemDTOGroup outboundItemDTOGroup)

handleResponse

protected void handleResponse(org.springframework.http.ResponseEntity<java.util.Map> responseEntity,
                              OutboundItemDTOGroup outboundItemDTOGroup)

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()

findItemByPk

protected ItemModel findItemByPk(PK pk)

handleSuccessfulSync

protected void handleSuccessfulSync(OutboundItemDTOGroup outboundItemDTOGroup)

consumeChanges

protected void consumeChanges(OutboundItemDTOGroup outboundItemDTOGroup)

getModelService

@Deprecated(since="2105",
            forRemoval=true)
protected ModelService getModelService()

Deprecated, for removal: This API element is subject to removal in a future version.

This method will be removed without alternative

setModelService

@Deprecated(since="2105",
            forRemoval=true)
public void setModelService(ModelService modelService)

Deprecated, for removal: This API element is subject to removal in a future version.

Use setItemModelSearchService(ItemModelSearchService) instead

getOutboundItemFactory

protected OutboundItemFactory getOutboundItemFactory()

setOutboundItemFactory

public void setOutboundItemFactory(OutboundItemFactory factory)

getOutboundServiceFacade

public OutboundServiceFacade getOutboundServiceFacade()

setOutboundServiceFacade

public void setOutboundServiceFacade(OutboundServiceFacade outboundServiceFacade)

getOutboundItemConsumer

public OutboundItemConsumer getOutboundItemConsumer()

setOutboundItemConsumer

public void setOutboundItemConsumer(OutboundItemConsumer outboundItemConsumer)

getSyncRetryService

protected SyncRetryService getSyncRetryService()

setSyncRetryService

public void setSyncRetryService(SyncRetryService syncRetryService)

setEventService

public void setEventService(EventService eventService)

getItemModelSearchService

protected ItemModelSearchService getItemModelSearchService()

setItemModelSearchService

public void setItemModelSearchService(ItemModelSearchService itemModelSearchService)

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