spring/spring-boot
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-boot.git synced 2026-09-17 12:09:16 +00:00
Code Issues Projects Releases Wiki Activity

Configure trust packages in AMQP test that accepts JSON

Browse Source 
See gh-49678
This commit is contained in:
Stéphane Nicoll
2026-07-15 16:56:25 +02:00
parent b5ba1ec85c
commit ebac87ae65
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
module/spring-boot-amqp/src/dockerTest/java/org/springframework/boot/amqp/autoconfigure/AmqpAutoConfigurationIntegrationTests.java
+11 -7
View File
@@ -28,6 +28,7 @@ import org.testcontainers.junit.jupiter.Testcontainers;
import org.springframework.amqp.client.AmqpClient;
import org.springframework.amqp.client.annotation.AmqpListener;
import org.springframework.amqp.support.converter.JacksonJsonMessageConverter;
import org.springframework.boot.autoconfigure.AutoConfigurations;
import org.springframework.boot.jackson.autoconfigure.JacksonAutoConfiguration;
import org.springframework.boot.test.context.runner.ApplicationContextRunner;
@@ -63,13 +64,16 @@ class AmqpAutoConfigurationIntegrationTests {
@Test
void sendAndReceiveUsingJson() {
String queue = container.createRandomQueue();
this.contextRunner.withConfiguration(AutoConfigurations.of(JacksonAutoConfiguration.class)).run((context) -> {
AmqpClient amqpClient = context.getBean(AmqpClient.class);
assertThat(amqpClient.to(queue).body(new TestMessage("hello", 42)).send().get(1, TimeUnit.SECONDS))
.isTrue();
assertThat(amqpClient.from(queue).receiveAndConvert().get(1, TimeUnit.SECONDS))
.isEqualTo(new TestMessage("hello", 42));
});
this.contextRunner.withConfiguration(AutoConfigurations.of(JacksonAutoConfiguration.class))
.withBean(JacksonJsonMessageConverter.class,
() -> new JacksonJsonMessageConverter(getClass().getPackageName()))
.run((context) -> {
AmqpClient amqpClient = context.getBean(AmqpClient.class);
assertThat(amqpClient.to(queue).body(new TestMessage("hello", 42)).send().get(1, TimeUnit.SECONDS))
.isTrue();
assertThat(amqpClient.from(queue).receiveAndConvert().get(1, TimeUnit.SECONDS))
.isEqualTo(new TestMessage("hello", 42));
});
}
@Test