0
@Component
public class OrderItemListener{

    @Autowired
    private final StoreService storeService;

    @JmsListener(destination = "order.item.queue")
    public void receiveOrder(String message) {
        //processing
    }
}

这是我用于接收消息的 POJO 类。我可以通过 JCONSOLE 在此处发送消息,但是,如果我有另一个应用程序需要向此侦听器/队列发送消息怎么办?我将如何识别地址?这是通过 spring-boot 自动配置的。我只指定了activemq jar。

4

1 回答 1

0
@Autowired
private JmsTemplate template;

...


    this.template.convertAndSend("order.item.queue", "foo");

如果这是在不同的 JVM 中运行,您将需要一个独立的代理并设置spring.activemq.broker-url=tcp://somehost:61616.

于 2016-02-05T15:07:03.997 回答