How to delete an acked subject message #4215
-
How do I get j.Subscribe(subject, func(msg *nats.Msg) {
err := cb(msg.Data)
if err != nil {
return
}
err = msg.Ack()
if err != nil {
log.Errorf(context.Background(), "[SubscribeSubject] Unable to Ack: %+v", err)
return
}
j.DeleteMsg(name string, seq uint64, opts ...nats.JSOpt)
}) Thank you |
Beta Was this translation helpful? Give feedback.
Answered by
derekcollison
Jun 5, 2023
Replies: 1 comment
-
|
Beta Was this translation helpful? Give feedback.
0 replies
Answer selected by
agufagit
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
meta, err := msg.Metadata()