org.camunda.bpm.engine.impl.telemetry.reporter

Class TelemetryReporter

java.lang.Object

org.camunda.bpm.engine.impl.telemetry.reporter.TelemetryReporter

public class TelemetryReporter
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected CommandExecutor	commandExecutor
protected Data	data
static long	DEFAULT_INIT_REPORT_DELAY_SECONDS Report after 5 minutes the first time so that we get an initial ping quickly.
static long	EXTENDED_INIT_REPORT_DELAY_SECONDS Report after 3 hours for the first time so that other modules (e.g.
protected org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>>	httpConnector
protected static TelemetryLogger	LOG
protected MetricsRegistry	metricsRegistry
protected long	reportingIntervalInSeconds
protected String	telemetryEndpoint
protected TelemetryRegistry	telemetryRegistry
protected int	telemetryRequestRetries
protected int	telemetryRequestTimeout
protected TelemetrySendingTask	telemetrySendingTask
protected Timer	timer

Constructor Summary

Constructors

Constructor and Description
TelemetryReporter(CommandExecutor commandExecutor, String telemetryEndpoint, int telemetryRequestRetries, long telemetryReportingPeriod, Data data, org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>> httpConnector, TelemetryRegistry telemetryRegistry, MetricsRegistry metricsRegistry, int telemetryRequestTimeout)

Method Summary

Modifier and Type	Method and Description
org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>>	getHttpConnector()
long	getInitialReportingDelaySeconds()
long	getReportingIntervalInSeconds()
String	getTelemetryEndpoint()
TelemetrySendingTask	getTelemetrySendingTask()
protected void	initTelemetrySendingTask(boolean sendInitialMessage)
boolean	isScheduled()
void	reportNow()
void	reschedule(boolean sendInitialMessage)
void	setTelemetrySendingTask(TelemetrySendingTask telemetrySendingTask)
void	start(boolean sendInitialMessage)
void	stop()
void	stop(boolean report)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final TelemetryLogger LOG

reportingIntervalInSeconds

protected long reportingIntervalInSeconds

DEFAULT_INIT_REPORT_DELAY_SECONDS

public static long DEFAULT_INIT_REPORT_DELAY_SECONDS

Report after 5 minutes the first time so that we get an initial ping quickly. 5 minutes delay so that other modules (e.g. those collecting the app server name) can contribute their data.

EXTENDED_INIT_REPORT_DELAY_SECONDS

public static long EXTENDED_INIT_REPORT_DELAY_SECONDS

Report after 3 hours for the first time so that other modules (e.g. those collecting the app server name) can contribute their data and test cases which accidentally enable reporting are very unlikely to send data.

telemetrySendingTask

protected TelemetrySendingTask telemetrySendingTask

timer

protected Timer timer

commandExecutor

protected CommandExecutor commandExecutor

telemetryEndpoint

protected String telemetryEndpoint

telemetryRequestRetries

protected int telemetryRequestRetries

data

protected Data data

httpConnector

protected org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>> httpConnector

telemetryRegistry

protected TelemetryRegistry telemetryRegistry

metricsRegistry

protected MetricsRegistry metricsRegistry

telemetryRequestTimeout

protected int telemetryRequestTimeout

Constructor Detail

TelemetryReporter

public TelemetryReporter(CommandExecutor commandExecutor,
                         String telemetryEndpoint,
                         int telemetryRequestRetries,
                         long telemetryReportingPeriod,
                         Data data,
                         org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>> httpConnector,
                         TelemetryRegistry telemetryRegistry,
                         MetricsRegistry metricsRegistry,
                         int telemetryRequestTimeout)

Method Detail

initTelemetrySendingTask

protected void initTelemetrySendingTask(boolean sendInitialMessage)

start

public void start(boolean sendInitialMessage)

reschedule

public void reschedule(boolean sendInitialMessage)

stop

public void stop()

stop

public void stop(boolean report)

reportNow

public void reportNow()

isScheduled

public boolean isScheduled()

getReportingIntervalInSeconds

public long getReportingIntervalInSeconds()

getTelemetrySendingTask

public TelemetrySendingTask getTelemetrySendingTask()

setTelemetrySendingTask

public void setTelemetrySendingTask(TelemetrySendingTask telemetrySendingTask)

getTelemetryEndpoint

public String getTelemetryEndpoint()

getHttpConnector

public org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>> getHttpConnector()

getInitialReportingDelaySeconds

public long getInitialReportingDelaySeconds()