Tag: messagebroker

ActiveMQ没有持久性

我想在生成消息的服务器和接收消息的许多客户端之间建立基于发布者 – 订户的通信协议。 经过一番研究，我决定选择ActiveMQ。 我查看了一些教程和ActiveMQ站点，并按如下方式设置了代理： BrokerService broker = new BrokerService(); broker.setPersistent(false); broker.addConnector(“tcp://localhost:61616”); broker.start(); 我只需要消息传递function，没有数据库持久性或类似的东西。 但是，当我启动应用程序时，无论配置如何，都会创建activemq-data文件夹。 这反过来会在下次启动代理时导致exception。 SEVERE: Failed to start ActiveMQ JMS Message Broker. Reason: java.io.EOFException: Chunk stream does not exist at page: 0 这是一个错误还是我没有正确设置代理（使用ActiveMQ 5.4.1）？ 如何禁用持久性，因此不会创建额外的数据存储？ 此外，我更喜欢从Java应用程序中配置代理，而不是通过xml文件。 干杯，马克斯

如何使用Spring Boot配置嵌入式ActiveMQ Broker URL

我按照一个简单的例子来设置和运行带有Spring Boot的嵌入式ActiveMQ（版本1.4.X）。 这是示例https://spring.io/guides/gs/messaging-jms/的链接 我的课程结构如下： @SpringBootApplication @EnableJms public class Application { @Autowired ConfigurableApplicationContext context; @Bean JmsListenerContainerFactory myJmsContainerFactory(ConnectionFactory connectionFactory) { SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory(); factory.setConnectionFactory(connectionFactory); return factory; } @JmsListener(destination = “mailbox-destination”, containerFactory = “myJmsContainerFactory”) public void receiveMessage(String message) { System.out.println(“Message received: ” + message); context.close(); } public static void main(String[] args) throws Exception { FileSystemUtils.deleteRecursively(new File(“active-data”)); […]