Added full tests for nats ers

This commit is contained in:
Trial97
2021-06-25 15:30:29 +03:00
committed by Dan Christian Bogos
parent 81f2d722f6
commit e7bbbbdb2d
7 changed files with 236 additions and 49 deletions

View File

@@ -105,6 +105,7 @@ func (pstr *NatsPoster) parseOpt(opts map[string]interface{}, nodeID string, con
return
}
}
pstr.subject = utils.DefaultQueueID
if vals, has := opts[utils.NatsSubject]; has {
pstr.subject = utils.IfaceAsString(vals)
}