From 7b79288b55077c5f378b5f5e45f2ac8fd3be76ee Mon Sep 17 00:00:00 2001 From: Nick White Date: Sat, 14 Sep 2019 08:24:27 +0100 Subject: Ensure enough time has elapsed before looking for the message to reget in the case of heartbeat running out --- bookpipeline/cmd/bookpipeline/main.go | 1 + 1 file changed, 1 insertion(+) (limited to 'bookpipeline/cmd/bookpipeline/main.go') diff --git a/bookpipeline/cmd/bookpipeline/main.go b/bookpipeline/cmd/bookpipeline/main.go index 610b969..f1309ca 100644 --- a/bookpipeline/cmd/bookpipeline/main.go +++ b/bookpipeline/cmd/bookpipeline/main.go @@ -242,6 +242,7 @@ func heartbeat(conn Pipeliner, t *time.Ticker, msg bookpipeline.Qmsg, queue stri return } if m.Id != "" { + conn.GetLogger().Println("Replaced message handle as visibilitytimeout limit was reached") currentmsg = m // TODO: maybe handle communicating new msg more gracefully than this for range msgc { -- cgit v1.2.1-24-ge1ad