diff --git a/internal/cmd/consumer.go b/internal/cmd/consumer.go
index cfc0a372..9431503e 100644
--- a/internal/cmd/consumer.go
+++ b/internal/cmd/consumer.go
@@ -55,7 +55,7 @@ var consumerCmd = &cobra.Command{
 		conn.Start()
 
 		handler := handler.NewConsumerHandler(correctnessService, uniswapService, evmLogService)
-		client.Consume(handler)
+		client.NewRPC(handler)
 
 		server.New(
 			gql.WithGraphQL(),
diff --git a/internal/cmd/worker.go b/internal/cmd/worker.go
index bf62b268..0ce67271 100644
--- a/internal/cmd/worker.go
+++ b/internal/cmd/worker.go
@@ -57,7 +57,7 @@ var workerCmd = &cobra.Command{
 		conn.Start()
 
 		handler := handler.NewWorkerHandler()
-		client.Consume(handler)
+		client.NewRPC(handler)
 
 		scheduler.Start()
 	},
diff --git a/internal/transport/client/client.go b/internal/transport/client/client.go
index 096cb170..291c5f07 100644
--- a/internal/transport/client/client.go
+++ b/internal/transport/client/client.go
@@ -7,7 +7,7 @@ import (
 	"github.com/KenshiTech/unchained/transport/client/handler"
 )
 
-func Consume(handler handler.Handler) {
+func NewRPC(handler handler.Handler) {
 	incoming := conn.Read()
 
 	go func() {