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

integrate-onpoint #54

Merged
sinhluu merged 15 commits from integrate-onpoint into master 2022-10-31 09:33:39 +00:00
Conversation 0 Commits 15 Files Changed 7 +15 -4
2 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit ae36115495 - Show all commits

9
model/warehouse_response.go
View File

@ -84,10 +84,11 @@ type WarehousePartner struct {
// SyncORStatusResponse ... // SyncORStatusResponse ...
type SyncORStatusResponse struct { type SyncORStatusResponse struct {
ORCode string `json:"orCode"` ORCode string `json:"orCode"`
OrderCode string `json:"orderCode"` OrderCode string `json:"orderCode"`
Status string `json:"status"` Status string `json:"status"`
DeliveryStatus string `json:"deliveryStatus"` DeliveryStatus string `json:"deliveryStatus"`
Data OrderORData `json:"data"`
} }
// ResponseWarehouseContact ... // ResponseWarehouseContact ...

10
server_reqres.go
View File

@ -40,6 +40,16 @@ func (sv Server) Subscribe(subject string, cb nats.MsgHandler) (*nats.Subscripti
return sub, nil 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 ... // NewJSONEncodedConn ...
func (sv Server) NewJSONEncodedConn() (*JSONEncoder, error) { func (sv Server) NewJSONEncodedConn() (*JSONEncoder, error) {
enc, err := nats.NewEncodedConn(sv.instance, nats.JSON_ENCODER) enc, err := nats.NewEncodedConn(sv.instance, nats.JSON_ENCODER)