Could not refresh JMS Connection for destination 'myTopic' - retrying in 5000 ms. Cause: Broker: localhost - Client: ID already connected from tcp:// 0.0.0.1:54267
配置如下：
<bean id="amqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="failover:(tcp://0.0.0.1:61616?wireFormat.maxInactivityDuration=0)?timeout=10000" />
<property name="userName" value="admin"></property>
<property name="password" value="admin"></property>
<property name="useAsyncSend" value="true"/>
</bean>
<bean id="cachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
<property name="cachingConnectionFactory" ref="amqConnectionFactory"></property>
<property name="clientId" value="clientid" />
<property name="sessionCacheSize" value="1"></property>
</bean>
<bean id="topicConsumer" class="com.util.jms.TopicSubscriber"></bean>
<jms:listener-container
container-type="default"
connection-factory="cachingConnectionFactory"
client-id="clientid_001"
destination-type="durableTopic">
<jms:listener subscription="client_007" destination="myTopic" ref="topicConsumer" method="onMessage" />
</jms:listener-container>
添加评论
关注(1)
相关推荐
SpringJMS和ActiveMQ结合，可以实现消息的持久化，即使消息服务器重启，也不会丢失未被消费的消息。 8. **事务管理** SpringJMS提供了事务支持，可以在发送或接收消息时启用JMS事务，确保消息传递的可靠性。 9. ...
在本文中，我们将深入探讨如何使用SpringBoot框架与Apache ActiveMQ结合实现JMS（Java消息服务）...同时，ActiveMQ还提供了许多高级特性，如消息持久化、事务支持和多种协议支持，可以进一步增强系统的稳定性和灵活性。
在XML配置中，可以定义消息代理（broker）的属性，如是否持久化消息以及是否启用JMX监控，并可以配置传输连接器，包括使用特定的传输协议和URI等。 在Spring框架中，使用Spring JMS可以很方便地将ActiveMQ集成到...
Oracle AQ 实现了 JMS 规范，使得开发者能够利用其强大的特性，如事务性队列、优先级和持久化等。 在不使用 Spring JMS 的情况下，我们需要直接使用 Oracle JDBC 驱动和 Oracle AQ 的 API 来创建和管理消息。以下是...
同时，还可以通过配置消息监听器的并发数来调整消费消息的速度，以及利用ActiveMQ的持久化机制来保证消息的可靠性。 总之，Spring与ActiveMQ的整合为分布式系统提供了可靠的消息传递机制，通过解耦组件之间的依赖，...
4. **配置JMS资源**：设置消息存储（例如，持久化存储）、连接工厂和目的地（队列或主题）等。 5. **配置应用程序**：在应用中引入JMS相关的依赖库，如JMS API、Spring框架的JMS支持和其他必要的库（如WebLogic...
ActiveMQ具备高可用性、高性能和可伸缩性，支持发布/订阅和点对点两种消息模型，以及事务处理和持久化机制，确保消息的可靠传输。 二、Spring模板模式 Spring框架提供了模板类，如JdbcTemplate、HibernateTemplate...
5. **对JMS的增强**：支持JMS 2.0规范，提供更多的JMS特性，如共享订阅、事务消息和持久化订阅。 6. **更好的移动设备支持**：Spring Mobile项目被整合到Spring Web MVC中，提供了更好的移动设备检测和适配能力。 ...
- **ConnectionFactory**：用于创建连接的工厂类，是JMS客户端与消息代理之间的桥梁。 - **Connection**：实际的网络连接，可以创建会话（Session）。 - **Session**：线程安全的单线程或多线程工作单元，用于...
在IT行业中，Spring框架是Java应用开发中的一个关键...在实际项目中，可能还需要考虑更多因素，比如错误处理、负载均衡、消息持久化等，但这些基础知识已经为你开启了一扇门，让你能够深入探索更复杂的消息系统架构。
Spring与JPA结合，提供了统一的数据访问接口，支持多种持久化供应商，如Hibernate、EclipseLink等。 10. Spring与Jedis整合：Jedis是Redis的Java客户端，Redis是一种高性能的键值对数据存储系统。Spring Data Redis...
- **高级主题：** 探索了使用 JMS 进行事务管理和消息持久化的高级技术。 **10: 发送和接收邮件** - **邮件发送：** 解释了如何使用 Spring Integration 发送电子邮件。 - **邮件接收：** 讨论了如何接收电子邮件...
- 在客户端，Spring应用需要配置JMS连接工厂。这可以通过XML配置文件或者使用Java配置来完成，定义`ActiveMQConnectionFactory`并设置服务器地址、端口等参数。 2. **消息生产者** - 使用Spring的`JmsTemplate`类...
8. **消息持久化**：ActiveMQ支持消息的持久化，即使在服务器重启后，未被消费的消息也能恢复，保证了消息的可靠性。 9. **监控和管理**：ActiveMQ提供了一个Web控制台，可以用来监控消息队列的状态，管理消息和...
7. **持久化与消息确认**：ActiveMQ支持消息持久化，即使服务器重启，未消费的消息也不会丢失。同时，你可以配置消息确认模式，例如自动确认、客户端确认或DUPS_OK确认，以平衡消息处理速度和可靠性。 8. **监控与...
9. **消息持久化**：配置ActiveMQ实现消息的持久化存储，即使服务器重启也不会丢失未处理的消息。 10. **监控和调试**：学习如何使用ActiveMQ的Web Console监控消息队列状态，以及使用日志和调试工具排查问题。 11...
Spring提供了`spring-jms`模块，它包含了一组丰富的API和配置选项，使得在Spring应用中集成ActiveMQ变得简单。通过使用`JmsTemplate`类，我们可以方便地发送和接收消息。 1. **配置ActiveMQ**：在开始之前，我们...
- **持久化**：确保即使在消息中间件或客户端崩溃后，消息也不会丢失。生产者可以选择发送持久化消息，确保在系统恢复后仍能传递。 - **事务**：在Session上开启事务，可以保证一组消息要么全部成功发送或接收，要么...
这通常通过修改 `activemq.xml` 文件完成，设置 broker 地址、持久化策略等。 2. 配置 Spring：在 Spring 的配置文件中（例如 `applicationContext.xml`），定义 `ConnectionFactory` 和 `Destination`。可以使用 `...