В моем приложении у меня есть @kafkalistener и @jmslistener в классе diff, когда я запускаю программу прослушивания jms, которая сначала использует данные, я хочу работать параллельно.
@KafkaListener(topics = "topicName", groupId = "foo")
public void listen(String message) {
System.out.println("Received Messasge in group foo: " + message);
}
jms code
@JmsListener(destination = AppConfig.QUEUE_NAME)
public void handleMessage(String message) {//implicit message type conversion
System.out.println("received: "+message);