diff --git a/packages/binary/messagelayer/messagerequester/messagerequester.go b/packages/binary/messagelayer/messagerequester/messagerequester.go index 5018520849e4a3a1b7beb0ff15626101e569059a..7ca437c68868ddea850db0c15a7715e10ba25fb9 100644 --- a/packages/binary/messagelayer/messagerequester/messagerequester.go +++ b/packages/binary/messagelayer/messagerequester/messagerequester.go @@ -56,7 +56,7 @@ func (requester *MessageRequester) ScheduleRequest(messageId message.Id) { requester.Events.SendRequest.Trigger(messageId) 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() }) }