stawros/http-mock-server
1
0
Fork 0
Code Releases Packages Activity

Add logger configuration

Browse source 
Change-Id: I8a7c4ac0e09eb114845547202aa27792741cf549
This commit is contained in:
Dominik Adam Przybysz 2015-12-16 20:30:49 +01:00 • committed by Dominik Przybysz
parent bfc547721e
commit 951a0f1b56
3 changed files with 30 additions and 74 deletions
Download patch file Download diff file Expand all files Collapse all files

59
mockserver-tests/src/test/groovy/pl/touk/mockserver/tests/ServerMockPT.groovy
View file

@ -1,59 +0,0 @@
package pl.touk.mockserver.tests
import org.apache.http.client.HttpClient
import org.apache.http.client.methods.CloseableHttpResponse
import org.apache.http.client.methods.HttpPost
import org.apache.http.entity.ContentType
import org.apache.http.entity.StringEntity
import org.apache.http.impl.client.HttpClients
import pl.touk.mockserver.api.request.AddMock
import pl.touk.mockserver.client.RemoteMockServer
import pl.touk.mockserver.client.Util
import pl.touk.mockserver.server.HttpMockServer
import spock.lang.Specification
import spock.lang.Timeout
import java.util.concurrent.ExecutorService
import java.util.concurrent.Executors
import java.util.concurrent.TimeUnit
class ServerMockPT extends Specification {
@Timeout(value = 90)
def "should handle many request simultaneously"() {
given:
HttpClient client = HttpClients.createDefault()
HttpMockServer httpMockServer = new HttpMockServer()
RemoteMockServer controlServerClient = new RemoteMockServer("localhost", 9999)
int requestAmount = 1000
String[] responses = new String[requestAmount]
ExecutorService executorService = Executors.newCachedThreadPool()
when:
for (int i = 0; i < requestAmount; ++i) {
int current = i
executorService.submit {
int endpointNumber = current % 10
int port = 9000 + (current % 7)
controlServerClient.addMock(new AddMock(
name: "testRest$current",
path: "testEndpoint$endpointNumber",
port: port,
predicate: """{req -> req.xml.name() == 'request$current'}""",
response: """{req -> "<goodResponse$current/>"}"""
))
HttpPost restPost = new HttpPost("http://localhost:$port/testEndpoint$endpointNumber")
restPost.entity = new StringEntity("<request$current/>", ContentType.create("text/xml", "UTF-8"))
CloseableHttpResponse response = client.execute(restPost)
responses[current] = Util.extractStringResponse(response)
controlServerClient.removeMock("testRest$current", true)
}
}
executorService.shutdown()
executorService.awaitTermination(90, TimeUnit.SECONDS)
then:
responses.eachWithIndex { res, i -> assert res && new XmlSlurper().parseText(res).name() == "goodResponse$i" as String }
cleanup:
executorService.shutdown()
httpMockServer.stop()
}
}