diff options
| author | Timotej S <6674623+underhood@users.noreply.github.com> | 2022-06-06 12:05:32 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-06-06 12:05:32 +0200 |
| commit | 123e923f76ad2cc458dd98b01ba8b29f2306bee2 (patch) | |
| tree | 3f57835986e0381c6ab973b142ad8c42398f82f5 /streaming | |
| parent | e6f1aeb54c5b17f7ad5315fd97c6e1dcdd03207e (diff) | |
Allow usage of the new MQTT 5 implementation (#12838)
* adds support for new MQTT5 implementation in agent, currently by default disabled as Tech Preview
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/receiver.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/streaming/receiver.c b/streaming/receiver.c index 4685f6bcd2..d20658e658 100644 --- a/streaming/receiver.c +++ b/streaming/receiver.c @@ -682,9 +682,9 @@ static int rrdpush_receive(struct receiver_state *rpt) cd.version = rpt->stream_version; -#if defined(ENABLE_ACLK) +#if defined(ENABLE_NEW_CLOUD_PROTOCOL) // in case we have cloud connection we inform cloud - // new slave connected + // new child connected if (netdata_cloud_setting) aclk_host_state_update(rpt->host, 1); #endif @@ -696,9 +696,9 @@ static int rrdpush_receive(struct receiver_state *rpt) error("STREAM %s [receive from [%s]:%s]: disconnected (completed %zu updates).", rpt->hostname, rpt->client_ip, rpt->client_port, count); -#if defined(ENABLE_ACLK) +#if defined(ENABLE_NEW_CLOUD_PROTOCOL) // in case we have cloud connection we inform cloud - // new slave connected + // new child connected if (netdata_cloud_setting) aclk_host_state_update(rpt->host, 0); #endif |