|
@@ -88,9 +88,10 @@ func (item *BindItem[I, O]) bind(r *router.Router, bindingResponseIdentifier res
|
|
|
responseIdentifier = bindingResponseIdentifier
|
|
|
}
|
|
|
|
|
|
+ var inputModel I
|
|
|
+
|
|
|
var req any
|
|
|
if inputType != nil {
|
|
|
- var inputModel I
|
|
|
req = &inputModel
|
|
|
}
|
|
|
|
|
@@ -112,7 +113,7 @@ func (item *BindItem[I, O]) bind(r *router.Router, bindingResponseIdentifier res
|
|
|
|
|
|
|
|
|
if item.BusinessFunc != nil {
|
|
|
- outputModel, err := item.BusinessFunc(mqttClientInstance, req)
|
|
|
+ outputModel, err := item.BusinessFunc(mqttClientInstance, inputModel)
|
|
|
item.ResponseFunc(mqttClientInstance, routerItem, responseIdentifier, outputModel, err)
|
|
|
return
|
|
|
}
|