SpringBoot中@SendTo注解操作ActiveMQ无报错但消息未入队

首先，你遇到的核心问题是对@SendTo注解的使用场景理解有误——这个注解并不是用来直接触发主动JMS消息发送的，它的设计初衷是配合Spring Messaging的消息处理流程（比如JMS消息监听后的结果转发，或者通过消息网关发送），而不是直接在普通业务方法上标记就自动发送消息。

当你直接调用enqueueExchangeNotification方法时，这只是一个普通的Java方法调用，Spring并不会识别这个@SendTo注解并自动将返回值发送到JMS队列，这就是为什么你看不到错误但消息没入队的原因。而JmsTemplate是Spring提供的专门用于主动发送JMS消息的工具类，所以它可以正常工作。

正确使用@SendTo的方式 #

要让@SendTo生效发送JMS消息，你需要配合@MessagingGateway来实现，这是Spring Messaging提供的声明式消息发送方式。具体步骤如下：

1. 定义消息网关接口 #

创建一个带有@MessagingGateway注解的接口，在方法上标记@SendTo指定目标队列：

import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.messaging.gateway.MessagingGateway;
import java.util.Map;

@MessagingGateway
public interface NotificationGateway {
    // 指定要发送到的JMS队列
    @SendTo("inboundSyncQueue")
    void sendNotification(Map<String, Object> message);
}

2. 修改Service类，注入并调用网关 #

在你的NotificationServiceImpl中注入这个网关，然后在业务方法中调用网关的发送方法：

@Service
public class NotificationServiceImpl implements NotificationService {

    @Autowired
    private NotificationGateway notificationGateway;

    @Override
    public Map<String, Object> enqueueExchangeNotification(ExchangeNotification notification, String tenantId) throws RuntimeException {
        Map<String, Object> jmsMessage = new HashMap<>();
        jmsMessage.put("tenantId", tenantId);
        jmsMessage.put("source", ExternalNotificationSource.EXCHANGE);
        jmsMessage.put("payload", notification);
        
        // 通过网关发送消息到指定队列
        notificationGateway.sendNotification(jmsMessage);
        
        return jmsMessage;
    }
}

3. 确保网关被Spring扫描到 #

确保NotificationGateway所在的包在Spring Boot的自动扫描范围内（比如和MyCustomRouterApplication同包或子包），如果不在，需要在启动类上添加@ComponentScan指定扫描路径。

额外说明 #

• 你的ActiveMQ配置是完全正常的，因为JmsTemplate可以正常工作，所以不需要额外的配置变更。
• @SendTo另一个常见的使用场景是在@JmsListener标注的方法上：当你监听一个队列的消息并处理完成后，返回的结果会通过@SendTo自动发送到指定的队列，用于消息的转发处理。

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