Question about the apache-activemq-perftest in the src path

[cnhome]

MessageBroker 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:

activemq-perf:producer

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.

[mielket]

What version do you use? I just tried FUSE Message Broker 5.3.0.0-fuse and was able to connect two producers to the same broker without any errors being raised.

[gseben]

Based on the error message you have conflicting client IDs:

javax.jms.InvalidClientIDException: Broker: localhost - Client: JmsProducer0 already connected from /172.17.40.216:35240

I think that the client ID here is determine by combining the 'sysTest.clientPrefix' and 'sysTest.numClients' properties. They default to 'JmsProducer' and 1 (0 on the count) respectively. Try setting the sysTest.clientPrefix for the producers to something like 'JmsProducerHostY' and 'JmsProducerHostX'. Ex:

activemq-perf:producer -Dfactory.brokerURL=tcp://localhost:12345 -DsysTest.clientPrefix=JmsProducerX

For a complete list of properties available check out: http://activemq.apache.org/activemq-performance-module-users-manual.html

[cnhome]

gseben, thanks a lot! Have passed.

[mielket]

Strange that I did not run into this problem although I started two producers on different machines too.

Anyway thanks for the answer gseben.