new watchers functionality

2 files changed, 8 insertions, 6 deletions

diff --git a/cmd/rr/cmd/root.go b/cmd/rr/cmd/root.go
index 2e170307..1222177a 100644
--- a/cmd/rr/cmd/root.go
+++ b/cmd/rr/cmd/root.go
@@ -109,11 +109,13 @@ func init() {
 		}
 
 		// global watcher config
-		wcv, _ := Container.Get(watcher.ID)
-		if wcv, ok := wcv.(*watcher.Service); ok {
-			wcv.AddListener(func(event int, ctx interface{}) {
-				util.LogEvent(Logger, event, ctx)
-			})
+		if Verbose {
+			wcv, _ := Container.Get(watcher.ID)
+			if wcv, ok := wcv.(*watcher.Service); ok {
+				wcv.AddListener(func(event int, ctx interface{}) {
+					util.LogEvent(Logger, event, ctx)
+				})
+			}
 		}
 	})
 }
diff --git a/cmd/util/debug.go b/cmd/util/debug.go
index 54ef104f..01082112 100644
--- a/cmd/util/debug.go
+++ b/cmd/util/debug.go
@@ -71,7 +71,7 @@ func LogEvent(logger *logrus.Logger, event int, ctx interface{}) bool {
 
 	case watcher.EventMaxMemory:
 		w := ctx.(roadrunner.WorkerError)
-		logger.Warning(Sprintf(
+		logger.Error(Sprintf(
 			"<white+hb>worker.%v</reset> <red>%s</reset>",
 			*w.Worker.Pid,
 			w.Caused,