diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-02-02 13:32:48 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-02-02 13:32:48 +0000 |
| commit | c773b038bb1432f2265759ddf1da5e98b9bda525 (patch) | |
| tree | 357c7dac69f4f87dda61bbaf004ae3351d5277d8 /roomserver | |
| parent | 2dee706f9ef2de70516dbc993dcfc8ec6f7fdd52 (diff) | |
Use pull consumers (#2140)
* Pull consumers
* Pull consumers
* Only nuke consumers if they are push consumers
* Clean up old consumers
* Better error handling
* Update comments
Diffstat (limited to 'roomserver')
| -rw-r--r-- | roomserver/internal/api.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/roomserver/internal/api.go b/roomserver/internal/api.go index 5b87e623..fd963ad8 100644 --- a/roomserver/internal/api.go +++ b/roomserver/internal/api.go @@ -41,7 +41,7 @@ type RoomserverInternalAPI struct { fsAPI fsAPI.FederationInternalAPI asAPI asAPI.AppServiceQueryAPI JetStream nats.JetStreamContext - Durable nats.SubOpt + Durable string InputRoomEventTopic string // JetStream topic for new input room events OutputRoomEventTopic string // JetStream topic for new output room events PerspectiveServerNames []gomatrixserverlib.ServerName @@ -87,7 +87,7 @@ func (r *RoomserverInternalAPI) SetFederationAPI(fsAPI fsAPI.FederationInternalA InputRoomEventTopic: r.InputRoomEventTopic, OutputRoomEventTopic: r.OutputRoomEventTopic, JetStream: r.JetStream, - Durable: r.Durable, + Durable: nats.Durable(r.Durable), ServerName: r.Cfg.Matrix.ServerName, FSAPI: fsAPI, KeyRing: keyRing, |