Hands-On Microservices with Spring Boot and Spring Cloud

Changes in the test code

Since the core services now receive events for creating and deleting their entities, the tests need to be updated so that they send events instead of calling REST APIs, like they did previously. In the following source code, we can see how the send() method on the input method channel is used to send an event:

private void sendCreateProductEvent(int productId) {    Product product = new Product(productId, "Name " + productId,     productId, "SA");    Event<Integer, Product> event = new Event(CREATE, productId,     product);    input.send(new GenericMessage<>(event));}private void sendDeleteProductEvent(int productId) {    Event<Integer, Product> event = new Event(DELETE, productId, null);    input.send(new GenericMessage<>(event));}