diff --git a/internal/scaler/docker/docker.go b/internal/scaler/docker/docker.go
index 40cd5cc..fec5606 100644
--- a/internal/scaler/docker/docker.go
+++ b/internal/scaler/docker/docker.go
@@ -37,7 +37,7 @@ func (s *Scaler) Register(ctx context.Context) error {
 	}
 	cli.NegotiateAPIVersion(ctx)
 
-	event.B.Subscribe(s.namespacedID, func(_ []byte) {
+	event.B.Subscribe(fmt.Sprintf("%s.input", s.namespacedID), func(_ []byte) {
 		s.log.Verbose("start")
 
 		imageFullName := fmt.Sprintf("%s:%s", s.imageName, s.imageTag)