mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-02-24 21:43:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Add missing "Pull" suffix to consumer name

Browse source
This commit is contained in:
Till Faelligen 2023-12-01 08:56:09 +01:00
parent 62c2e92ef9
commit 4da7b43f88
No known key found for this signature in database
GPG key ID: 3DF82D8AB9211D4E
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
appservice/consumers/roomserver.go
View file

@ -101,7 +101,7 @@ func (s *OutputRoomEventConsumer) Start() error {
// Cleanup any consumers still existing on the OutputRoomEvent stream // Cleanup any consumers still existing on the OutputRoomEvent stream
// to avoid messages not being deleted // to avoid messages not being deleted
for _, consumerName := range durableNames { for _, consumerName := range durableNames {
err := s.jetstream.DeleteConsumer(s.cfg.Matrix.JetStream.Prefixed(jetstream.OutputRoomEvent), consumerName) err := s.jetstream.DeleteConsumer(s.cfg.Matrix.JetStream.Prefixed(jetstream.OutputRoomEvent), consumerName+"Pull")
if err != nil && err != nats.ErrConsumerNotFound { if err != nil && err != nats.ErrConsumerNotFound {
return err return err
} }