From 81b71dafde4204aa4f00cef1c4ce14ee17513fda Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Thu, 10 Feb 2022 12:32:22 +0000 Subject: [PATCH] Consume on the correct topic for the roomserver --- pushserver/consumers/roomserver.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/pushserver/consumers/roomserver.go b/pushserver/consumers/roomserver.go index 857bd0916..7bcfc5005 100644 --- a/pushserver/consumers/roomserver.go +++ b/pushserver/consumers/roomserver.go @@ -7,7 +7,6 @@ import ( "strings" "time" - "github.com/matrix-org/dendrite/federationapi/queue" "github.com/matrix-org/dendrite/internal/eventutil" "github.com/matrix-org/dendrite/internal/pushgateway" "github.com/matrix-org/dendrite/internal/pushrules" @@ -33,7 +32,6 @@ type OutputRoomEventConsumer struct { jetstream nats.JetStreamContext durable string db storage.Database - queues *queue.OutgoingQueues topic string pgClient pushgateway.Client syncProducer *producers.SyncAPI @@ -55,7 +53,7 @@ func NewOutputRoomEventConsumer( jetstream: js, db: store, durable: cfg.Matrix.JetStream.Durable("PushServerClientAPIConsumer"), - topic: cfg.Matrix.JetStream.TopicFor(jetstream.OutputClientData), + topic: cfg.Matrix.JetStream.TopicFor(jetstream.OutputRoomEvent), pgClient: pgClient, psAPI: psAPI, rsAPI: rsAPI,