Searched refs:errorRetryQueue (Results 1 – 2 of 2) sorted by relevance
1049 BlockingQueue<Long> errorRetryQueue = new LinkedBlockingQueue<>(); in testRequestCapabilitiesWithPresenceMechanism() local1064 errorRetryQueue.offer(retryAfterMilliseconds); in testRequestCapabilitiesWithPresenceMechanism()1121 errorRetryQueue.clear(); in testRequestCapabilitiesWithPresenceMechanism()1148 errorRetryQueue.clear(); in testRequestCapabilitiesWithPresenceMechanism()1334 BlockingQueue<Long> errorRetryQueue = new LinkedBlockingQueue<>(); in testRequestCapabilitiesFromCacheWithPresenceMechanism() local1349 errorRetryQueue.offer(retryAfterMilliseconds); in testRequestCapabilitiesFromCacheWithPresenceMechanism()1388 errorRetryQueue.clear(); in testRequestCapabilitiesFromCacheWithPresenceMechanism()1407 errorRetryQueue.clear(); in testRequestCapabilitiesFromCacheWithPresenceMechanism()2186 BlockingQueue<Long> errorRetryQueue = new LinkedBlockingQueue<>(); in testTerminatedCallbackWithCapabilitiesRequest() local2201 errorRetryQueue.offer(retryAfterMillis); in testTerminatedCallbackWithCapabilitiesRequest()[all …]
2760 LinkedBlockingQueue<Long> errorRetryQueue = new LinkedBlockingQueue<>(); in testRcsPublishWithAuthorizedErrorResponse() local2775 errorRetryQueue.offer(retryAfterMilliseconds); in testRcsPublishWithAuthorizedErrorResponse()2802 assertEquals(Long.valueOf(0L), waitForResult(errorRetryQueue)); in testRcsPublishWithAuthorizedErrorResponse()2807 errorRetryQueue.clear(); in testRcsPublishWithAuthorizedErrorResponse()