只需
BrokerService在您的应用程序中添加一个bean:
@SpringBootApplicationpublic class So48504265Application { public static void main(String[] args) { SpringApplication.run(So48504265Application.class, args); } @Bean public BrokerService broker() throws Exception { BrokerService broker = new BrokerService(); broker.addConnector("tcp://localhost:61616"); return broker; } @Bean public ApplicationRunner runner(JmsTemplate template) { return args -> template.convertAndSend("foo", "AMessage"); } @JmsListener(destination = "foo") public void listen(String in) { System.out.println(in); }}和
spring.activemq.broker-url=tcp://localhost:61616
并将其添加到您的pom
<dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-kahadb-store</artifactId></dependency>



