diff --git a/cluster/node/actor.go b/cluster/node/actor.go index 4d3eae66..a636b8c3 100644 --- a/cluster/node/actor.go +++ b/cluster/node/actor.go @@ -54,6 +54,11 @@ func (a *Actor) Proxy() *Proxy { return a.scheduler.node.proxy } +// Processor 获取处理器 +func (a *Actor) Processor() Processor { + return a.processor +} + // Invoke 调用函数(Actor内线程安全) func (a *Actor) Invoke(fn func()) { a.rw.RLock()