1 files changed, 5 insertions, 7 deletions
diff --git a/server.go b/server.go
index 08d96a6b..fb3c737f 100644
--- a/server.go
+++ b/server.go
@@ -46,8 +46,11 @@ type Server struct {
 }
 
 // NewServer creates new router. Make sure to call configure before the usage.
-func NewServer(cfg *ServerConfig) *Server {
-	return &Server{cfg: cfg}
+func NewServer(cfg *ServerConfig, o func(event int, ctx interface{})) *Server {
+	return &Server{
+		cfg:      cfg,
+		observer: o,
+	}
 }
 
 // Reconfigure re-configures underlying pool and destroys it's previous version if any.
@@ -94,11 +97,6 @@ func (srv *Server) Reset() error {
 	return srv.Reconfigure(srv.cfg)
 }
 
-// Observe attaches event watcher to the router.
-func (srv *Server) Observe(o func(event int, ctx interface{})) {
-	srv.observer = o
-}
-
 // Start underlying worker pool, configure factory and command provider.
 func (srv *Server) Start() (err error) {
 	srv.mu.Lock()