diff --git a/mq-starter-redis-stream/src/test/java/com/njcn/mq/driver/redis/RedisStreamMqDriverWiringTest.java b/mq-starter-redis-stream/src/test/java/com/njcn/mq/driver/redis/RedisStreamMqDriverWiringTest.java new file mode 100644 index 0000000..3e2663a --- /dev/null +++ b/mq-starter-redis-stream/src/test/java/com/njcn/mq/driver/redis/RedisStreamMqDriverWiringTest.java @@ -0,0 +1,33 @@ +package com.njcn.mq.driver.redis; + +import com.njcn.mq.autoconfig.MqCoreAutoConfiguration; +import org.junit.jupiter.api.Test; +import org.springframework.boot.autoconfigure.AutoConfigureBefore; + +import static org.assertj.core.api.Assertions.assertThat; + +/** + * 装配顺序回归护栏(mq-starter 自身)。 + * + *

{@link RedisStreamMqDriverAutoConfiguration} 必须声明 + * {@code @AutoConfigureBefore(MqCoreAutoConfiguration.class)}:否则真实 Spring Boot 按类名字母序 + * 处理 autoconfig,{@code com.njcn.mq.autoconfig.*}(core) 先于 {@code com.njcn.mq.driver.*}(driver), + * core 的 {@code @ConditionalOnBean(MqDriver)} 在 driver bean 注册前求值失败, + * {@code MqTemplate} / {@code MqListenerRegistry} 不装配。 + * + *

以注解契约守护,真实装配结果由 cn-data-platform 的 {@code MqSliceWiringTest} + * (真实 autoconfig 顺序)覆盖。删掉 @AutoConfigureBefore 本测试即 RED。 + */ +class RedisStreamMqDriverWiringTest { + + @Test + void declaresAutoConfigureBeforeCore() { + AutoConfigureBefore ann = RedisStreamMqDriverAutoConfiguration.class.getAnnotation(AutoConfigureBefore.class); + assertThat(ann) + .as("RedisStreamMqDriverAutoConfiguration 必须声明 @AutoConfigureBefore,使 driver 先于 core 装配") + .isNotNull(); + assertThat(ann.value()) + .as("@AutoConfigureBefore 必须指向 MqCoreAutoConfiguration") + .contains(MqCoreAutoConfiguration.class); + } +} diff --git a/mq-starter-rocketmq/src/test/java/com/njcn/mq/driver/rocketmq/RocketMqDriverWiringTest.java b/mq-starter-rocketmq/src/test/java/com/njcn/mq/driver/rocketmq/RocketMqDriverWiringTest.java new file mode 100644 index 0000000..93547b4 --- /dev/null +++ b/mq-starter-rocketmq/src/test/java/com/njcn/mq/driver/rocketmq/RocketMqDriverWiringTest.java @@ -0,0 +1,37 @@ +package com.njcn.mq.driver.rocketmq; + +import com.njcn.mq.autoconfig.MqCoreAutoConfiguration; +import org.junit.jupiter.api.Test; +import org.springframework.boot.autoconfigure.AutoConfigureBefore; + +import static org.assertj.core.api.Assertions.assertThat; + +/** + * 装配顺序回归护栏(mq-starter 自身)。 + * + *

{@link RocketMqDriverAutoConfiguration} 必须声明 + * {@code @AutoConfigureBefore(MqCoreAutoConfiguration.class)}:否则真实 Spring Boot 按类名字母序 + * 处理 autoconfig,{@code com.njcn.mq.autoconfig.*}(core) 先于 {@code com.njcn.mq.driver.*}(driver), + * core 的 {@code @ConditionalOnBean(MqDriver)} 在 driver bean 注册前求值失败, + * {@code MqTemplate} / {@code MqListenerRegistry} 不装配,整个 mq-starter 在真实应用中失效。 + * + *

这里以注解契约守护(不 refresh context):本模块单测 classpath 因 + * {@code rocketmq-spring-boot-starter:2.2.3} 与父 pom spring-boot 2.3.12 的 spring 版本不一致 + * (缺 {@code spring-core} 5.3 的 ApplicationStartup),无法可靠 refresh context。 + * 真实装配结果(真实 autoconfig 顺序下 MqTemplate/MqListenerRegistry 确实装配)由 + * cn-data-platform 的 {@code MqSliceWiringTest} 在正确 spring 版本下覆盖。删掉 @AutoConfigureBefore + * 本测试即 RED。 + */ +class RocketMqDriverWiringTest { + + @Test + void declaresAutoConfigureBeforeCore() { + AutoConfigureBefore ann = RocketMqDriverAutoConfiguration.class.getAnnotation(AutoConfigureBefore.class); + assertThat(ann) + .as("RocketMqDriverAutoConfiguration 必须声明 @AutoConfigureBefore,使 driver 先于 core 装配") + .isNotNull(); + assertThat(ann.value()) + .as("@AutoConfigureBefore 必须指向 MqCoreAutoConfiguration") + .contains(MqCoreAutoConfiguration.class); + } +}