ticker.advance(ThreadLocalRandom.current().nextLong());
doReturn(ticker).when(mockContext).ticker();
+ final ClientActorConfig mockConfig = AccessClientUtil.newMockClientActorConfig();
+ doReturn(mockConfig).when(mockContext).config();
+
mockActor = TestProbe.apply(actorSystem);
mockBackendInfo = new BackendInfo(mockActor.ref(), 0, ABIVersion.current(), 5);
mockRequest = new MockRequest(mockIdentifier, mockReplyTo);
public void testRunTimeoutWithTimeoutLess() throws NoProgressException {
queue.sendRequest(mockRequest, mockCallback);
- ticker.advance(AbstractClientConnection.BACKEND_ALIVE_TIMEOUT_NANOS - 1);
+ ticker.advance(AbstractClientConnection.DEFAULT_BACKEND_ALIVE_TIMEOUT_NANOS - 1);
Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
queue.sendRequest(mockRequest, mockCallback);
- ticker.advance(AbstractClientConnection.BACKEND_ALIVE_TIMEOUT_NANOS);
+ ticker.advance(AbstractClientConnection.DEFAULT_BACKEND_ALIVE_TIMEOUT_NANOS);
Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNull(ret);
queue.sendRequest(mockRequest, mockCallback);
- ticker.advance(AbstractClientConnection.BACKEND_ALIVE_TIMEOUT_NANOS + 1);
+ ticker.advance(AbstractClientConnection.DEFAULT_BACKEND_ALIVE_TIMEOUT_NANOS + 1);
Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNull(ret);
public void testRunTimeoutWithoutProgressExact() throws NoProgressException {
queue.sendRequest(mockRequest, mockCallback);
- ticker.advance(AbstractClientConnection.NO_PROGRESS_TIMEOUT_NANOS);
+ ticker.advance(AbstractClientConnection.DEFAULT_NO_PROGRESS_TIMEOUT_NANOS);
// Kaboom
queue.runTimer((ClientActorBehavior) mockBehavior);
public void testRunTimeoutWithoutProgressMore() throws NoProgressException {
queue.sendRequest(mockRequest, mockCallback);
- ticker.advance(AbstractClientConnection.NO_PROGRESS_TIMEOUT_NANOS + 1);
+ ticker.advance(AbstractClientConnection.DEFAULT_NO_PROGRESS_TIMEOUT_NANOS + 1);
// Kaboom
queue.runTimer((ClientActorBehavior) mockBehavior);
@Test
public void testRunTimeoutEmptyWithoutProgressExact() throws NoProgressException {
- ticker.advance(AbstractClientConnection.NO_PROGRESS_TIMEOUT_NANOS);
+ ticker.advance(AbstractClientConnection.DEFAULT_NO_PROGRESS_TIMEOUT_NANOS);
// No problem
Optional<Long> ret = queue.checkTimeout(ticker.read());
@Test
public void testRunTimeoutEmptyWithoutProgressMore() throws NoProgressException {
- ticker.advance(AbstractClientConnection.NO_PROGRESS_TIMEOUT_NANOS + 1);
+ ticker.advance(AbstractClientConnection.DEFAULT_NO_PROGRESS_TIMEOUT_NANOS + 1);
// No problem
Optional<Long> ret = queue.checkTimeout(ticker.read());
queue.sendRequest(mockRequest2, mockCallback);
queue.receiveResponse(mockResponseEnvelope);
- ticker.advance(AbstractClientConnection.NO_PROGRESS_TIMEOUT_NANOS - 11);
+ ticker.advance(AbstractClientConnection.DEFAULT_NO_PROGRESS_TIMEOUT_NANOS - 11);
Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNull(ret);