Package de.hybris.platform.outboundsync.job.impl
package de.hybris.platform.outboundsync.job.impl
-
ClassDescriptionA parser that converts
ItemChangeDTO.getInfo()string into a structured format.A filter for non-delete changes collected byDefaultFilteringService.Implementation of theChangeInfoParserthat parses info from a JSON string of the following format:"{ "key": "..", "type": "..", "rootType": ".." }", in which order of the attributes is arbitrary and attribute "key" contains value of the changed item integration key; attribute "type" contains value of the item type; attribute "rootType" contains value of the item type that is navigated from the changed item and corresponds to the root item in the integration object used to synchronize the change.Streaming changes collector implementation for the factory.A filter service for all outbound item dto's collected byStreamingChangesCollector.Default implementation of theOutboundItemFactoryImplementation of theOutboundSyncJobRegisterthat is used by default when no custom implementation is injected.A filter for changes collected byStreamingChangesCollector, that passes the change through, if the changed item type and type of the root item, it relates to, belong to the integration object.ThisJobPerformablecollects the changes specified in theStreamConfigurationand send them out via theItemChangeSender.OutboundSyncEventHandler<T extends OutboundSyncEvent>Handler for calculating anOutboundSyncStatebased on aOutboundSyncEventand, if it exists, aOutboundSyncStatewith the previous status.An object controlling and representing state of a single outbound sync job.A registry of currently running outbound sync jobs.This aggregator keeps track of an outbound sync job by aggregatingOutboundSyncEvents indicating the job progress.Keeps track of outbound sync cron jobs and stops "stuck" jobs, if it sees no activity in them.Represents state of a single outbound sync cron job run.A builder for creating immutableOutboundSyncStateAllows implementors to be notified about outbound sync job state changes.