Question about the apache-activemq-perftest in the src path
cnhome Apr 14, 2009 7:40 AMMessageBroker provide the source code about ActiveMQ.
I run the command:mvn activemq-perf:broker -Durl=broker:tcp://localhost:61616 on the HostA, and run the command:mvn activemq-perf:producer -Dfactory.brokerURL=tcp://HostA's IP:61616 on other two hosts.
I get the wrong message as follewing:
Apr 15, 2009 3:24:50 AM org.apache.activemq.tool.AbstractJmsClientSystem loadJmsFactory
INFO: Created: org.apache.activemq.ActiveMQConnectionFactory using SPIConnectionFactory: org.apache.activemq.tool.spi.ActiveMQReflectionSPI
javax.jms.InvalidClientIDException: Broker: localhost - Client: JmsProducer0 already connected from /172.17.40.216:35240
+ at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:209)+
+ at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)+
+ at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)+
+ at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:75)+
+ at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)+
+ at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:89)+
+ at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:679)+
+ at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:86)+
+ at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:125)+
+ at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)+
+ at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)+
+ at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)+
+ at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)+
+ at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)+
+ at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)+
+ at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)+
+ at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)+
+ at java.lang.Thread.run(Thread.java:619)+
How to deal with it? Anybody help me.