We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents d6e20e9 + 92bcb23 commit ad57c45Copy full SHA for ad57c45
go/worker.go
@@ -56,11 +56,11 @@ func main() {
56
go func() {
57
for d := range msgs {
58
log.Printf("Received a message: %s", d.Body)
59
- d.Ack(false)
60
dot_count := bytes.Count(d.Body, []byte("."))
61
t := time.Duration(dot_count)
62
time.Sleep(t * time.Second)
63
log.Printf("Done")
+ d.Ack(false)
64
}
65
}()
66
0 commit comments