In RabbitListener I see the following
go func() {
for d := range msg {
if err := q.handler.Consume(string(d.Body)); err != nil {
logx.Errorf("Error on consuming: %s, error: %v", string(d.Body), err)
}
}
}()
Is it possible to call AutoAck manually like this:
go func() {
for d := range msg {
if err := q.handler.Consume(string(d.Body)); err != nil {
logx.Errorf("Error on consuming: %s, error: %v", string(d.Body), err)
}else if !que.AutoAck {
d.Ack(que.AutoAck)
}
}
}()