Skip to content

Instantly share code, notes, and snippets.

@ripienaar

ripienaar/confirmed-ack.go

Created August 19, 2020 12:31
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ripienaar/4ec3775fa1586180c06433ce47fc6b56 to your computer and use it in GitHub Desktop.
Save ripienaar/4ec3775fa1586180c06433ce47fc6b56 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
confirmed-ack.go
func(m *nats.Msg) {
// process m
_, err := nc.Request(m.reply, []byte("+ACK"), 2*time.Second)
// err here means ack was not confirmed
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment