From 374a6163875ea3a3fbb217b724f44346237ad9d0 Mon Sep 17 00:00:00 2001 From: Nam Huynh Date: Tue, 30 Nov 2021 22:29:02 +0700 Subject: [PATCH] change publish payload data type to []byte --- pubsub.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/pubsub.go b/pubsub.go index 915a66b..33232a0 100644 --- a/pubsub.go +++ b/pubsub.go @@ -1,7 +1,6 @@ package natsio import ( - "encoding/json" "errors" "fmt" @@ -9,11 +8,10 @@ import ( ) // Publish ... -func Publish(stream, subject string, data interface{}) error { +func Publish(stream, subject string, payload []byte) error { channel := combineStreamAndSubjectName(stream, subject) - b, _ := json.Marshal(data) - _, err := natsJS.PublishAsync(channel, b) + _, err := natsJS.PublishAsync(channel, payload) if err != nil { msg := fmt.Sprintf("publish message to subject %s error: %s", channel, err.Error()) return errors.New(msg)