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 Summary

Constructors

Modifier	Constructor and Description
protected	HBDataSenderServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	enable(boolean heartbeatState) Enables or disables the heartbeat sending data process.
protected int	getCacheCount()
protected String	getHeartBeatIngestionUrl()
protected HBSendDataScheduler	getScheduler()
protected boolean	isTargetAvailable()
void	process() Process the data in batches.
void	process(Consumer<List<HBData>> consumer) Process the data in batches with a given consumer.
void	sendData(HBData data) Sends heartbeat collected data to the Heartbeat server
void	sendData(List<HBData> dataBatch) Sends a list of heartbeat collected data to the Heartbeat server
protected void	setBatchSize(int size)
protected void	setCacheMaxEntries(long maxEntries)
protected void	setHeartBeatUrl(String heartBeatUrl)
protected void	setScheduler(HBSendDataScheduler scheduler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HBDataSenderServiceImpl

protected HBDataSenderServiceImpl()

Method Detail

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.