diff --git a/src/github.com/matrix-org/dendrite/federationsender/queue/destinationqueue.go b/src/github.com/matrix-org/dendrite/federationsender/queue/destinationqueue.go index 64d721d4a..c0afe3be2 100644 --- a/src/github.com/matrix-org/dendrite/federationsender/queue/destinationqueue.go +++ b/src/github.com/matrix-org/dendrite/federationsender/queue/destinationqueue.go @@ -125,6 +125,7 @@ func (oq *destinationQueue) next() *gomatrixserverlib.Transaction { t.EDUs = append(t.EDUs, *edu) } oq.pendingEDUs = nil + oq.sentCounter += len(t.EDUs) return &t }