unistack-org/micro-broker-stan
4
0
Fork 0
Code Issues 2 Pull Requests Packages Projects Releases 5 Wiki Activity

simplify stan handler error handling

Browse Source
This commit is contained in:
Asim Aslam 2019-01-28 08:02:42 +00:00 committed by Vasiliy Tolstov
parent 6c04d1a29b
commit 6eb8ae50d5
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
stan.go
View File

@ -224,14 +224,16 @@ func (n *stanBroker) Subscribe(topic string, handler broker.Handler, opts ...bro
fn := func(msg *stan.Msg) { fn := func(msg *stan.Msg) {
var m broker.Message var m broker.Message
var err error
if err = n.opts.Codec.Unmarshal(msg.Data, &m); err != nil { // unmarshal message
if err := n.opts.Codec.Unmarshal(msg.Data, &m); err != nil {
return return
} }
err = handler(&publication{m: &m, msg: msg, t: msg.Subject})
if err == nil && successAutoAck && !opt.AutoAck { // execute the handler
msg.Ack() err := handler(&publication{m: &m, msg: msg, t: msg.Subject})
} else if err != nil && opt.AutoAck { // if there's no error and success auto ack is enabled ack it
if err == nil && successAutoAck {
msg.Ack() msg.Ack()
} }
} }