hoernschen/dendrite
1
0
Fork 0
mirror of https://github.com/hoernschen/dendrite.git synced 2024-12-26 15:08:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Publish send-to-device messages into correct JetStream subject

Browse source
This commit is contained in:
Neil Alexander 2021-11-08 10:49:20 +00:00
parent 621dabcb34
commit d6229a3c9a
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
eduserver/input/input.go
View file

@ -190,7 +190,7 @@ func (t *EDUServerInputAPI) sendToDeviceEvent(ise *api.InputSendToDeviceEvent) e
} }
if _, err = t.JetStream.PublishMsg(&nats.Msg{ if _, err = t.JetStream.PublishMsg(&nats.Msg{
Subject: t.OutputTypingEventTopic, Subject: t.OutputSendToDeviceEventTopic,
Data: eventJSON, Data: eventJSON,
}); err != nil { }); err != nil {
logrus.WithError(err).Error("sendToDevice failed t.Producer.SendMessage") logrus.WithError(err).Error("sendToDevice failed t.Producer.SendMessage")