fix #3
|
@ -43,7 +43,7 @@ func publishWithJetStream(streamName, subject string, data []byte) (isPublished
|
|||
var req = RequestBody{Body: data}
|
||||
|
||||
// Publish jet stream
|
||||
if err := client.natsJetStream.Publish(streamName, subject, toBytes(req)); err != nil {
|
||||
if err = client.natsJetStream.Publish(streamName, subject, toBytes(req)); err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
|
|
6
go.mod
6
go.mod
|
@ -1,10 +1,14 @@
|
|||
module github.com/Selly-Modules/appier
|
||||
|
||||
go 1.16
|
||||
go 1.17
|
||||
|
||||
require github.com/Selly-Modules/natsio v0.0.0-20220321031929-3fe4271f1bbc
|
||||
|
||||
require (
|
||||
github.com/logrusorgru/aurora v2.0.3+incompatible // indirect
|
||||
github.com/nats-io/nats.go v1.13.0 // indirect
|
||||
github.com/nats-io/nkeys v0.3.0 // indirect
|
||||
github.com/nats-io/nuid v1.0.1 // indirect
|
||||
github.com/thoas/go-funk v0.9.2 // indirect
|
||||
golang.org/x/crypto v0.0.0-20220315160706-3147a52a75dd // indirect
|
||||
)
|
||||
|
|
Loading…
Reference in New Issue