From 6144fa4e2eb0610b6587d6896302b97bab82f555 Mon Sep 17 00:00:00 2001
From: a <a@tuxpa.in>
Date: Sat, 5 Aug 2023 21:26:59 -0500
Subject: [PATCH] sec
---
contrib/codecs/broker/brokerredis/redis.go | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/contrib/codecs/broker/brokerredis/redis.go b/contrib/codecs/broker/brokerredis/redis.go
index 0f91107..a1694b5 100644
--- a/contrib/codecs/broker/brokerredis/redis.go
+++ b/contrib/codecs/broker/brokerredis/redis.go
@@ -103,8 +103,7 @@ type RedisRequest struct {
}
func (s *Broker) ReadRequest(ctx context.Context) (json.RawMessage, func(json.RawMessage) error, error) {
- timeout := time.Hour
-
+ timeout := time.Second
res, err := s.client.BLPop(ctx, timeout, s.domain+reqDomainSuffix).Result()
if err != nil {
return nil, nil, err
--
GitLab