mirror of
https://github.com/matrix-org/dendrite
synced 2024-12-15 01:03:43 +01:00
Revert 482914aef4
This commit is contained in:
parent
482914aef4
commit
7f89fed1e4
1 changed files with 3 additions and 1 deletions
|
@ -172,10 +172,12 @@ func (r *Inputer) Start() error {
|
||||||
func(m *nats.Msg) {
|
func(m *nats.Msg) {
|
||||||
roomID := m.Header.Get(jetstream.RoomID)
|
roomID := m.Header.Get(jetstream.RoomID)
|
||||||
r.startWorkerForRoom(roomID)
|
r.startWorkerForRoom(roomID)
|
||||||
|
_ = m.Ack()
|
||||||
},
|
},
|
||||||
nats.HeadersOnly(),
|
nats.HeadersOnly(),
|
||||||
nats.DeliverAll(),
|
nats.DeliverAll(),
|
||||||
nats.AckNone(),
|
nats.AckExplicit(),
|
||||||
|
nats.ReplayInstant(),
|
||||||
nats.BindStream(r.InputRoomEventTopic),
|
nats.BindStream(r.InputRoomEventTopic),
|
||||||
)
|
)
|
||||||
return err
|
return err
|
||||||
|
|
Loading…
Reference in a new issue