remove ack git reply func
This commit is contained in:
parent
eab463ab57
commit
b5f1a7e93e
|
@ -18,11 +18,7 @@ func (sv Server) Request(subject string, payload []byte) (*nats.Msg, error) {
|
||||||
|
|
||||||
// Reply ...
|
// Reply ...
|
||||||
func (sv Server) Reply(msg *nats.Msg, payload []byte) error {
|
func (sv Server) Reply(msg *nats.Msg, payload []byte) error {
|
||||||
err := sv.instance.Publish(msg.Reply, payload)
|
return sv.instance.Publish(msg.Reply, payload)
|
||||||
|
|
||||||
// Ack message
|
|
||||||
// msg.Ack()
|
|
||||||
return err
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Subscribe ...
|
// Subscribe ...
|
||||||
|
|
Loading…
Reference in New Issue