diff --git a/micro/request.go b/micro/request.go index 380f4945c..e282d4576 100644 --- a/micro/request.go +++ b/micro/request.go @@ -58,6 +58,9 @@ type ( // Subject returns underlying NATS message subject. Subject() string + + // Reply returns underlying NATS message reply subject. + Reply() string } // Headers is a wrapper around [*nats.Header] @@ -186,6 +189,11 @@ func (r *request) Subject() string { return r.msg.Subject } +// Reply returns underlying NATS message reply subject. +func (r *request) Reply() string { + return r.msg.Reply +} + // Get gets the first value associated with the given key. // It is case-sensitive. func (h Headers) Get(key string) string {