diff --git a/cmd/misconduct-detector/main.go b/cmd/misconduct-detector/main.go
index 60ec553..8d8413b 100644
--- a/cmd/misconduct-detector/main.go
+++ b/cmd/misconduct-detector/main.go
@@ -102,6 +102,8 @@ func main() {
 		return
 	}
 
+	rpcClient.StartConsumer()
+
 	logger.Info("RPC client started")
 
 	wg := &sync.WaitGroup{}