use the router

2019-06-12 12:05:34 +01:00 · 2019-06-12 12:05:34 +01:00 · 000e25a4b2
commit 000e25a4b2
parent 7a1cef46b0
1 changed files with 1 additions and 1 deletions
--- 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),