diff --git a/server/rpc_server.go b/server/rpc_server.go index 22fca2d9..9c4a3ef1 100644 --- a/server/rpc_server.go +++ b/server/rpc_server.go @@ -40,7 +40,7 @@ func newRpcServer(opts ...Option) Server { return &rpcServer{ opts: options, - router: DefaultRouter, + router: router, handlers: make(map[string]Handler), subscribers: make(map[*subscriber][]broker.Subscriber), exit: make(chan chan error),