support for realtime error aggegration

1 files changed, 6 insertions, 1 deletions

diff --git a/cmd/rr/debug/debugger.go b/cmd/rr/debug/debugger.go
index 0621285b..6c23b057 100644
--- a/cmd/rr/debug/debugger.go
+++ b/cmd/rr/debug/debugger.go
@@ -45,7 +45,6 @@ func (s *debugger) listener(event int, ctx interface{}) {
 			"<white+hb>worker.%v</reset> <yellow>killed</red>",
 			*w.Pid,
 		))
-
 	case roadrunner.EventWorkerError:
 		err := ctx.(roadrunner.WorkerError)
 		s.logger.Error(utils.Sprintf(
@@ -55,6 +54,12 @@ func (s *debugger) listener(event int, ctx interface{}) {
 		))
 	}
 
+	// outputs
+	switch event {
+	case roadrunner.EventStderrOutput:
+		s.logger.Warning(string(ctx.([]byte)))
+	}
+
 	// rr server events
 	switch event {
 	case roadrunner.EventServerFailure: