mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-01 03:03:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Recreate if subjects wrong

Browse source
This commit is contained in:
Neil Alexander 2022-03-22 14:41:48 +00:00
parent 1170030352
commit 2f232537f6
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
setup/jetstream/nats.go
View file

@ -81,6 +81,9 @@ func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) (natsclient.JetStream
if err != nil && err != natsclient.ErrStreamNotFound { if err != nil && err != natsclient.ErrStreamNotFound {
logrus.WithError(err).Fatal("Unable to get stream info") logrus.WithError(err).Fatal("Unable to get stream info")
} }
if len(stream.Subjects) == 0 {
stream.Subjects = []string{name, name + ".>"}
}
if info != nil { if info != nil {
switch { switch {
case !reflect.DeepEqual(info.Config.Subjects, stream.Subjects): case !reflect.DeepEqual(info.Config.Subjects, stream.Subjects):
@ -93,10 +96,6 @@ func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) (natsclient.JetStream
} }
} }
} else { } else {
if len(stream.Subjects) == 0 {
stream.Subjects = []string{name}
}
// If we're trying to keep everything in memory (e.g. unit tests) // If we're trying to keep everything in memory (e.g. unit tests)
// then overwrite the storage policy. // then overwrite the storage policy.
if cfg.InMemory { if cfg.InMemory {