Selly-Modules
/
appier
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix

This commit is contained in:
Minh Nguyen 2022-03-23 10:24:37 +07:00
parent fd4ed3187c
commit 2afc55eb5f
2 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
appier.go
View File

@ -41,10 +41,9 @@ func NewClient(config Config) (*Client, error) {
// publishWithJetStream ... // publishWithJetStream ...
func publishWithJetStream(streamName, subject string, data []byte) (isPublished bool, err error) { func publishWithJetStream(streamName, subject string, data []byte) (isPublished bool, err error) {
var req = RequestBody{Body: data}
// Publish jet stream // Publish jet stream
if err = client.natsJetStream.Publish(streamName, subject, toBytes(req)); err != nil { if err = client.natsJetStream.Publish(streamName, subject, data); err != nil {
return return
} }

9
pull.go
View File

@ -4,11 +4,6 @@ package appier
type Pull struct{} type Pull struct{}
// ProductUpsert ... // ProductUpsert ...
func (Pull) ProductUpsert(payload Payload) (bool, error) { func (Pull) ProductUpsert(payload []byte) (bool, error) {
return publishWithJetStream(JetStreamAppierService, SubjectPullProductUpsert, payload.Data) return publishWithJetStream(JetStreamAppierService, SubjectPullProductUpsert, payload)
}
// PingService ...
func (Pull) PingService(payload Payload) (bool, error) {
return publishWithJetStream(JetStreamAppierService, SubjectPingPullService, payload.Data)
} }