diff options
| author |   srinivasyanamadala <srinivas.yanamadala@techmahindra.com> | 2025-02-03 16:44:33 +0100 |
|---|---|---|
| committer | srinivasyanamadala <srinivas.yanamadala@techmahindra.com> | 2025-02-07 13:00:34 +0100 |
| commit | c98f9a1086c1ede4b6ccb6a566197533b3001826 (patch) | |
| tree | 78cb519b8a7dce509306a0de34da957d49721150 /pkg/kafkacomm | |
| parent | cb3e442497fc8b847d878bdcfb20276bc725718d (diff) | |
Issue-ID: POLICY-5261
Change-Id: I6e55a4050025fe8626a0a8cd3e114e7d3f137767
Signed-off-by: srinivasyanamadala <srinivas.yanamadala@techmahindra.com>
Diffstat (limited to 'pkg/kafkacomm')
| -rw-r--r-- | pkg/kafkacomm/publisher/pdp-heartbeat.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/pkg/kafkacomm/publisher/pdp-heartbeat.go b/pkg/kafkacomm/publisher/pdp-heartbeat.go index 0c48189..42a5e70 100644 --- a/pkg/kafkacomm/publisher/pdp-heartbeat.go +++ b/pkg/kafkacomm/publisher/pdp-heartbeat.go @@ -69,7 +69,9 @@ func StartHeartbeatIntervalTimer(intervalMs int64, s PdpStatusSender) { for { select { case <-ticker.C: - sendPDPHeartBeat(s) + if err := sendPDPHeartBeat(s); err != nil { + log.Errorf("Failed to send PDP Heartbeat: %v", err) + } case <-stopChan: ticker.Stop() return |