rm unnecessary locking

centrifugal · Dec 9, 2024 · 6df4c9d · 6df4c9d
1 parent 48ae424
commit 6df4c9d
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/internal/consuming/postgresql.go b/internal/consuming/postgresql.go
@@ -5,7 +5,6 @@ import (
 	"errors"
 	"fmt"
 	"strconv"
-	"sync"
 	"time"
 
 	"github.com/centrifugal/centrifugo/v5/internal/configtypes"
@@ -175,7 +174,6 @@ func (c *PostgresConsumer) processOnce(ctx context.Context, partition int) (int,
 
 	var dispatchErr error
 
-	var mu sync.Mutex
 	for _, event := range events {
 		dispatchErr = c.dispatcher.Dispatch(context.Background(), event.Method, event.Payload)
 		if dispatchErr != nil {
@@ -184,9 +182,7 @@ func (c *PostgresConsumer) processOnce(ctx context.Context, partition int) (int,
 			break
 		} else {
 			numProcessedRows++
-			mu.Lock()
 			idsToDelete = append(idsToDelete, event.ID)
-			mu.Unlock()
 		}
 	}