From 5a5d4cb8e3b51960f0543653af8d30a4c9f2b69c Mon Sep 17 00:00:00 2001
From: Sameh Abouel-saad <samehvirus@gmail.com>
Date: Tue, 3 Oct 2023 11:13:21 +0300
Subject: [PATCH] fix: increase the limit for redis queues length (#170)

---
 src/peer/storage/redis_storage.rs | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/peer/storage/redis_storage.rs b/src/peer/storage/redis_storage.rs
index 7776091..5a5aa72 100644
--- a/src/peer/storage/redis_storage.rs
+++ b/src/peer/storage/redis_storage.rs
@@ -16,6 +16,8 @@ use bb8_redis::{
 
 struct BacklogKey<'a>(&'a str);
 
+const MAX_COMMANDS: isize = 10000;
+
 impl<'a> ToRedisArgs for BacklogKey<'a> {
     fn write_redis_args<W>(&self, out: &mut W)
     where
@@ -95,7 +97,7 @@ impl RedisStorageBuilder {
     pub fn new(pool: Pool<RedisConnectionManager>) -> RedisStorageBuilder {
         RedisStorageBuilder {
             pool,
-            max_commands: 500,
+            max_commands: MAX_COMMANDS,
         }
     }