У меня есть компонент с несколькими слушателями в одном компоненте:
@JmsListener(destination = "${jsa.activemq.topic.stomp}")
public void receiveMessage(final TextMessage msg) throws Exception {
printMessage(msg);
}
@JmsListener(destination = "${jsa.activemq.topic.mqtt}")
public void receiveMessage(final BytesMessage msg) throws Exception {
printMessage(msg);
}
@JmsListener(destination = "${jsa.activemq.topic.mqtt.alert}")
public void receiveAlertMessage(final BytesMessage msg) throws Exception {
printMessage(msg);
}
Первый слушатель (topic.stomp) отлично читает все сообщения.Другие два не получают сообщения, даже если я оставлю только одно.