update
This commit is contained in:
parent
8446b578c2
commit
eab463ab57
|
@ -21,7 +21,7 @@ func (sv Server) Reply(msg *nats.Msg, payload []byte) error {
|
||||||
err := sv.instance.Publish(msg.Reply, payload)
|
err := sv.instance.Publish(msg.Reply, payload)
|
||||||
|
|
||||||
// Ack message
|
// Ack message
|
||||||
msg.Ack()
|
// msg.Ack()
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue