Pure master/slave is departed in later releases and wont get supported any more. You should consider other cluster topology.
2013/12/3 赵振华 ZhenhuaZhao <zhenhuaz...@pptv.com> > hi,all > I’m a newbie in activemq. > I use active-5.5.5 on rhel5.4 X86_64 in pure master/slave mode. > I leave master’s config file activemq.xml the default,and only add > the following after “<broker” on the slave server: > brokerName="slave" masterConnectorURI="tcp://masterip:61616" > shutdownOnMasterFailure="false" persistent="false". > > The topology can switch when I shut down the master. > When I running both the master and the slave,I get the following > error message on the master: > 2013-12-03 19:47:24,190 | ERROR | Slave Failed | > org.apache.activemq.broker.ft.MasterBroker | ActiveMQ Transport: > tcp:///clientip:6812 > java.lang.IllegalStateException: Cannot lookup a consumer from a > connection that had not been registered: > ID:tjccb-vod-DC-193-45-53444-1385544308281-0:2 > at > org.apache.activemq.broker.MapTransportConnectionStateRegister.lookupConnectionState(MapTransportConnectionStateRegister.java:67) > at > org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1423) > at > org.apache.activemq.broker.TransportConnection.getConsumerBrokerExchange(TransportConnection.java:1337) > at > org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:464) > at > org.apache.activemq.command.MessageAck.visit(MessageAck.java:229) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69) > at > org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:218) > at > org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) > > and the error message on the slave: > 2013-12-03 19:47:26,013 | WARN | Async error occurred: > java.lang.IllegalStateException: Cannot lookup a connection that had not > been registered: ID:tjccb-vod-activeMQ-193-42 -52963-1385544249228-0:8 | > org.apache.activemq.broker.TransportConnection.Service | VMTransport: > vm://slave#1 > java.lang.IllegalStateException: Cannot lookup a connection that had not > been registered: > ID:tjccb-vod-activeMQ-193-42.idc.pplive.cn-52963-1385544249228-0:8 > at > org.apache.activemq.broker.MapTransportConnectionStateRegister.lookupConnectionState(MapTransportConnectionStateRegister.java:97) > at > org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1435) > at > org.apache.activemq.broker.TransportConnection.processBeginTransaction(TransportConnection.java:362) > at > org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:94) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69) > at > org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:218) > at > org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) > > who can help me out? > > >
