Tweak order
This commit is contained in:
parent
8cbf67a2f2
commit
e0a485c50d
|
@ -113,10 +113,10 @@ func (r *Inputer) Start() error {
|
|||
"type": inputRoomEvent.Event.Type(),
|
||||
}).Warn("Roomserver failed to process async event")
|
||||
}
|
||||
if !retry {
|
||||
_ = msg.Ack()
|
||||
} else {
|
||||
if retry {
|
||||
_ = msg.Nak()
|
||||
} else {
|
||||
_ = msg.Ack()
|
||||
}
|
||||
})
|
||||
},
|
||||
|
|
Loading…
Reference in a new issue