4 Replies Latest reply on Apr 14, 2009 10:59 AM by Torsten Mielke

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

    cnhome cnhome Newbie

      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.