diff --git a/subject/product.go b/subject/product.go
index 39c5a2b..5177fea 100644
--- a/subject/product.go
+++ b/subject/product.go
@@ -8,15 +8,17 @@ func getProductValue(val string) string {
 }
 
 var Product = struct {
-	ApplyRequest        string
-	CreateRequestStep   string
-	ProcessApplyRequest string
-	RequestChangeStatus string
-	WebhookStockUpdate  string
+	ApplyRequest         string
+	CreateRequestStep    string
+	ProcessApplyRequest  string
+	RequestChangeStatus  string
+	WebhookStockUpdate   string // WebhookStockUpdate Kiotviet queue
+	OPWebhookStockUpdate string // OPWebhookStockUpdate Onpoint queue
 }{
-	ApplyRequest:        getProductValue("apply_request"),
-	CreateRequestStep:   getProductValue("create_request_step"),
-	ProcessApplyRequest: getProductValue("process_apply_request"),
-	RequestChangeStatus: getProductValue("request_change_status"),
-	WebhookStockUpdate:  getProductValue("webhook_stock_update"),
+	ApplyRequest:         getProductValue("apply_request"),
+	CreateRequestStep:    getProductValue("create_request_step"),
+	ProcessApplyRequest:  getProductValue("process_apply_request"),
+	RequestChangeStatus:  getProductValue("request_change_status"),
+	WebhookStockUpdate:   getProductValue("webhook_stock_update"),
+	OPWebhookStockUpdate: getProductValue("op_webhook_stock_update"),
 }