测试类中定义的Spring ServiceActivator未执行，如何排查？

测试类中的@ServiceActivator注解方法未被Spring处理，因为测试类默认不会被Spring识别为组件类，Spring无法扫描到该注解并创建对应的消息处理器。此外，若未启用Spring Integration，@ServiceActivator注解也不会生效。

方法一：将测试类标记为Spring组件并启用Integration #

在测试类上添加@Component和@EnableIntegration注解，确保Spring能扫描到并处理@ServiceActivator：

@RunWith(SpringRunner.class)
@SpringBootTest
@Component
@EnableIntegration
public class PublisherTest {

    private final List<Event> events = new ArrayList<>();

    @Autowired
    private Publisher publisher;

    @Test
    public void testPublish() {
        Event testEvent = new Event("some_id_number");
        publisher.publish(testEvent);

        Awaitility.await()
             .atMost(2, TimeUnit.SECONDS)
             .until(() -> !this.events.isEmpty());
    }

    @ServiceActivator(inputChannel = "publishingChannel")
    public void publishEventListener(Event event) {
        this.events.add(event);
    }
}

注意：如果测试类所在包不在主应用的组件扫描范围内，需要通过@SpringBootTest(scanBasePackages = "你的测试类包路径")指定扫描范围。

方法二：将消息处理器抽离到单独的组件类 #

创建一个独立的Spring组件类存放@ServiceActivator方法，测试类中注入该组件：

// 新建消息处理器组件
@Component
public class TestEventReceiver {
    private final List<Event> events = new ArrayList<>();

    @ServiceActivator(inputChannel = "publishingChannel")
    public void publishEventListener(Event event) {
        this.events.add(event);
    }

    public List<Event> getEvents() {
        return events;
    }
}

// 修改测试类
@RunWith(SpringRunner.class)
@SpringBootTest
public class PublisherTest {

    @Autowired
    private Publisher publisher;

    @Autowired
    private TestEventReceiver eventReceiver;

    @Test
    public void testPublish() {
        Event testEvent = new Event("some_id_number");
        publisher.publish(testEvent);

        Awaitility.await()
             .atMost(2, TimeUnit.SECONDS)
             .until(() -> !eventReceiver.getEvents().isEmpty());
    }
}

这种方式更符合Spring组件设计规范，避免测试类承担额外职责。

方法三：在测试类中用配置类注册处理器 #

通过内部配置类注册ServiceActivator，无需将测试类标记为组件：

@RunWith(SpringRunner.class)
@SpringBootTest
@EnableIntegration
@Import(PublisherTest.TestConfig.class)
public class PublisherTest {

    private final List<Event> events = new ArrayList<>();

    @Autowired
    private Publisher publisher;

    @Test
    public void testPublish() {
        Event testEvent = new Event("some_id_number");
        publisher.publish(testEvent);

        Awaitility.await()
             .atMost(2, TimeUnit.SECONDS)
             .until(() -> !this.events.isEmpty());
    }

    @Configuration
    public static class TestConfig {
        @Autowired
        private PublisherTest publisherTest;

        @ServiceActivator(inputChannel = "publishingChannel")
        public void publishEventListener(Event event) {
            publisherTest.events.add(event);
        }
    }
}

• 必须确保项目中引入了Spring Integration依赖，否则@ServiceActivator注解不会被识别。
• 若publishingChannel是DirectChannel（默认类型），消息发送是同步的，无需用Awaitility等待；如果是异步通道（如ExecutorChannel），则需要等待机制。

内容的提问来源于stack exchange，提问作者reka18