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

Consume on the correct topic for the roomserver

Browse source
This commit is contained in:
Neil Alexander 2022-02-10 12:32:22 +00:00
parent b01b9180d0
commit 81b71dafde
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
pushserver/consumers/roomserver.go
View file

@ -7,7 +7,6 @@ import (
"strings" "strings"
"time" "time"
"github.com/matrix-org/dendrite/federationapi/queue"
"github.com/matrix-org/dendrite/internal/eventutil" "github.com/matrix-org/dendrite/internal/eventutil"
"github.com/matrix-org/dendrite/internal/pushgateway" "github.com/matrix-org/dendrite/internal/pushgateway"
"github.com/matrix-org/dendrite/internal/pushrules" "github.com/matrix-org/dendrite/internal/pushrules"
@ -33,7 +32,6 @@ type OutputRoomEventConsumer struct {
jetstream nats.JetStreamContext jetstream nats.JetStreamContext
durable string durable string
db storage.Database db storage.Database
queues *queue.OutgoingQueues
topic string topic string
pgClient pushgateway.Client pgClient pushgateway.Client
syncProducer *producers.SyncAPI syncProducer *producers.SyncAPI
@ -55,7 +53,7 @@ func NewOutputRoomEventConsumer(
jetstream: js, jetstream: js,
db: store, db: store,
durable: cfg.Matrix.JetStream.Durable("PushServerClientAPIConsumer"), durable: cfg.Matrix.JetStream.Durable("PushServerClientAPIConsumer"),
topic: cfg.Matrix.JetStream.TopicFor(jetstream.OutputClientData), topic: cfg.Matrix.JetStream.TopicFor(jetstream.OutputRoomEvent),
pgClient: pgClient, pgClient: pgClient,
psAPI: psAPI, psAPI: psAPI,
rsAPI: rsAPI, rsAPI: rsAPI,