diff --git a/indexer/src/main.rs b/indexer/src/main.rs
index f33c0d5..423588d 100644
--- a/indexer/src/main.rs
+++ b/indexer/src/main.rs
@@ -256,7 +256,7 @@ async fn main() -> anyhow::Result<()> {
                 receipts_cache_arc.clone(),
             )
         })
-        .buffer_unordered(1usize);
+        .buffer_unordered(usize::from(opts.concurrency.get()));
 
     while let Some(handle_message) = handlers.next().await {
         if let Err(e) = handle_message {