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

Add client API topic to common

Browse source
This commit is contained in:
Brendan Abolivier 2017-07-31 16:05:04 +01:00
parent fd64eff7a4
commit 2cdc3a0e07
No known key found for this signature in database
GPG key ID: 8EF1500759F70623
2 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/github.com/matrix-org/dendrite/cmd/syncserver-integration-tests/main.go
View file

@ -54,7 +54,7 @@ var (
) )
const inputTopic = "syncserverInput" const inputTopic = "syncserverInput"
const clientTopic = "clientapiOutput" const clientTopic = "clientapiserverOutput"
var exe = test.KafkaExecutor{ var exe = test.KafkaExecutor{
ZookeeperURI: zookeeperURI, ZookeeperURI: zookeeperURI,

1
src/github.com/matrix-org/dendrite/common/test/config.go
View file

@ -82,6 +82,7 @@ func MakeConfig(configDir, kafkaURI, database, host string, startPort int) (*con
// TODO: Different servers should be using different topics. // TODO: Different servers should be using different topics.
// Make this configurable somehow? // Make this configurable somehow?
cfg.Kafka.Topics.OutputRoomEvent = "test.room.output" cfg.Kafka.Topics.OutputRoomEvent = "test.room.output"
cfg.Kafka.Topics.OutputClientData = "test.clientapi.output"
// TODO: Use different databases for the different schemas. // TODO: Use different databases for the different schemas.
// Using the same database for every schema currently works because // Using the same database for every schema currently works because