本文整理了Java中org.mockserver.model.HttpRequest.request()
方法的一些代码示例,展示了HttpRequest.request()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HttpRequest.request()
方法的具体详情如下:
包路径:org.mockserver.model.HttpRequest
类名称:HttpRequest
方法名:request
暂无
代码示例来源:origin: jamesdbloom/mockserver
/**
* Reset MockServer by clearing all expectations
*/
public MockServerClient reset() {
MockServerEventBus.getInstance().publish(EventType.RESET);
sendRequest(request().withMethod("PUT").withPath(calculatePath("reset")));
return clientClass.cast(this);
}
代码示例来源:origin: testcontainers/testcontainers-java
private static String responseFromMockserver(MockServerContainer mockServer, String expectedBody, String path) throws IOException {
new MockServerClient(mockServer.getContainerIpAddress(), mockServer.getServerPort())
.when(request(path))
.respond(response(expectedBody));
URLConnection urlConnection = new URL(mockServer.getEndpoint() + path).openConnection();
@Cleanup BufferedReader reader = new BufferedReader(new InputStreamReader(urlConnection.getInputStream()));
return reader.readLine();
}
}
代码示例来源:origin: jamesdbloom/mockserver
@Override
public HttpResponse call() throws Exception {
return httpClient.sendRequest(
request(addContextToPath(calculatePath("delayed")))
.withHeader(HOST.toString(), "localhost:" + getServerPort())
).get(10, TimeUnit.SECONDS);
}
});
代码示例来源:origin: jamesdbloom/mockserver
@Override
public HttpRequest handle(HttpRequest httpRequest) {
return request()
.withHeader("Host", "localhost:" + httpRequest.getFirstHeader("x-echo-server-port"))
.withHeader("x-test", httpRequest.getFirstHeader("x-test"))
.withBody("some_overridden_body")
.withSecure(httpRequest.isSecure());
}
}
代码示例来源:origin: Netflix/eureka
@Test
public void testHeartbeatReplicationWithNoResponseBody() throws Exception {
serverMockClient.when(
request()
.withMethod("PUT")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/apps/" + instanceInfo.getAppName() + '/' + instanceInfo.getId())
).respond(
response().withStatusCode(200)
);
EurekaHttpResponse<InstanceInfo> response = replicationClient.sendHeartBeat(instanceInfo.getAppName(), instanceInfo.getId(), instanceInfo, InstanceStatus.DOWN);
assertThat(response.getStatusCode(), is(equalTo(200)));
assertThat(response.getEntity(), is(nullValue()));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testRegistrationReplication() throws Exception {
serverMockClient.when(
request()
.withMethod("POST")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/apps/" + instanceInfo.getAppName())
).respond(
response().withStatusCode(200)
);
EurekaHttpResponse<Void> response = replicationClient.register(instanceInfo);
assertThat(response.getStatusCode(), is(equalTo(200)));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testRegistrationReplication() throws Exception {
serverMockClient.when(
request()
.withMethod("POST")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/apps/" + instanceInfo.getAppName())
).respond(
response().withStatusCode(200)
);
EurekaHttpResponse<Void> response = replicationClient.register(instanceInfo);
assertThat(response.getStatusCode(), is(equalTo(200)));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testHeartbeatReplicationWithNoResponseBody() throws Exception {
serverMockClient.when(
request()
.withMethod("PUT")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/apps/" + instanceInfo.getAppName() + '/' + instanceInfo.getId())
).respond(
response().withStatusCode(200)
);
EurekaHttpResponse<InstanceInfo> response = replicationClient.sendHeartBeat(instanceInfo.getAppName(), instanceInfo.getId(), instanceInfo, InstanceStatus.DOWN);
assertThat(response.getStatusCode(), is(equalTo(200)));
assertThat(response.getEntity(), is(nullValue()));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testAsgStatusUpdateReplication() throws Exception {
serverMockClient.when(
request()
.withMethod("PUT")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/asg/" + instanceInfo.getASGName() + "/status")
).respond(
response().withStatusCode(200)
);
EurekaHttpResponse<Void> response = replicationClient.statusUpdate(instanceInfo.getASGName(), ASGStatus.ENABLED);
assertThat(response.getStatusCode(), is(equalTo(200)));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testAsgStatusUpdateReplication() throws Exception {
serverMockClient.when(
request()
.withMethod("PUT")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/asg/" + instanceInfo.getASGName() + "/status")
).respond(
response().withStatusCode(200)
);
EurekaHttpResponse<Void> response = replicationClient.statusUpdate(instanceInfo.getASGName(), ASGStatus.ENABLED);
assertThat(response.getStatusCode(), is(equalTo(200)));
}
代码示例来源:origin: oblac/jodd
@Test
void testDirect() {
HttpResponse response = HttpRequest.get("http://localhost:1080/get_books").send();
assertEquals(200, response.statusCode());
assertTrue(response.body().contains("Tatum"));
proxy.verify(request().withPath("/get_books"), exactly(0));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testDeleteStatusOverrideReplication() throws Exception {
serverMockClient.when(
request()
.withMethod("DELETE")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/apps/" + instanceInfo.getAppName() + '/' + instanceInfo.getId() + "/status")
).respond(
response().withStatusCode(204)
);
EurekaHttpResponse<Void> response = replicationClient.deleteStatusOverride(instanceInfo.getAppName(), instanceInfo.getId(), instanceInfo);
assertThat(response.getStatusCode(), is(equalTo(204)));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testDeleteStatusOverrideReplication() throws Exception {
serverMockClient.when(
request()
.withMethod("DELETE")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/apps/" + instanceInfo.getAppName() + '/' + instanceInfo.getId() + "/status")
).respond(
response().withStatusCode(204)
);
EurekaHttpResponse<Void> response = replicationClient.deleteStatusOverride(instanceInfo.getAppName(), instanceInfo.getId(), instanceInfo);
assertThat(response.getStatusCode(), is(equalTo(204)));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testCancelReplication() throws Exception {
serverMockClient.when(
request()
.withMethod("DELETE")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/apps/" + instanceInfo.getAppName() + '/' + instanceInfo.getId())
).respond(
response().withStatusCode(204)
);
EurekaHttpResponse<Void> response = replicationClient.cancel(instanceInfo.getAppName(), instanceInfo.getId());
assertThat(response.getStatusCode(), is(equalTo(204)));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testCancelReplication() throws Exception {
serverMockClient.when(
request()
.withMethod("DELETE")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/apps/" + instanceInfo.getAppName() + '/' + instanceInfo.getId())
).respond(
response().withStatusCode(204)
);
EurekaHttpResponse<Void> response = replicationClient.cancel(instanceInfo.getAppName(), instanceInfo.getId());
assertThat(response.getStatusCode(), is(equalTo(204)));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testStatusUpdateReplication() throws Exception {
serverMockClient.when(
request()
.withMethod("PUT")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/apps/" + instanceInfo.getAppName() + '/' + instanceInfo.getId() + "/status")
).respond(
response().withStatusCode(200)
);
EurekaHttpResponse<Void> response = replicationClient.statusUpdate(instanceInfo.getAppName(), instanceInfo.getId(), InstanceStatus.DOWN, instanceInfo);
assertThat(response.getStatusCode(), is(equalTo(200)));
}
代码示例来源:origin: Netflix/eureka
@Test
public void testStatusUpdateReplication() throws Exception {
serverMockClient.when(
request()
.withMethod("PUT")
.withHeader(header(PeerEurekaNode.HEADER_REPLICATION, "true"))
.withPath("/eureka/v2/apps/" + instanceInfo.getAppName() + '/' + instanceInfo.getId() + "/status")
).respond(
response().withStatusCode(200)
);
EurekaHttpResponse<Void> response = replicationClient.statusUpdate(instanceInfo.getAppName(), instanceInfo.getId(), InstanceStatus.DOWN, instanceInfo);
assertThat(response.getStatusCode(), is(equalTo(200)));
}
代码示例来源:origin: oblac/jodd
@Test
void testDirectHttps() {
HttpResponse response = HttpRequest.get("https://localhost:1080/get_books").trustAllCerts(true).send();
assertEquals(200, response.statusCode());
assertTrue(response.body().contains("Tatum"));
proxy.verify(request().withPath("/get_books"), exactly(0));
}
代码示例来源:origin: oblac/jodd
@Test
void testSocks5Proxy() {
SocketHttpConnectionProvider s = new SocketHttpConnectionProvider();
s.useProxy(ProxyInfo.socks5Proxy("localhost", 1090, null, null));
HttpResponse response = HttpRequest.get("http://localhost:1080/get_books")
.withConnectionProvider(s)
.send();
assertEquals(200, response.statusCode());
assertTrue(response.body().contains("Tatum"));
proxy.verify(request().withPath("/get_books"), exactly(1));
}
代码示例来源:origin: oblac/jodd
@Test
void testSocks5ProxyWithHttps() {
SocketHttpConnectionProvider s = new SocketHttpConnectionProvider();
s.useProxy(ProxyInfo.socks5Proxy("localhost", 1090, null, null));
HttpResponse response = HttpRequest.get("https://localhost:1080/get_books")
.withConnectionProvider(s)
.trustAllCerts(true)
.send();
assertEquals(200, response.statusCode());
assertTrue(response.body().contains("Tatum"));
proxy.verify(request().withPath("/get_books"), exactly(1));
}
内容来源于网络,如有侵权,请联系作者删除!