diff --git a/syncapi/consumers/clientapi.go b/syncapi/consumers/clientapi.go
index 4939aaf31..f8d0d6a3f 100644
--- a/syncapi/consumers/clientapi.go
+++ b/syncapi/consumers/clientapi.go
@@ -97,7 +97,7 @@ func (s *OutputClientDataConsumer) onMessage(msg *sarama.ConsumerMessage) error
 	}
 
 	s.streams.AccountDataStreamProvider.Advance(pduPos)
-	s.notifier.OnNewEvent(nil, "", []string{string(msg.Key)}, types.StreamingToken{AccountDataPosition: pduPos})
+	s.notifier.OnNewAccountData(string(msg.Key), types.StreamingToken{AccountDataPosition: pduPos})
 
 	return nil
 }
diff --git a/syncapi/notifier/notifier.go b/syncapi/notifier/notifier.go
index 47bf04bf6..f45871d36 100644
--- a/syncapi/notifier/notifier.go
+++ b/syncapi/notifier/notifier.go
@@ -124,6 +124,15 @@ func (n *Notifier) OnNewEvent(
 	}
 }
 
+func (n *Notifier) OnNewAccountData(
+	userID string, posUpdate types.StreamingToken,
+) {
+	n.streamLock.Lock()
+	defer n.streamLock.Unlock()
+
+	n.wakeupUsers([]string{userID}, nil, posUpdate)
+}
+
 func (n *Notifier) OnNewPeek(
 	roomID, userID, deviceID string,
 ) {