diff --git a/restream/core.go b/restream/core.go
index fa1656ec..3e8649b1 100644
--- a/restream/core.go
+++ b/restream/core.go
@@ -469,17 +469,7 @@ func (r *restream) load() error {
 
 		t.ffmpeg = ffmpeg
 
-		r.events.Consume(t.parser, func(e event.Event) event.Event {
-			pe, ok := e.(*event.ProcessEvent)
-			if !ok {
-				return e
-			}
-
-			pe.ProcessID = t.process.ID
-			pe.Domain = t.process.Domain
-
-			return pe
-		})
+		r.events.Consume(t.parser, t.RewriteEvent)
 
 		return true
 	})