From e519dcdfbc77b804bd45e62fe28d74a58e448935 Mon Sep 17 00:00:00 2001 From: "i.navrotskyj" Date: Tue, 30 Apr 2024 13:09:49 +0300 Subject: [PATCH] WTEL-4498 --- mq/rabbit/client.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/mq/rabbit/client.go b/mq/rabbit/client.go index 40eead7b..316889d2 100644 --- a/mq/rabbit/client.go +++ b/mq/rabbit/client.go @@ -96,6 +96,9 @@ func (a *AMQP) readMessage(msg *amqp.Delivery) { wlog.Error(fmt.Sprintf("%s :\n%s", err.Error(), string(msg.Body))) return } + if ev.Event == "heartbeat" { + return // TODO + } a.callEvent <- ev case model.ChatExchange: