+ * IllegalArgumentException: SimpleMessageConverter only supports String, byte[] and + * Serializable payloads, received: com.ankurm.rabbit.OrderMessage + *+ * + *
Declaring one {@code MessageConverter} bean fixes both directions — the auto-configured + * {@code RabbitTemplate} and the listener container factory both pick it up. + * + *
Note the class name. Spring AMQP 4.1 ships {@code Jackson2JsonMessageConverter} (Jackson 2) + * and {@code JacksonJsonMessageConverter} (Jackson 3) side by side, exactly as Spring Kafka + * ships {@code JsonSerializer} and {@code JacksonJsonSerializer}. Boot 4 is a Jackson 3 + * application; pick the one without the 2. + * + * @see docs/01-the-on-ramp.md + */ +@Configuration(proxyBeanMethods = false) +public class ConverterConfiguration { + + @Bean + MessageConverter messageConverter() { + return new JacksonJsonMessageConverter(); + } + +} diff --git a/rabbitmq/src/main/java/com/ankurm/rabbit/OrderMessage.java b/rabbitmq/src/main/java/com/ankurm/rabbit/OrderMessage.java new file mode 100644 index 0000000..665e7f2 --- /dev/null +++ b/rabbitmq/src/main/java/com/ankurm/rabbit/OrderMessage.java @@ -0,0 +1,13 @@ +package com.ankurm.rabbit; + +/** + * The payload. Kept to a String field so the tests are about routing and acknowledgement rather + * than about converters. + */ +public record OrderMessage(String orderId, String detail) { + + public static OrderMessage of(String orderId) { + return new OrderMessage(orderId, "detail for " + orderId); + } + +} diff --git a/rabbitmq/src/main/java/com/ankurm/rabbit/RabbitDemoApplication.java b/rabbitmq/src/main/java/com/ankurm/rabbit/RabbitDemoApplication.java new file mode 100644 index 0000000..b7047fc --- /dev/null +++ b/rabbitmq/src/main/java/com/ankurm/rabbit/RabbitDemoApplication.java @@ -0,0 +1,20 @@ +package com.ankurm.rabbit; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * All four AMQP 0-9-1 exchange types, a working dead-letter path, and the traps that make + * RabbitMQ feel unpredictable until you know them. + * + *
Everything here runs against a real broker. See the module README for how the scripts start + * one without Docker. + */ +@SpringBootApplication +public class RabbitDemoApplication { + + public static void main(String[] args) { + SpringApplication.run(RabbitDemoApplication.class, args); + } + +} diff --git a/rabbitmq/src/main/java/com/ankurm/rabbit/Topology.java b/rabbitmq/src/main/java/com/ankurm/rabbit/Topology.java new file mode 100644 index 0000000..bf5acba --- /dev/null +++ b/rabbitmq/src/main/java/com/ankurm/rabbit/Topology.java @@ -0,0 +1,217 @@ +package com.ankurm.rabbit; + +import org.springframework.amqp.core.Binding; +import org.springframework.amqp.core.BindingBuilder; +import org.springframework.amqp.core.DirectExchange; +import org.springframework.amqp.core.FanoutExchange; +import org.springframework.amqp.core.HeadersExchange; +import org.springframework.amqp.core.Queue; +import org.springframework.amqp.core.QueueBuilder; +import org.springframework.amqp.core.TopicExchange; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import java.util.Map; + +/** + * The whole topology as beans. {@code RabbitAdmin} declares every {@code Exchange}, + * {@code Queue} and {@code Binding} bean when the connection is first opened. + * + *
Two things about that are worth knowing before you rely on it: + *
Included because the article states all three triggers in one table, and this was the only
+ * row not produced by a run. It is now.
+ *
+ * @see docs/04-dead-lettering.md
+ */
+@SpringBootTest
+class MaxLengthTest {
+
+ static final String Q_BOUNDED = "orders.bounded";
+
+ @Autowired
+ RabbitTemplate template;
+
+ @Autowired
+ RabbitAdmin admin;
+
+ @Test
+ @SuppressWarnings("unchecked")
+ void exceedingMaxLengthDeadLettersTheOldestWithReasonMaxlen() throws Exception {
+ this.admin.deleteQueue(Q_BOUNDED);
+ Queue bounded = QueueBuilder.durable(Q_BOUNDED)
+ .maxLength(2)
+ .deadLetterExchange(Topology.DLX)
+ .deadLetterRoutingKey("failed")
+ .build();
+ this.admin.declareQueue(bounded);
+ Binding binding = BindingBuilder.bind(bounded)
+ .to(new DirectExchange(Topology.DIRECT)).with("bounded");
+ this.admin.declareBinding(binding);
+ this.admin.purgeQueue(Topology.Q_DLQ, false);
+
+ // Three messages into a queue that holds two. RabbitMQ drops from the HEAD, so the
+ // FIRST message is the one dead-lettered - the oldest, not the newest.
+ for (String id : List.of("m-1", "m-2", "m-3")) {
+ this.template.convertAndSend(Topology.DIRECT, "bounded", OrderMessage.of(id));
+ }
+
+ var message = this.template.receive(Topology.Q_DLQ, 10_000);
+ assertThat(message).isNotNull();
+ List Note the {@code Number}: {@code RabbitAdmin.QUEUE_MESSAGE_COUNT} holds a {@code Long}
+ * in Spring AMQP 4.1. Casting it to {@code Integer}, as every older example does, is a
+ * {@code ClassCastException} at runtime.
+ */
+ private int depth(String queue) {
+ Properties properties = this.admin.getQueueProperties(queue);
+ return (properties == null) ? -1
+ : ((Number) properties.get(RabbitAdmin.QUEUE_MESSAGE_COUNT)).intValue();
+ }
+
+ /** Publishing is asynchronous; give the broker a moment to route before counting. */
+ private int settledDepth(String queue) {
+ int last = -1;
+ for (int i = 0; i < 50; i++) {
+ last = depth(queue);
+ if (last > 0) {
+ return last;
+ }
+ try {
+ Thread.sleep(20);
+ }
+ catch (InterruptedException ex) {
+ Thread.currentThread().interrupt();
+ }
+ }
+ return last;
+ }
+
+ @Test
+ void directExchangeMatchesTheRoutingKeyExactly() {
+ this.template.convertAndSend(Topology.DIRECT, "new", OrderMessage.of("o-1"));
+ this.template.convertAndSend(Topology.DIRECT, "cancel", OrderMessage.of("o-2"));
+ // No binding for "amend". The broker discards it - see UnroutableTest.
+ this.template.convertAndSend(Topology.DIRECT, "amend", OrderMessage.of("o-3"));
+
+ assertThat(settledDepth(Topology.Q_NEW)).isEqualTo(1);
+ assertThat(settledDepth(Topology.Q_CANCEL)).isEqualTo(1);
+ }
+
+ @Test
+ void fanoutIgnoresTheRoutingKeyCompletely() {
+ this.template.convertAndSend(Topology.FANOUT, "this-is-ignored", OrderMessage.of("o-1"));
+
+ assertThat(settledDepth(Topology.Q_AUDIT)).isEqualTo(1);
+ assertThat(settledDepth(Topology.Q_ANALYTICS)).isEqualTo(1);
+ }
+
+ @Test
+ void topicWildcardsAreWordsNotCharacters() {
+ // binding "order.eu.*" - exactly one word after order.eu
+ // binding "order.#.high" - zero or more words between order. and .high
+ Map {@code @ServiceConnection} supplies host, port, username and password to the
+ * auto-configuration, so no {@code spring.rabbitmq.*} property and no
+ * {@code @DynamicPropertySource} block is needed.
+ *
+ * The Maven coordinate is {@code org.testcontainers:testcontainers-rabbitmq}.
+ * Testcontainers 2.x prefixed every module artifact; the old {@code org.testcontainers:rabbitmq}
+ * stopped at 1.21.4 and is not managed by the Boot 4.1 BOM.
+ *
+ * The committed transcripts under {@code docs/output/} came from a broker started by
+ * {@code scripts/broker.sh} instead, on a machine with no Docker — see the module README
+ * for why that matters and what version it was.
+ */
+@TestConfiguration(proxyBeanMethods = false)
+public class TestcontainersConfiguration {
+
+ @Bean
+ @ServiceConnection
+ RabbitMQContainer rabbitContainer() {
+ return new RabbitMQContainer(DockerImageName.parse("rabbitmq:4.1-management"));
+ }
+
+}
diff --git a/rabbitmq/src/test/java/com/ankurm/rabbit/TopologyTrapsTest.java b/rabbitmq/src/test/java/com/ankurm/rabbit/TopologyTrapsTest.java
new file mode 100644
index 0000000..5c37e91
--- /dev/null
+++ b/rabbitmq/src/test/java/com/ankurm/rabbit/TopologyTrapsTest.java
@@ -0,0 +1,100 @@
+package com.ankurm.rabbit;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.amqp.AmqpIOException;
+import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.core.QueueBuilder;
+import org.springframework.amqp.core.ReturnedMessage;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.List;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
+
+/**
+ * Two ways a RabbitMQ topology loses your work quietly.
+ *
+ * @see docs/03-the-silent-drop.md
+ * @see docs/06-changing-your-mind.md
+ */
+@SpringBootTest
+class TopologyTrapsTest {
+
+ @Autowired
+ RabbitTemplate template;
+
+ @Autowired
+ RabbitAdmin admin;
+
+ @Test
+ void anUnroutableMessageIsDiscardedUnlessYouAskForItBack() throws Exception {
+ List