Class DefaultFilteringService

java.lang.Object
de.hybris.platform.outboundsync.job.impl.DefaultFilteringService
All Implemented Interfaces:
FilteringService

public class DefaultFilteringService extends Object implements FilteringService
A filter service for all outbound item dto's collected by StreamingChangesCollector.
  • Constructor Details

    • DefaultFilteringService

      public DefaultFilteringService(@NotNull @NotNull OutboundItemConsumer outboundItemConsumer)
      Constructor to create FilteringService
      Parameters:
      outboundItemConsumer - - outbound item consumer responsible for consuming changes that will not be sent outbound
  • Method Details

    • applyFilters

      public Optional<OutboundItemDTO> applyFilters(@NotNull @NotNull OutboundItemDTO dto, @NotNull @NotNull IntegrationObjectModel io)
      Searches for an applicable SyncFilter from the syncFilterList and calls evaluate on the first applicable filter if any is found. Consumes the item change dto and returns optional empty if an applicable SyncFilter filters it out when evaluating.
      Specified by:
      applyFilters in interface FilteringService
      Parameters:
      dto - - outbound item dto
      io - - integration object
      Returns:
      - outbound item dto that will be sent to the spring configuration channel for synchronization, or an empty optional
    • setSyncFilterList

      public void setSyncFilterList(List<SyncFilter> syncFilterList)