Как запустить слушатель кафки и слушателя jms параллельно при весенней загрузке - PullRequest
0 голосов
/ 24 марта 2019

В моем приложении у меня есть @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);
...