springboot依赖配置
<dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-spring</artifactId> <version>5.15.8</version> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-pool</artifactId> <version>5.15.8</version> </dependency>
配置文件
activemq.broker.url=failover:(tcp://内网ip1:61616,tcp://内网ip2:61616)
activemq 配置(activemq.xml)
1.回流功能
<policyEntry queue=">" enableAudit="false">
<networkBridgeFilterFactory>
<conditionalNetworkBridgeFilterFactory replayWhenNoConsumers="true"/>
</networkBridgeFilterFactory>
</policyEntry>
2.负载配置 <networkConnectors> <networkConnector duplex="true" uri="static://(tcp://ip:prot,tcp://ip:port)"/> </networkConnectors>