File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed
Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -57,7 +57,7 @@ export class SimpleQueue<TMessageCatalog extends MessageCatalogSchema> {
5757 const delay = Math . min ( times * 50 , 1000 ) ;
5858 return delay ;
5959 } ,
60- maxRetriesPerRequest : 3 ,
60+ maxRetriesPerRequest : 20 ,
6161 } ) ;
6262 this . #registerCommands( ) ;
6363 this . schema = schema ;
Original file line number Diff line number Diff line change @@ -97,7 +97,7 @@ const redisOptions = async (
9797 host : redisContainer . getHost ( ) ,
9898 port : redisContainer . getPort ( ) ,
9999 password : redisContainer . getPassword ( ) ,
100- maxRetriesPerRequest : 3 , // Lower the retry attempts
100+ maxRetriesPerRequest : 20 , // Lower the retry attempts
101101 retryStrategy ( times ) {
102102 const delay = Math . min ( times * 50 , 2000 ) ;
103103 return delay ;
Original file line number Diff line number Diff line change @@ -79,7 +79,7 @@ async function verifyRedisConnection(container: StartedRedisContainer) {
7979 host : container . getHost ( ) ,
8080 port : container . getPort ( ) ,
8181 password : container . getPassword ( ) ,
82- maxRetriesPerRequest : 3 ,
82+ maxRetriesPerRequest : 20 ,
8383 connectTimeout : 10000 ,
8484 retryStrategy ( times ) {
8585 const delay = Math . min ( times * 50 , 2000 ) ;
You can’t perform that action at this time.
0 commit comments