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 ...
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)