129 version, serverKeepalive, async)); |
129 version, serverKeepalive, async)); |
130 MockServer server = new MockServer(0, factory); |
130 MockServer server = new MockServer(0, factory); |
131 URI uri = new URI(server.getURL()); |
131 URI uri = new URI(server.getURL()); |
132 out.println("server is: " + uri); |
132 out.println("server is: " + uri); |
133 server.start(); |
133 server.start(); |
|
134 |
|
135 |
|
136 // The following code can be uncommented to verify that the |
|
137 // MockServer will reject rogue requests whose URI does not |
|
138 // contain "/foo/". |
|
139 // |
|
140 // Thread rogue = new Thread() { |
|
141 // public void run() { |
|
142 // try { |
|
143 // HttpClient client = newHttpClient(); |
|
144 // URI uri2 = URI.create(uri.toString().replace("/foo/","/")); |
|
145 // HttpRequest request = HttpRequest |
|
146 // .newBuilder(uri2).version(version).build(); |
|
147 // while (true) { |
|
148 // try { |
|
149 // client.send(request, HttpResponse.BodyHandler.asString()); |
|
150 // } catch (IOException ex) { |
|
151 // System.out.println("Client rejected " + request); |
|
152 // } |
|
153 // sleep(250); |
|
154 // } |
|
155 // } catch ( Throwable x) { |
|
156 // } |
|
157 // } |
|
158 // }; |
|
159 // rogue.setDaemon(true); |
|
160 // rogue.start(); |
|
161 |
134 |
162 |
135 HttpClient client = newHttpClient(); |
163 HttpClient client = newHttpClient(); |
136 HttpRequest request = HttpRequest.newBuilder(uri).version(version).build(); |
164 HttpRequest request = HttpRequest.newBuilder(uri).version(version).build(); |
137 HttpResponse<String> r; |
165 HttpResponse<String> r; |
138 CompletableFuture<HttpResponse<String>> cf1; |
166 CompletableFuture<HttpResponse<String>> cf1; |