Class DefaultDataHubOutboundClient

java.lang.Object
com.hybris.datahub.core.rest.client.DefaultDataHubOutboundClient
All Implemented Interfaces:
DataHubOutboundClient

public class DefaultDataHubOutboundClient extends Object implements DataHubOutboundClient
Implementation of a REST client for communication with the Data Hub
  • Constructor Details

    • DefaultDataHubOutboundClient

      public DefaultDataHubOutboundClient()
      Instantiates this client.
    • DefaultDataHubOutboundClient

      protected DefaultDataHubOutboundClient(javax.ws.rs.client.Client cl)
    • DefaultDataHubOutboundClient

      public DefaultDataHubOutboundClient(com.hybris.datahub.client.ClientConfiguration cfg)
  • Method Details

    • exportData

      public ResultData exportData(String[] csvContent, String dataFeed, String rawItemType) throws DataHubCommunicationException
      Specified by:
      exportData in interface DataHubOutboundClient
      Parameters:
      csvContent - the CSV content
      dataFeed - the name of the data feed
      rawItemType - the raw item type
      Returns:
      the result of the export
      Throws:
      DataHubCommunicationException - if communication with the Data Hub server failed
    • deleteItem

      public ResultData deleteItem(String poolName, String canonicalItemType, Map<String,String> keyFields) throws DataHubCommunicationException
      Description copied from interface: DataHubOutboundClient
      Deletes item with an integration key comprised of the specified primary keys, of the type specified, in the pool specified on the Data Hub server
      Specified by:
      deleteItem in interface DataHubOutboundClient
      Parameters:
      poolName - name of the data pool the item to be deleted resides in
      canonicalItemType - type code for the canonical item to delete
      keyFields - map of primary key attribute names and values to uniquely identify the item to be deleted
      Returns:
      the result of the deletion
      Throws:
      DataHubCommunicationException - if communication with the Data Hub server failed
    • deleteByFeed

      public ResultData deleteByFeed(String feedName, String rawItemType) throws DataHubCommunicationException
      Description copied from interface: DataHubOutboundClient
      Deletes all items originating from the data feed and raw item type specified
      Specified by:
      deleteByFeed in interface DataHubOutboundClient
      Parameters:
      feedName - Name of the data feed the items originated from
      rawItemType - Name of the raw item type the items originated from
      Returns:
      the result of the deletion
      Throws:
      DataHubCommunicationException - if communication with the Data Hub server failed
    • deleteByFeed

      public ResultData deleteByFeed(String feedName, String rawItemType, Map<String,Object> keyFields) throws DataHubCommunicationException
      Description copied from interface: DataHubOutboundClient
      Deletes item with an integration key comprised of the specified primary keys, originating from the data feed and raw item type specified
      Specified by:
      deleteByFeed in interface DataHubOutboundClient
      Parameters:
      feedName - Name of the data feed the items originated from
      rawItemType - Name of the raw item type the items originated from
      keyFields - Map of primary key attribute names and values to uniquely identify the item to be deleted
      Returns:
      the result of the deletion
      Throws:
      DataHubCommunicationException - if communication with the Data Hub server failed
    • setRetryTemplate

      public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
    • setDataHubUrl

      public void setDataHubUrl(String dataHubUrl)
      Specifies DataHub location.
      Parameters:
      dataHubUrl - URL for the DataHub server to exchange data with.