unistack-org/micro-broker-nats
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 8 Wiki Activity

fix double pointer for nats unmarshal

Browse Source
This commit is contained in:
Asim Aslam 2016-12-06 20:35:00 +00:00 committed by Vasiliy Tolstov
parent f8714d4cd9
commit 2f94cdd04c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nats.go
View File

@ -117,11 +117,11 @@ func (n *nbroker) Subscribe(topic string, handler broker.Handler, opts ...broker
}
fn := func(msg *nats.Msg) {
var m *broker.Message
var m broker.Message
if err := n.opts.Codec.Unmarshal(msg.Data, &m); err != nil {
return
}
handler(&publication{m: m, t: topic})
handler(&publication{m: &m, t: topic})
}
var sub *nats.Subscription