Update pkg/stream/producer_unconfirmed.go

Co-authored-by: Alberto Moretti <[email protected]>
rabbitmq · Jan 27, 2025 · 4ef5570 · 4ef5570
1 parent e90b093
commit 4ef5570
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/stream/producer_unconfirmed.go b/pkg/stream/producer_unconfirmed.go
@@ -137,7 +137,7 @@ func (u *unConfirmed) maybeUnLock() {
 	if len(u.messages) < u.maxSize {
 		logs.LogDebug("unConfirmed size: %d back to normal, producer unblocked", u.maxSize)
 		u.blockSignal.L.Lock()
-		u.blockSignal.Signal()
+		u.blockSignal.Broadcast()
 		u.blockSignal.L.Unlock()
 	}
 }