Sniffing Request and Response on Wiremock

Sniffing Request and Response on Wiremock


Often we use Wiremock on our test classes without knowing how the entire request or response looks like, well, mostly the requests since we can construct the response body from plain string. For that apparently Wiremock has a nice little request listener that can be utilised to print out all requests received by the Wiremock port:

Syntax:
  @Rule
  WireMockRule wmr = new WireMockRule(8888);


  @Before
  public void setUp() {

    wmr.addMockServiceRequestListener(new RequestListener() {

      @Override
      public void requestReceived(Request req, Response resp) {
        System.out.println("URL: " + req.getAbsoluteUrl());
        System.out.println("Req Body: " + req.getBodyAsString());
        System.out.println("Resp Code: " + resp.getStatus());
        System.out.println("Resp Body: " + resp.getBodyAsString());
      }
    });
  }


or the Java 8 way:
    wmr.addMockServiceRequestListener((req, resp) -> {
        System.out.println("URL: " + req.getAbsoluteUrl());
        System.out.println("Req Body: " + req.getBodyAsString());
        System.out.println("Resp Code: " + resp.getStatus());
        System.out.println("Resp Body: " + resp.getBodyAsString());
      }



Minimal Example:

@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = WebEnvironment.RANDOM_PORT)
public class WireMockTest {

  @Rule
  public WireMockRule wmr = new WireMockRule(8888);


  @Before
  public void setUp() {

    wmr.addMockServiceRequestListener((req, resp) -> {
      System.out.println("URL: " + req.getAbsoluteUrl());
      System.out.println("Req Body: " + req.getBodyAsString());
      System.out.println("Resp Code: " + resp.getStatus());
      System.out.println("Resp Body: " + resp.getBodyAsString());
    });
  }


  @Autowired
  TestRestTemplate template;

  @Test
  public void test() {
    wmr.stubFor(post(urlEqualTo("/some/thing"))
        .willReturn(aResponse().withHeader("Content-Type", "text/plain").withBody("Hello world!")));

    template.postForObject("http://localhost:8888/some/thing", "Hello?", String.class);
  }
}

 Output of Minimal Example:
URL: http://localhost:8888/some/thing
Req Body: Hello?
Resp Code: 200
Resp Body: Hello world!

Have fun sniffing!!

Comments

Post a Comment

Popular posts from this blog

Image
Implementing gRPC Using Spring Boot and Gradle Background GRPC (gRPC) is a RPC framework pioneered by google later on made public and open source. GRPC has not been officially supported by Spring Framework, so far there are few community libraries that can work seamlessly with Spring Boot. In this article, I will use the lognet's grpc-spring-boot-starter. Project Structure Ideally, the proto files for gRPC is located in another directory, which will then be accessed by the gradle plugin to auto generate the required files.   Gradle Script The heart of gRPC enablement lies on the grpc boot starter, which includes few other tasks outlined as below. https://github.com/overtakerx/grpcbootdemo/blob/main/build.gradle Few important note: first you have to run gradlew compileJava for the auto generation to generate the files from the proto file, then you will need to rebuild the project for Intellij to recognise the auto-generated files. Full demo: https://github.com/overtakerx/grpcbootdem
Read more

Spring Boot 2: Parallelism with Spring WebFlux

Image
Spring Boot 2: Parallelism with Spring WebFlux Parallelism is rather unusual in Spring application, however when we encounter the need of HITLOL (HIgh Throughput LOw Latency), we need ways to make async calls. With Spring Boot 1, in high level definition, we can declare async on all the functions that are meant to be parallel and return Futures from there. Here is more detailed info:  https://medium.com/sipios/how-to-make-parallel-calls-in-java-springboot-application-and-how-to-test-them-dcc27318a0cf For Spring Boot 2, we shall employ Spring WebFlux libraries to accomplish parallelism. Mainly focused on functions: Mono.zipDelayError(), Mono.subscribeOn() and Mono.onErrorResume() The main function that drives the parallelism is zipDelayError(), the purpose of zipDelayError() as supposed to using zip() is to enable the other Monos to run to completion even if one Mono failed. AllDtos allDtos = Mono. zipDelayError (Arrays. asList (firstDto , secondDto , (Mono&l
Read more

Spring Boot Reactive API Part 2

Image
 Spring Boot Reactive: Improving CPU bound performance using Scheduler In part 1 , we have seen that Spring Boot Reactive doesn't really improve performance if the WAITING time is CPU bound / CPU intensive tasks. This article show a quick way on how we can improve the speed through specific configuration Setup Spring Boot's embedded Tomcat is reconfigured to only use 10 worker threads, this way we can clearly see the performance limitation and tweaks. Gatling is configured to simulate 30 concurrent requests with 30000 milliseconds request timeout. APIs internal process is calling java native code that calculate the value of PI over 1 million iterations Default / No scheduler The main reason why CPU bound tasks do not improve (or even degrade) with high parallelism is because of the costly overhead for context switching in the low level. In the scenario below, 10 main threads are all being used to calculate PI values and because there are less CPU than threads, a lot of context
Read more