diff --git a/server_reqres.go b/server_reqres.go index 303c954..deb9b88 100644 --- a/server_reqres.go +++ b/server_reqres.go @@ -21,7 +21,7 @@ func (sv Server) Reply(msg *nats.Msg, payload []byte) error { err := sv.instance.Publish(msg.Reply, payload) // Ack message - msg.Ack() + // msg.Ack() return err }