Я создал простого автономного потребителя, пытающегося потреблять 4 сообщения, сидя на ActiveMQ.Но когда я запустил приложение, оно создало другую очередь с тем же именем, как показано на рисунке ниже:
Моя структура проекта выглядит следующим образом:
И код внутри классов выглядит следующим образом:
класс FebMessageConsumer
package com.consumer.messages.febMessageConsumer;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;
@Component
public class FebMessageConsumer {
@JmsListener(destination = "CDD Feb 21 Queue")
///@JmsListener
public void processFebMessage(String message) {
System.out.println("Message Retrieved is:" +message);
}
}
класс FebMessageConsumerApplication
package com.consumer.messages.febMessageConsumer;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.jms.annotation.EnableJms;
@SpringBootApplication
@EnableJms
public class FebMessageConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(FebMessageConsumerApplication.class, args);
}
}
1) Что не так в приведенном выше коде?
2) После того, как все вышеперечисленное работает, я планирую развернуть его какВОЙНА Apache Tomcat 8.5.Это похоже на то, когда я развертываю приложение или запускаю приложение как Java-приложение, оно будет поглощать все сообщения одно за другим?ИЛИ когда я запускаю приложение, за раз будет потребляться только одно сообщение, а затем мне придется остановить приложение, а затем снова начать использовать следующее сообщение?
Вот Google Drive Ссылка на заархивированный проект в случае необходимости для справки.