From 5fe9dc3a403cdfe0b41830aac16ef8b02f7e0e4e Mon Sep 17 00:00:00 2001 From: Nick White Date: Mon, 16 Sep 2019 14:57:14 +0100 Subject: Be more careful to try to grab the message after a heartbeat failure more quickly Rather than waiting for the whole length of a visibility timeout, in which time another process may grab the message, instead wait a short amount of time, each time the message is searched for. Also add a bit more logging. --- bookpipeline/cmd/bookpipeline/main.go | 2 ++ 1 file changed, 2 insertions(+) (limited to 'bookpipeline/cmd/bookpipeline/main.go') diff --git a/bookpipeline/cmd/bookpipeline/main.go b/bookpipeline/cmd/bookpipeline/main.go index f1309ca..f8b0b68 100644 --- a/bookpipeline/cmd/bookpipeline/main.go +++ b/bookpipeline/cmd/bookpipeline/main.go @@ -322,8 +322,10 @@ func processBook(msg bookpipeline.Qmsg, conn Pipeliner, process func(chan string case m, ok := <-msgc : if ok { msg = m + conn.GetLogger().Println("Using new message handle to delete message from old queue") } default: + conn.GetLogger().Println("Using original message handle to delete message from old queue") } conn.GetLogger().Println("Deleting original message from queue", fromQueue) -- cgit v1.2.1-24-ge1ad