diff --git a/federationsender/consumers/roomserver.go b/federationsender/consumers/roomserver.go index adca255f7..ff5230161 100644 --- a/federationsender/consumers/roomserver.go +++ b/federationsender/consumers/roomserver.go @@ -131,9 +131,7 @@ func (s *OutputRoomEventConsumer) onMessage(msg *sarama.ConsumerMessage) error { // processMessage updates the list of currently joined hosts in the room // and then sends the event to the hosts that were joined before the event. func (s *OutputRoomEventConsumer) processMessage(ore api.OutputNewRoomEvent) error { - addStateEvents := []gomatrixserverlib.HeaderedEvent{ore.Event} - addStateEvents = append(addStateEvents, ore.AddStateEvents...) - addsJoinedHosts, err := joinedHostsFromEvents(gomatrixserverlib.UnwrapEventHeaders(addStateEvents)) + addsJoinedHosts, err := joinedHostsFromEvents(gomatrixserverlib.UnwrapEventHeaders(ore.AddStateEvents)) if err != nil { return err }