activemq 5.12
经纪人configurationnetworking：hub，spoke1，spoke2
spoke1具有双工n / w连接到集线器spoke2具有双工networking连接到集线器
我使用以下来在spoke1上产生
bin / activemq生产者–brokerurl tcp：//0.0.0.0：61616 – 目的地队列：/ /生产者 – 214 – 消息计数100 – 消息“你好”然后在spoke2，我尝试消费消息
bin / activemq消费者–brokerUrl tcp：//0.0.0.0：61616 – 目标队列：//生产者 – 214我可以看到100消息排队在spoke1，但我的消费者没有看到任何消息，只是等待所以
INFO | 连接到URL：tcp：//0.0.0.0：61616（null：null）INFO | 消费队列：// producer-214 INFO | 睡觉之间接收0毫秒INFO | 运行1个并行线程INFO | 消费者-1等到1000消息被消费我的spoke1 / 2configuration是相同的除了brokername。 以下是对spoke2的configuration：
http://www.springframework.org/schema/beans/spring-beans.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core。 xsd “>
file：$ {activemq.conf} /credentials.properties元素用于configurationActiveMQ代理。 – >
<destinationPolicy> <policyMap> <policyEntries> <policyEntry topic=">" > <!-- The constantPendingMessageLimitStrategy is used to prevent slow topic consumers to block producers and affect other consumers by limiting the number of messages that are retained For more information, see: http://activemq.apache.org/slow-consumer-handling.html --> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy> <networkConnectors> <networkConnector uri="static:(tcp://172.31.10.24:61616)?transport.useInactivityMonitor=false" duplex="true"/> </networkConnectors> <!-- Configure message persistence for the broker. The default persistence mechanism is the KahaDB store (identified by the kahaDB tag). For more information, see: http://activemq.apache.org/persistence.html --> <persistenceAdapter> <kahaDB directory="${activemq.data}/kahadb"/> </persistenceAdapter> <!-- The systemUsage controls the maximum amount of space the broker will use before disabling caching and/or slowing down producers. For more information, see: http://activemq.apache.org/producer-flow-control.html --> <systemUsage> <systemUsage> <memoryUsage> <memoryUsage percentOfJvmHeap="70" /> </memoryUsage> <storeUsage> <storeUsage limit="100 gb"/> </storeUsage> <tempUsage> <tempUsage limit="50 gb"/> </tempUsage> </systemUsage> </systemUsage> <transportConnectors> <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB --> <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> </transportConnectors> <!-- destroy the spring context on shutdown to stop jetty --> <shutdownHooks> <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /> </shutdownHooks>
Take a look at ${ACTIVEMQ_HOME}/conf/jetty.xml for more details --> <import resource="jetty.xml"/> </beans>
任何帮助将不胜感激
问候
问题是我一旦networkTTL = 2在networking连接器中，networkTTL = 1，消息可以从spoke2读取
谢谢