From f846b1f33cf6fa9a5ebfc6a03530c490a72ef3bd Mon Sep 17 00:00:00 2001 From: Erik Johnston Date: Tue, 10 Oct 2017 12:15:54 +0100 Subject: [PATCH] Include missing patch --- .../matrix-org/dendrite/cmd/dendrite-monolith-server/main.go | 2 +- .../dendrite/cmd/dendrite-public-rooms-api-server/main.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/github.com/matrix-org/dendrite/cmd/dendrite-monolith-server/main.go b/src/github.com/matrix-org/dendrite/cmd/dendrite-monolith-server/main.go index 4ff8a70d9..5dc846aa8 100644 --- a/src/github.com/matrix-org/dendrite/cmd/dendrite-monolith-server/main.go +++ b/src/github.com/matrix-org/dendrite/cmd/dendrite-monolith-server/main.go @@ -306,7 +306,7 @@ func (m *monolith) setupConsumers() { log.Panicf("startup: failed to start client API server consumer: %s", err) } - publicRoomsAPIConsumer := publicroomsapi_consumers.NewOutputRoomEvent( + publicRoomsAPIConsumer := publicroomsapi_consumers.NewOutputRoomEventConsumer( m.cfg, m.kafkaConsumer(), m.publicRoomsAPIDB, m.queryAPI, ) if err = publicRoomsAPIConsumer.Start(); err != nil { diff --git a/src/github.com/matrix-org/dendrite/cmd/dendrite-public-rooms-api-server/main.go b/src/github.com/matrix-org/dendrite/cmd/dendrite-public-rooms-api-server/main.go index 807aa0ca5..30dd2ee9b 100644 --- a/src/github.com/matrix-org/dendrite/cmd/dendrite-public-rooms-api-server/main.go +++ b/src/github.com/matrix-org/dendrite/cmd/dendrite-public-rooms-api-server/main.go @@ -73,7 +73,7 @@ func main() { }).Panic("Failed to setup kafka consumers") } - roomConsumer := consumers.NewOutputRoomEvent(cfg, kafkaConsumer, db, queryAPI) + roomConsumer := consumers.NewOutputRoomEventConsumer(cfg, kafkaConsumer, db, queryAPI) if err != nil { log.Panicf("startup: failed to create room server consumer: %s", err) }