diff --git a/packages/binary/messagelayer/messagerequester/messagerequester.go b/packages/binary/messagelayer/messagerequester/messagerequester.go index 068451643a9ea3d239e52006e6bf63f9a9bd4733..caad920c645a5976b94ed93be2210f39d6eff540 100644 --- a/packages/binary/messagelayer/messagerequester/messagerequester.go +++ b/packages/binary/messagelayer/messagerequester/messagerequester.go @@ -69,3 +69,10 @@ func (requester *MessageRequester) reRequest(id message.Id) { requester.scheduledRequests[id] = time.AfterFunc(requester.options.retryInterval, func() { requester.reRequest(id) }) } } + +// RequestQueueSize returns the number of scheduled message requests. +func (requester *MessageRequester) RequestQueueSize() int { + requester.scheduledRequestsMutex.RLock() + defer requester.scheduledRequestsMutex.RUnlock() + return len(requester.scheduledRequests) +}