bahtya dd3c923f44 fix: close pubsub connection on Subscribe error in CancelationPubSub ...

When redis.Subscribe succeeds but Receive() fails, the pubsub
connection was not being closed before returning the error. This caused
the subscriber goroutine to leak a Redis connection on each retry
iteration, eventually exhausting the connection pool.

Fixes #1095

2026-04-09 18:15:48 +08:00

..

base

Feature: Add Headers Support to Tasks (#1070)

2026-02-03 09:05:40 +03:00

context

Fix comment typos

2022-05-16 21:14:15 -07:00

errors

ci: format code with golangci-lint

2025-11-04 19:06:18 +03:00

log

Change LogLevel to satisfy flag.Value interface

2020-05-16 08:00:35 -07:00

proto

Feature: Add Headers Support to Tasks (#1070)

2026-02-03 09:05:40 +03:00

rdb

fix: close pubsub connection on Subscribe error in CancelationPubSub

2026-04-09 18:15:48 +08:00

testbroker

feature: configurable janitor interval and deletion batch size (#715)

2024-05-06 14:11:52 +08:00

testutil

fix unit test

2023-04-17 22:30:33 -07:00

timeutil

Make timeutil.SimulatedClock concurrency safe

2022-02-19 06:15:44 -08:00