Package org.alfresco.heartbeat.datasender

Class HBDataSenderServiceImpl

java.lang.Object
org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl
All Implemented Interfaces:
HBDataSenderService
public class HBDataSenderServiceImpl extends Object implements HBDataSenderService
Heartbeat Data Sender service implementation - collected data is sent to an ingestion endpoint (AWS).
Author:
Ancuta Morarasu

  • Constructor Details

    • HBDataSenderServiceImpl

      protected HBDataSenderServiceImpl()

  • Method Details

    • getScheduler

      protected HBSendDataScheduler getScheduler()

    • setScheduler

      protected void setScheduler(HBSendDataScheduler scheduler)

    • setCacheMaxEntries

      protected void setCacheMaxEntries(long maxEntries)

    • setBatchSize

      protected void setBatchSize(int size)

    • setHeartBeatUrl

      protected void setHeartBeatUrl(String heartBeatUrl)

    • getHeartBeatIngestionUrl

      protected String getHeartBeatIngestionUrl()

    • isTargetAvailable

      protected boolean isTargetAvailable()

    • getCacheCount

      protected int getCacheCount()

    • enable

      public void enable(boolean heartbeatState)
      Description copied from interface: HBDataSenderService
      Enables or disables the heartbeat sending data process.
      Specified by:
      enable in interface HBDataSenderService
      Parameters:
      heartbeatState - true to enable sending the collected data, false otherwise

    • sendData

      public void sendData(HBData data)
      Description copied from interface: HBDataSenderService
      Sends heartbeat collected data to the Heartbeat server
      Specified by:
      sendData in interface HBDataSenderService
      Parameters:
      data - collected data

    • sendData

      public void sendData(List<HBData> dataBatch)
      Description copied from interface: HBDataSenderService
      Sends a list of heartbeat collected data to the Heartbeat server
      Specified by:
      sendData in interface HBDataSenderService
      Parameters:
      dataBatch - batch of collected data

    • process

      public void process()
      Process the data in batches.

    • process

      public void process(Consumer<List<HBData>> consumer)
      Process the data in batches with a given consumer.
      Parameters:
      consumer - the hb data consumer