use msg.Subject as topic

2017-01-12 20:21:49 +00:00
parent 040c291e74
commit 8898b42bda
1 changed files with 1 additions and 1 deletions
--- a/nats.go
+++ b/nats.go
@@ -122,7 +122,7 @@ func (n *nbroker) Subscribe(topic string, handler broker.Handler, opts ...broker
 		if err := n.opts.Codec.Unmarshal(msg.Data, &m); err != nil {
 			return
 		}
-		handler(&publication{m: &m, t: topic})
+		handler(&publication{m: &m, t: msg.Subject})
 	}

 	var sub *nats.Subscription