Back to Repositories

Testing RabbitMQ Producer Confirmation Workflow in SpringBoot-Labs

This test suite evaluates RabbitMQ message producer functionality in a Spring Boot application with confirmation handling. It focuses on synchronous message sending with producer confirmation patterns, demonstrating integration between Spring Boot and RabbitMQ messaging systems.

Test Coverage Overview

The test coverage focuses on synchronous message sending capabilities with RabbitMQ producer confirmation.

Tests synchronous message dispatch with unique message IDs
Verifies producer confirmation handling
Includes message delivery tracking
Validates logging of successful message transmission

Implementation Analysis

The testing approach utilizes Spring Boot’s test framework with JUnit integration. The implementation employs a CountDownLatch for thread synchronization to ensure message consumption completion before test termination.

Utilizes @SpringBootTest for full context loading
Implements synchronous producer testing patterns
Employs dependency injection for producer component

Technical Details

JUnit 4 testing framework
Spring Boot Test context
SLF4J logging framework
RabbitMQ client libraries
CountDownLatch for thread synchronization
Spring Runner for test execution

Best Practices Demonstrated

The test suite demonstrates several testing best practices for message-based systems.

Proper test isolation using Spring Boot test context
Effective logging implementation
Thread-safe message consumption verification
Clean separation of producer component testing
Systematic message tracking with unique identifiers

yudaocode/springboot-labs

lab-04-rabbitmq/lab-04-rabbitmq-demo-confirm/src/test/java/cn/iocoder/springboot/lab04/rabbitmqdemo/producer/Demo13ProducerTest.java

            
package cn.iocoder.springboot.lab04.rabbitmqdemo.producer;

import cn.iocoder.springboot.lab04.rabbitmqdemo.Application;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.concurrent.CountDownLatch;

@RunWith(SpringRunner.class)
@SpringBootTest(classes = Application.class)
public class Demo13ProducerTest {

    private Logger logger = LoggerFactory.getLogger(getClass());

    @Autowired
    private Demo13Producer producer;

    @Test
    public void testSyncSend() throws InterruptedException {
        int id = (int) (System.currentTimeMillis() / 1000);
        producer.syncSend(id);
        logger.info("[testSyncSend][发送编号：[{}] 发送成功]", id);

        // 阻塞等待，保证消费
        new CountDownLatch(1).await();
    }

}