fix:#103 support resolvePlaceholders for selectorExpression codestyle
and update test class with actual meaning.
diff --git a/rocketmq-spring-boot/src/test/java/org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfigurationTest.java b/rocketmq-spring-boot/src/test/java/org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfigurationTest.java
index 4457b95..a865e3d 100644
--- a/rocketmq-spring-boot/src/test/java/org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfigurationTest.java
+++ b/rocketmq-spring-boot/src/test/java/org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfigurationTest.java
@@ -130,7 +130,7 @@
@Test
public void testExtRocketMQTemplate() {
runner.withPropertyValues("rocketmq.name-server=127.0.0.1:9876").
- withUserConfiguration(ExtRocketMQTemplateConfig.class, CustomObjectMappersConfig.class).
+ withUserConfiguration(TestExtRocketMQTemplateConfig.class, CustomObjectMappersConfig.class).
run(new ContextConsumer<AssertableApplicationContext>() {
@Override
public void accept(AssertableApplicationContext context) throws Throwable {
@@ -141,7 +141,7 @@
});
runner.withPropertyValues("rocketmq.name-server=127.0.1.1:9876").
- withUserConfiguration(ExtRocketMQTemplateConfig.class, CustomObjectMappersConfig.class).
+ withUserConfiguration(TestExtRocketMQTemplateConfig.class, CustomObjectMappersConfig.class).
run((context) -> {
// No producer on consume side
assertThat(context).getBean("extRocketMQTemplate").hasFieldOrProperty("producer");
@@ -202,12 +202,12 @@
@Bean
public Object consumeListener() {
- return new MyMessageListener();
+ return new TestDefaultNameServerListener();
}
@Bean
public Object consumeListener1() {
- return new MyMessageListener1();
+ return new TestCustomNameServerListener();
}
}
@@ -238,7 +238,7 @@
}
@RocketMQMessageListener(consumerGroup = "abc", topic = "test")
- static class MyMessageListener implements RocketMQListener {
+ static class TestDefaultNameServerListener implements RocketMQListener {
@Override
public void onMessage(Object message) {
@@ -247,7 +247,7 @@
}
@RocketMQMessageListener(nameServer = "127.0.1.1:9876", consumerGroup = "abc1", topic = "test")
- static class MyMessageListener1 implements RocketMQListener {
+ static class TestCustomNameServerListener implements RocketMQListener {
@Override
public void onMessage(Object message) {
@@ -280,17 +280,17 @@
}
@Configuration
- static class ExtRocketMQTemplateConfig {
+ static class TestExtRocketMQTemplateConfig {
@Bean
public RocketMQTemplate extRocketMQTemplate() {
- return new MyExtRocketMQTemplate();
+ return new TestExtRocketMQTemplate();
}
}
@ExtRocketMQTemplateConfiguration(group = "test", nameServer = "127.0.0.1:9876")
- static class MyExtRocketMQTemplate extends RocketMQTemplate {
+ static class TestExtRocketMQTemplate extends RocketMQTemplate {
}
