Patrick.Sy/spring-petclinic
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-petclinic.git synced 2025-07-21 07:15:49 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

ignore publish

Browse source
This commit is contained in:
Roni Dover 2024-04-14 17:48:43 -07:00
parent 0aea5a67f4
commit f3a725e59e
2 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/main/java/org/springframework/samples/petclinic/adapters/PetVaccinationRequestMessage.java
View file

@ -3,6 +3,8 @@ package org.springframework.samples.petclinic.adapters;
import org.springframework.kafka.core.KafkaTemplate; import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.io.Console;
@Component @Component
public class PetVaccinationRequestMessage { public class PetVaccinationRequestMessage {
@ -15,7 +17,12 @@ public class PetVaccinationRequestMessage {
public void Send() { public void Send() {
// template.convertAndSend("petVaccineRequests", "Hello, world!"); // template.convertAndSend("petVaccineRequests", "Hello, world!");
try {
kafkaTemplate.send("petVaccineRequests", "test"); kafkaTemplate.send("petVaccineRequests", "test");
} }
catch (Exception e) {
System.out.println(e.getMessage());
}
}
} }

2
src/test/java/org/springframework/samples/petclinic/integration/OwnerControllerTests.java
View file

@ -104,7 +104,7 @@ class OwnerControllerTests {
.statusCode(200) .statusCode(200)
.body(ownerLinkMatcher, Matchers.notNullValue()); .body(ownerLinkMatcher, Matchers.notNullValue());
assertThat(false).isTrue(); // assertThat(false).isTrue();
} }