Skip to content
Snippets Groups Projects
Unverified Commit 81684f7e authored by Wolfgang Welz's avatar Wolfgang Welz
Browse files

re-request messages unlimitedly

parent d24114cf
Branches
Tags
No related merge requests found
...@@ -56,7 +56,7 @@ func (requester *MessageRequester) ScheduleRequest(messageId message.Id) { ...@@ -56,7 +56,7 @@ func (requester *MessageRequester) ScheduleRequest(messageId message.Id) {
requester.Events.SendRequest.Trigger(messageId) requester.Events.SendRequest.Trigger(messageId)
requester.scheduledRequestsMutex.Lock() requester.scheduledRequestsMutex.Lock()
requester.scheduledRequests[messageId] = time.AfterFunc(requester.options.retryInterval, func() { retryRequest(false) }) requester.scheduledRequests[messageId] = time.AfterFunc(requester.options.retryInterval, func() { retryRequest(true) })
requester.scheduledRequestsMutex.Unlock() requester.scheduledRequestsMutex.Unlock()
}) })
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment