diff --git a/protocol/invocation/rpcinvocation.go b/protocol/invocation/rpcinvocation.go index 7f2cede9295e24c521de017ab3a1da7eaad250ab..1e820b0e9c02708f33883be3a13e3125d94a2f77 100644 --- a/protocol/invocation/rpcinvocation.go +++ b/protocol/invocation/rpcinvocation.go @@ -155,6 +155,11 @@ func (r *RPCInvocation) Invoker() protocol.Invoker { return r.invoker } +// SetInvoker ... +func (r *RPCInvocation) SetInvoker(invoker protocol.Invoker) { + r.invoker = invoker +} + // CallBack sets RPC callback method. func (r *RPCInvocation) CallBack() interface{} { return r.callBack