3 files changed, 4 insertions, 10 deletions
diff --git a/interfaces/pool/pool.go b/interfaces/pool/pool.go
index 22552388..97cc945c 100644
--- a/interfaces/pool/pool.go
+++ b/interfaces/pool/pool.go
@@ -5,16 +5,12 @@ import (
 	"runtime"
 	"time"
 
-	"github.com/spiral/roadrunner/v2/interfaces/events"
 	"github.com/spiral/roadrunner/v2/interfaces/worker"
 	"github.com/spiral/roadrunner/v2/pkg/payload"
 )
 
 // Pool managed set of inner worker processes.
 type Pool interface {
-	// AddListener connects event listener to the pool.
-	AddListener(listener events.EventListener)
-
 	// GetConfig returns pool configuration.
 	GetConfig() interface{}
 
diff --git a/interfaces/worker/factory.go b/interfaces/worker/factory.go
index 8db8ddcc..8412428d 100644
--- a/interfaces/worker/factory.go
+++ b/interfaces/worker/factory.go
@@ -3,16 +3,18 @@ package worker
 import (
 	"context"
 	"os/exec"
+
+	"github.com/spiral/roadrunner/v2/interfaces/events"
 )
 
 // Factory is responsible of wrapping given command into tasks WorkerProcess.
 type Factory interface {
 	// SpawnWorkerWithContext creates new WorkerProcess process based on given command with context.
 	// Process must not be started.
-	SpawnWorkerWithTimeout(context.Context, *exec.Cmd) (BaseProcess, error)
+	SpawnWorkerWithTimeout(context.Context, *exec.Cmd, ...events.EventListener) (BaseProcess, error)
 	// SpawnWorker creates new WorkerProcess process based on given command.
 	// Process must not be started.
-	SpawnWorker(*exec.Cmd) (BaseProcess, error)
+	SpawnWorker(*exec.Cmd, ...events.EventListener) (BaseProcess, error)
 	// Close the factory and underlying connections.
 	Close() error
 }
diff --git a/interfaces/worker/worker.go b/interfaces/worker/worker.go
index 7f2f8a53..0ac82158 100644
--- a/interfaces/worker/worker.go
+++ b/interfaces/worker/worker.go
@@ -6,7 +6,6 @@ import (
 	"time"
 
 	"github.com/spiral/goridge/v3/interfaces/relay"
-	"github.com/spiral/roadrunner/v2/interfaces/events"
 	"github.com/spiral/roadrunner/v2/internal"
 	"github.com/spiral/roadrunner/v2/pkg/payload"
 )
@@ -23,9 +22,6 @@ type BaseProcess interface {
 	// Created returns time worker was created at.
 	Created() time.Time
 
-	// AddListener attaches listener to consume worker events.
-	AddListener(listener events.EventListener)
-
 	// State return receive-only WorkerProcess state object, state can be used to safely access
 	// WorkerProcess status, time when status changed and number of WorkerProcess executions.
 	State() internal.State