mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-07 15:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Use the event ID as the key for de-dupe

Browse source
This commit is contained in:
Kegan Dougal 2017-03-10 15:42:04 +00:00
parent 53cd6546d3
commit b1e9752986
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/github.com/matrix-org/dendrite/clientapi/writers/createroom.go
View file

@ -274,7 +274,7 @@ func eventsToMessages(events []*gomatrixserverlib.Event) ([]*sarama.ProducerMess
return nil, err return nil, err
} }
m.Topic = "clientapiOutput" // TODO: Make this customisable like roomserver is? m.Topic = "clientapiOutput" // TODO: Make this customisable like roomserver is?
m.Key = sarama.StringEncoder("") m.Key = sarama.StringEncoder(e.EventID())
m.Value = sarama.ByteEncoder(value) m.Value = sarama.ByteEncoder(value)
msgs[i] = &m msgs[i] = &m
} }