在配置文件中增加以下参数
其中,transport.maxInactivityDuration
参数定义了连接允许的最长不活动时间,单位为毫秒。如果连接在此时间内没有收到任何消息,则会被断开。请根据实际情况调整此参数值。
另外,policyEntry
中的memoryLimit
参数也可以根据实际情况调整,它定义了允许队列占用的最大内存大小。
除了在配置文件中进行设置之外,还可以通过在代码中设置ActiveMQConnectionFactory
的maxInactivityDuration
属性来实现同样的效果:
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
((ActiveMQConnectionFactory) connectionFactory).setMaxInactivityDuration(5000);
Connection connection = connectionFactory.createConnection();