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

Use HeadersOnly subscription

Browse source
This commit is contained in:
Till Faelligen 2022-03-24 08:11:00 +01:00
parent 664d38ab96
commit 68286afe7d
3 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
federationapi/consumers/eduserver.go
View file

@ -71,7 +71,7 @@ func NewOutputEDUConsumer(
func (t *OutputEDUConsumer) Start() error { func (t *OutputEDUConsumer) Start() error {
if err := jetstream.JetStreamConsumer( if err := jetstream.JetStreamConsumer(
t.ctx, t.jetstream, t.typingTopic, t.durable, t.onTypingEvent, t.ctx, t.jetstream, t.typingTopic, t.durable, t.onTypingEvent,
nats.DeliverAll(), nats.ManualAck(), nats.DeliverAll(), nats.ManualAck(), nats.HeadersOnly(),
); err != nil { ); err != nil {
return err return err
} }
@ -83,7 +83,7 @@ func (t *OutputEDUConsumer) Start() error {
} }
if err := jetstream.JetStreamConsumer( if err := jetstream.JetStreamConsumer(
t.ctx, t.jetstream, t.receiptTopic, t.durable, t.onReceiptEvent, t.ctx, t.jetstream, t.receiptTopic, t.durable, t.onReceiptEvent,
nats.DeliverAll(), nats.ManualAck(), nats.DeliverAll(), nats.ManualAck(), nats.HeadersOnly(),
); err != nil { ); err != nil {
return err return err
} }

8
federationapi/federationapi.go
View file

@ -63,9 +63,11 @@ func AddPublicRoutes(
js, _ := jetstream.Prepare(process, &cfg.Matrix.JetStream) js, _ := jetstream.Prepare(process, &cfg.Matrix.JetStream)
producer := &producers.SyncAPIProducer{ producer := &producers.SyncAPIProducer{
JetStream: js, JetStream: js,
TopicReceiptEvent: cfg.Matrix.JetStream.TopicFor(jetstream.OutputReceiptEvent), TopicReceiptEvent: cfg.Matrix.JetStream.Prefixed(jetstream.OutputReceiptEvent),
TopicSendToDeviceEvent: cfg.Matrix.JetStream.TopicFor(jetstream.OutputSendToDeviceEvent), TopicSendToDeviceEvent: cfg.Matrix.JetStream.Prefixed(jetstream.OutputSendToDeviceEvent),
TopicTypingEvent: cfg.Matrix.JetStream.TopicFor(jetstream.OutputTypingEvent), TopicTypingEvent: cfg.Matrix.JetStream.Prefixed(jetstream.OutputTypingEvent),
ServerName: cfg.Matrix.ServerName,
UserAPI: userAPI,
} }
routing.Setup( routing.Setup(

0
syncapi/consumers/eduserver_typing.go → syncapi/consumers/typing.go
View file