Skip to content

Commit

Permalink
PR FIXUP - Fix capitalisation
Browse files Browse the repository at this point in the history
  • Loading branch information
AndrewSisley committed Nov 15, 2024
1 parent d1906b2 commit 461ca17
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions internal/db/messages.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ import (
)

func (db *db) handleMessages(ctx context.Context, sub *event.Subscription) {
docIdQueue := newMergeQueue()
docIDQueue := newMergeQueue()
schemaRootQueue := newMergeQueue()

// This is used to ensure we only trigger loadAndPublishP2PCollections and loadAndPublishReplicators
Expand Down Expand Up @@ -57,8 +57,8 @@ func (db *db) handleMessages(ctx context.Context, sub *event.Subscription) {
defer schemaRootQueue.done(evt.SchemaRoot)
} else {
// ensure only one merge per docID
docIdQueue.add(evt.DocID)
defer docIdQueue.done(evt.DocID)
docIDQueue.add(evt.DocID)
defer docIDQueue.done(evt.DocID)
}

// retry the merge process if a conflict occurs
Expand Down

0 comments on commit 461ca17

Please sign in to comment.