From 831e4b8247b07b950fb54e12d7a036aa03d6ba1a Mon Sep 17 00:00:00 2001 From: Sinh Date: Mon, 17 Oct 2022 11:09:27 +0700 Subject: [PATCH 1/2] update payload --- model/warehouse_response.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/model/warehouse_response.go b/model/warehouse_response.go index 88ba2f1..07969dc 100644 --- a/model/warehouse_response.go +++ b/model/warehouse_response.go @@ -84,10 +84,11 @@ type WarehousePartner struct { // SyncORStatusResponse ... type SyncORStatusResponse struct { - ORCode string `json:"orCode"` - OrderCode string `json:"orderCode"` - Status string `json:"status"` - DeliveryStatus string `json:"deliveryStatus"` + ORCode string `json:"orCode"` + OrderCode string `json:"orderCode"` + Status string `json:"status"` + DeliveryStatus string `json:"deliveryStatus"` + Data OrderORData `json:"data"` } // ResponseWarehouseContact ... From 77276b0ae671450c5f42537bf185a0510d393e87 Mon Sep 17 00:00:00 2001 From: Sinh Date: Tue, 18 Oct 2022 11:46:04 +0700 Subject: [PATCH 2/2] add queue subscribe --- server_reqres.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/server_reqres.go b/server_reqres.go index 8979ab0..7b2d66b 100644 --- a/server_reqres.go +++ b/server_reqres.go @@ -40,6 +40,16 @@ func (sv Server) Subscribe(subject string, cb nats.MsgHandler) (*nats.Subscripti return sub, nil } +// QueueSubscribe ... +func (sv Server) QueueSubscribe(subject, queue string, cb nats.MsgHandler) (*nats.Subscription, error) { + sub, err := sv.instance.QueueSubscribe(subject, queue, cb) + if err != nil { + msg := fmt.Sprintf("[NATS SERVER] - queue subscribe subject %s, queue %s error: %s", subject, queue, err.Error()) + return nil, errors.New(msg) + } + return sub, nil +} + // NewJSONEncodedConn ... func (sv Server) NewJSONEncodedConn() (*JSONEncoder, error) { enc, err := nats.NewEncodedConn(sv.instance, nats.JSON_ENCODER)