summaryrefslogtreecommitdiffstats
path: root/config/src/test/java/com/yahoo/config/subscription/impl/JRTConfigRequesterTest.java
diff options
context:
space:
mode:
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.java16
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);
}
}