diff --git a/appier.go b/appier.go index e9c661b..2ccf2da 100644 --- a/appier.go +++ b/appier.go @@ -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 } diff --git a/go.mod b/go.mod index a144ae0..8c4c244 100644 --- a/go.mod +++ b/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 )