修改代码

mqtt_binding/mqtt_binding.go

@@ -85,15 +85,15 @@ func (item *BindItem[I, O]) bind(r *router.Router, bindingResponseIdentifier res
 		}
 	}
 
+	var responseIdentifier response.Identifier
+	if item.ResponseIdentifier != nil {
+		responseIdentifier = item.ResponseIdentifier
+	} else if bindingResponseIdentifier != nil {
+		responseIdentifier = bindingResponseIdentifier
+	}
+
 	// 给单个路由增加中间件
 	handlers = append(handlers, func(routerItem *router.Item, data []byte) {
-		var responseIdentifier response.Identifier
-		if item.ResponseIdentifier != nil {
-			responseIdentifier = item.ResponseIdentifier
-		} else if bindingResponseIdentifier != nil {
-			responseIdentifier = bindingResponseIdentifier
-		}
-
 		var inputModel I
 
 		var req any