testMessagePublishingToQueue

src/test/java/com/github/fridujo/rabbitmq/mock/MessagePublishingTest.java

@@ -0,0 +1,46 @@
+package com.github.fridujo.rabbitmq.mock;
+import static org.junit.jupiter.api.Assertions.*;
+
+import com.github.fridujo.rabbitmq.mock.MockConnectionFactory;
+import com.rabbitmq.client.*;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+import java.util.concurrent.TimeoutException;
+
+class MessagePublishingTest {
+
+    private Connection connection;
+    private Channel channel;
+
+    @BeforeEach
+    void setUp() throws IOException, TimeoutException { // Create a mock of an in-memory RabbitMQ mock 
+        ConnectionFactory factory = new MockConnectionFactory();
+        connection = factory.newConnection();
+        channel = connection.createChannel();
+    }
+
+    @Test
+    void testMessagePublishingToQueue() throws IOException {
+        String exchangeName = "testExchange";
+        String queueName = "testQueue";
+        String routingKey = "testKey";
+        String message = "Test message for RabbitMQ";
+
+        // Declare exchange and queue, then bind them
+        channel.exchangeDeclare(exchangeName, BuiltinExchangeType.DIRECT);
+        channel.queueDeclare(queueName, false, false, false, null);
+        channel.queueBind(queueName, exchangeName, routingKey);
+
+        // Publish a message
+        channel.basicPublish(exchangeName, routingKey, null, message.getBytes(StandardCharsets.UTF_8));
+
+        // Consume the message from the queue
+        GetResponse response = channel.basicGet(queueName, true);
+        assertNotNull(response);
+        assertEquals(message, new String(response.getBody(), StandardCharsets.UTF_8));
+    }
+}