Commit 3324bf6e authored by David Stainton's avatar David Stainton

Fix minor bug dispatching MessageIDGarbageCollected event

parent 7ebe4f79
Pipeline #1024 passed with stage
in 8 minutes and 29 seconds
......@@ -190,7 +190,7 @@ func (s *Session) garbageCollect() {
if time.Now().After(message.SentAt.Add(message.ReplyETA).Add(cConstants.RoundTripTimeSlop)) {
s.log.Debug("Garbage collecting SURB ID Map entry for Message ID %x", message.ID)
s.surbIDMap.Delete(surbID)
s.eventCh.In() <- MessageIDGarbageCollected{
s.eventCh.In() <- &MessageIDGarbageCollected{
MessageID: message.ID,
}
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment