diff --git a/src/github.com/matrix-org/dendrite/federationsender/consumers/roomserver.go b/src/github.com/matrix-org/dendrite/federationsender/consumers/roomserver.go index fd3e5c007..9ac0e9880 100644 --- a/src/github.com/matrix-org/dendrite/federationsender/consumers/roomserver.go +++ b/src/github.com/matrix-org/dendrite/federationsender/consumers/roomserver.go @@ -134,18 +134,19 @@ func (s *OutputRoomEvent) processMessage(ore api.OutputRoomEvent, ev gomatrixser return nil } - joinedHosts, err := s.joinedHostsAtEvent(ore, ev, oldJoinedHosts) + // Work out which hosts were joined at the event itself. + joinedHostsAtEvent, err := s.joinedHostsAtEvent(ore, ev, oldJoinedHosts) if err != nil { return err } + // Send the event. if err = s.queues.SendEvent( - &ev, gomatrixserverlib.ServerName(ore.SendAsServer), joinedHosts, + &ev, gomatrixserverlib.ServerName(ore.SendAsServer), joinedHostsAtEvent, ); err != nil { return err } - // TODO: Add the event to the transaction queue return nil }