From 2c0aeb2cb142fa0bb4e5d781aaeca7f2f7090149 Mon Sep 17 00:00:00 2001
From: luizstacio <luizstacio@gmail.com>
Date: Fri, 6 Jun 2025 00:52:02 -0300
Subject: [PATCH] fix(sv-consumer): Use concurrent_tasks on subscribe to blocks

---
 services/consumer/src/executor/block_executor.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/services/consumer/src/executor/block_executor.rs b/services/consumer/src/executor/block_executor.rs
index 019374ff..0ae0c79e 100644
--- a/services/consumer/src/executor/block_executor.rs
+++ b/services/consumer/src/executor/block_executor.rs
@@ -95,7 +95,7 @@ impl BlockExecutor {
         let queue = NatsQueue::BlockImporter(self.message_broker.clone());
 
         while !token.is_cancelled() {
-            let mut messages = queue.subscribe(1).await?;
+            let mut messages = queue.subscribe(self.concurrent_tasks).await?;
             while let Some(msg) = messages.next().await {
                 let msg = msg?;
                 let semaphore = self.semaphore.clone();