diff options
Diffstat (limited to 'config/src/test/java/com/yahoo/config/subscription/impl/JRTConfigRequesterTest.java')
-rw-r--r-- | config/src/test/java/com/yahoo/config/subscription/impl/JRTConfigRequesterTest.java | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/config/src/test/java/com/yahoo/config/subscription/impl/JRTConfigRequesterTest.java b/config/src/test/java/com/yahoo/config/subscription/impl/JRTConfigRequesterTest.java index dca0c2d0018..07c3a5af56c 100644 --- a/config/src/test/java/com/yahoo/config/subscription/impl/JRTConfigRequesterTest.java +++ b/config/src/test/java/com/yahoo/config/subscription/impl/JRTConfigRequesterTest.java @@ -4,6 +4,7 @@ package com.yahoo.config.subscription.impl; import com.yahoo.config.subscription.ConfigSourceSet; import com.yahoo.foo.SimpletypesConfig; import com.yahoo.jrt.Request; +import com.yahoo.jrt.RequestWaiter; import com.yahoo.vespa.config.ConfigKey; import com.yahoo.vespa.config.ConnectionPool; import com.yahoo.vespa.config.ErrorCode; @@ -209,10 +210,10 @@ public class JRTConfigRequesterTest { } @Override - public void run() { + public void handle(Request request, RequestWaiter requestWaiter) { System.out.println("Running error response handler"); - request().setError(errorCode, "error"); - requestWaiter().handleRequestDone(request()); + request.setError(errorCode, "error"); + requestWaiter.handleRequestDone(request); } } @@ -224,16 +225,15 @@ public class JRTConfigRequesterTest { } @Override - public void run() { - System.out.println("Running delayed response handler (waiting " + waitTimeMilliSeconds + - ") before responding"); + public void handle(Request request, RequestWaiter requestWaiter) { + System.out.println("Running delayed response handler (waiting " + waitTimeMilliSeconds + ") before responding"); try { Thread.sleep(waitTimeMilliSeconds); } catch (InterruptedException e) { e.printStackTrace(); } - request().setError(com.yahoo.jrt.ErrorCode.TIMEOUT, "error"); - requestWaiter().handleRequestDone(request()); + request.setError(com.yahoo.jrt.ErrorCode.TIMEOUT, "error"); + requestWaiter.handleRequestDone(request); } } |