Skip to content

Commit 8ab3333

Browse files
authored
fix: Fix leaking ticket in agent's redis logic (#643)
Signed-off-by: jannfis <[email protected]>
1 parent a1526b3 commit 8ab3333

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

agent/inbound_redis.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -180,6 +180,7 @@ func (a *Agent) handleRedisSubscribeMessage(logCtx *logrus.Entry, rreq *event.Re
180180
// - This function will also close local redis connections for principal connections that are no longer active (based on pings received)
181181
func (a *Agent) forwardRedisSubscribeNotificationsToPrincipal(pubsub *redis.PubSub, rreq *event.RedisRequest, channelName string, logCtx *logrus.Entry) {
182182
ticker := time.NewTicker(1 * time.Minute)
183+
defer ticker.Stop()
183184

184185
ch := pubsub.Channel()
185186

0 commit comments

Comments
 (0)