The setClinetID call I can see in the ConsumerSampler but I am sure that this is not supported in OpenJMS. So the consumer name is taken which conflicts. 1.) connection.setClientID(idGenerator.generateId()); The set ClientID is not supported in the openJMS.
2.) consumer = ((TopicSession)session).createDurableSubscriber(topic, getClass().getName()); Where can I put the client Names if they are configurable ? Thanks for the help. --hemant -----Original Message----- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Tuesday, December 12, 2006 6:51 PM To: activemq-users@geronimo.apache.org Subject: Re: Consumer Sampler: How to configure No. of Consumers Are you providing a unique clientID and subscriberName for each topic subscription? On 12/12/06, Hemant Gaur <[EMAIL PROTECTED]> wrote: > > I see from connecting to the ActiveMQ that the consumers have the same > names for all the instances but with the different topic subscription. > When these are added to the OpenJMS DB they are cleaned up and only one > consumer is left. > > Any thoughts will be appriacted. > > --hemant > -----Original Message----- > From: Hemant Gaur [mailto:[EMAIL PROTECTED] > Sent: Tuesday, December 12, 2006 2:37 PM > To: activemq-users@geronimo.apache.org > Subject: Consumer Sampler: How to configure No. of Consumers > > Hi, > I am trying to run the jmeter test provided by ActiveMQ on the OpenJMS > release version. > > The desired configuration is > 5 topics, 5 publishers, 5 consumers, persistent, non- synchronous. > > Though I have added 5 Consumers in the consumer sampler, the DataBase > still shows only one after running the tests in the consumer table. > > org.activemq.sampler.Consumer > > Also I had to add all the topics manually into the openJMS config to get > things running. > <AdministeredDestinations> > <AdministeredTopic name="TOOL.DEFAULT.TOPIC0"/> > <AdministeredTopic name="TOOL.DEFAULT.TOPIC1"/> > <AdministeredTopic name="TOOL.DEFAULT.TOPIC2"/> > <AdministeredTopic name="TOOL.DEFAULT.TOPIC3"/> > <AdministeredTopic name="TOOL.DEFAULT.TOPIC4"/> > </AdministeredDestinations> > > The messages are published to all the five topics. > > My queries are : > How do I verify that they are published from the 5 Publishers? > How to get the five consumers ? > What does this configuration mean , all the five publisher publishing to > five topics and the five consumers subscribing to all of them ? > > JMeterLogs > 2006/12/12 13:13:18 INFO - jmeter.JMeter: Version 2.1.20050419 > 2006/12/12 13:13:18 INFO - jmeter.JMeter: java.version=1.6.0-rc > 2006/12/12 13:13:18 INFO - jmeter.JMeter: Copyright (c) 1998-2005 The > Apache Software Foundation > 2006/12/12 13:13:20 ERROR - jmeter.gui.action.Help: Couldn't load help > file java.io.FileNotFoundException: > C:\ActiveMQ\activemq-jmeter-4.0-SNAPSHOT\printable_docs\usermanual\compo > nent_reference.html (The system cannot find the path specified) > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [swiftmq_server] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_msg_send_type] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_async_send] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_non_async_send] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [swiftmq_server] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_msg_send_type] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_async_send] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_non_async_send] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_msg_send_type] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_async_send] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_non_async_send] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_msg_send_type] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_async_send] > 2006/12/12 13:13:20 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_non_async_send] > 2006/12/12 13:13:21 WARN - jmeter.testbeans.gui.TestBeanGUI: testing > class: org.apache.jmeter.config.CSVDataSet > 2006/12/12 13:13:21 WARN - jmeter.testbeans.gui.TestBeanGUI: testing > class: org.apache.jmeter.protocol.http.sampler.AccessLogSampler > 2006/12/12 13:13:21 INFO - > jmeter.protocol.http.sampler.AccessLogSamplerBeanInfo: Entered access > log sampler bean info > 2006/12/12 13:13:21 INFO - > jmeter.protocol.http.sampler.AccessLogSamplerBeanInfo: found parsers: > [org.apache.jmeter.protocol.http.util.accesslog.TCLogParser] > 2006/12/12 13:13:21 INFO - > jmeter.protocol.http.sampler.AccessLogSamplerBeanInfo: Got to end of > access log samper bean info init > 2006/12/12 13:13:21 WARN - jmeter.testbeans.gui.TestBeanGUI: testing > class: org.apache.jmeter.protocol.jdbc.config.DataSourceElement > 2006/12/12 13:13:21 WARN - jmeter.testbeans.gui.TestBeanGUI: testing > class: org.apache.jmeter.protocol.jdbc.sampler.JDBCSampler > 2006/12/12 13:13:21 WARN - jmeter.testbeans.gui.TestBeanGUI: testing > class: org.apache.jmeter.timers.ConstantThroughputTimer > 2006/12/12 13:13:21 WARN - jmeter.testbeans.gui.TestBeanGUI: testing > class: org.apache.jmeter.timers.SyncTimer > 2006/12/12 13:13:21 INFO - jmeter.samplers.SampleResult: Note: Sample > TimeStamps are END times > 2006/12/12 13:13:21 INFO - jmeter.samplers.SampleResult: > sampleresult.default.encoding is set to ISO-8859-1 > 2006/12/12 13:13:28 INFO - jmeter.services.FileServer: Setting basedir > to: null > 2006/12/12 13:13:32 INFO - jmeter.gui.action.Load: Loading file: > C:\ActiveMQ\activemq-jmeter-4.0-SNAPSHOT\bin\Hemant\ALL555.jmx > 2006/12/12 13:13:32 INFO - jmeter.services.FileServer: Setting basedir > to: C:\ActiveMQ\activemq-jmeter-4.0-SNAPSHOT\bin\Hemant\ALL555.jmx > 2006/12/12 13:13:32 INFO - jmeter.save.SaveService: Using SaveService > properties file 1.5 > 2006/12/12 13:13:32 WARN - jmeter.save.SaveService: Could not set up > alias BeanShellSampler java.lang.ClassNotFoundException: > org.apache.jmeter.protocol.java.sampler.BeanShellSampler > 2006/12/12 13:13:32 WARN - jmeter.save.SaveService: Could not set up > alias WebServiceSampler java.lang.ClassNotFoundException: > org.apache.jmeter.protocol.http.sampler.WebServiceSampler > 2006/12/12 13:13:32 INFO - jmeter.save.SaveService: All converter > versions present and correct > 2006/12/12 13:13:32 INFO - org.activemq.sampler.Producer: Protocol > Handler name=SamplerClientImpl > 2006/12/12 13:13:32 INFO - org.activemq.sampler.Producer: Status > prefix= > 2006/12/12 13:13:32 INFO - org.activemq.sampler.Producer: Status > suffix= > 2006/12/12 13:13:32 INFO - org.activemq.sampler.Producer: Status > properties= > 2006/12/12 13:13:32 INFO - org.activemq.sampler.SamplerClientImpl: > Using eolByte=0 > 2006/12/12 13:13:32 INFO - org.activemq.sampler.Consumer: Protocol > Handler name=SamplerClientImpl > 2006/12/12 13:13:32 INFO - org.activemq.sampler.Consumer: Status > prefix= > 2006/12/12 13:13:32 INFO - org.activemq.sampler.Consumer: Status > suffix= > 2006/12/12 13:13:32 INFO - org.activemq.sampler.Consumer: Status > properties= > 2006/12/12 13:13:32 INFO - org.activemq.sampler.SamplerClientImpl: > Using eolByte=0 > 2006/12/12 13:13:32 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_msg_send_type] > 2006/12/12 13:13:32 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_async_send] > 2006/12/12 13:13:32 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_non_async_send] > 2006/12/12 13:13:32 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_msg_send_type] > 2006/12/12 13:13:32 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_async_send] > 2006/12/12 13:13:32 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [form_non_async_send] > 2006/12/12 13:13:32 INFO - jmeter.services.FileServer: Setting basedir > to: C:\ActiveMQ\activemq-jmeter-4.0-SNAPSHOT\bin\Hemant\ALL555.jmx > 2006/12/12 13:13:32 INFO - org.activemq.sampler.SamplerClientImpl: > Using eolByte=0 > 2006/12/12 13:13:32 INFO - org.activemq.sampler.SamplerClientImpl: > Using eolByte=0 > 2006/12/12 13:13:57 INFO - org.activemq.sampler.SamplerClientImpl: > Using eolByte=0 > 2006/12/12 13:13:57 INFO - org.activemq.sampler.SamplerClientImpl: > Using eolByte=0 > 2006/12/12 13:13:57 INFO - jmeter.engine.StandardJMeterEngine: Running > the test! > 2006/12/12 13:13:57 INFO - jmeter.gui.util.JMeterMenuBar: > setRunning(true,local) > 2006/12/12 13:13:57 INFO - jmeter.engine.StandardJMeterEngine: Starting > 1 threads for group Thread Group. Ramp up = 1. > 2006/12/12 13:13:57 INFO - jmeter.engine.StandardJMeterEngine: Test > will stop on error > 2006/12/12 13:13:57 WARN - jmeter.threads.JMeterThread: > jmeterthread.startearlier=true (see jmeter.properties) > 2006/12/12 13:13:57 INFO - org.activemq.sampler.SamplerClientImpl: > Using eolByte=0 > 2006/12/12 13:13:57 INFO - org.activemq.sampler.SamplerClientImpl: > Using eolByte=0 > 2006/12/12 13:13:57 INFO - jmeter.threads.JMeterThread: Thread Thread > Group 1-1 started > 2006/12/12 13:13:57 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [swiftmq_server] > 2006/12/12 13:13:57 WARN - jmeter.util.JMeterUtils: ERROR! Resource > string not found: [webspheremq_server] > 2006/12/12 13:13:58 ERROR - org.activemq.sampler.Consumer: Error running > consumer javax.jms.JMSException: Failed to unsubscribe subscriber > org.activemq.sampler.Consumer since is still active > at > org.exolab.jms.server.JmsServerSession.unsubscribe(JmsServerSession.java > :881) > at > org.exolab.jms.server.JmsServerSession.createSubscriber(JmsServerSession > .java:758) > at > org.exolab.jms.server.mipc.IpcJmsSessionConnection.createSubscriber(IpcJ > msSessionConnection.java:588) > at > org.exolab.jms.server.mipc.IpcJmsSessionConnection.notify(IpcJmsSessionC > onnection.java:165) > at > org.exolab.jms.server.mipc.IpcJmsReceiver.notify(IpcJmsReceiver.java:100 > ) > at > org.exolab.jms.server.mipc.IpcServerChannel.run(IpcServerChannel.java:16 > 1) > > 2006/12/12 13:13:58 INFO - jmeter.threads.JMeterThread: Thread Thread > Group 1-1 is done > 2006/12/12 13:13:58 INFO - jmeter.engine.StandardJMeterEngine: Ending > thread 0 > 2006/12/12 13:13:58 INFO - jmeter.engine.StandardJMeterEngine: Stopping > test > 2006/12/12 13:13:58 INFO - jmeter.gui.util.JMeterMenuBar: > setRunning(false,local) > 2006/12/12 13:13:58 INFO - jmeter.engine.StandardJMeterEngine: Test has > ended > =========================== > > > > > > -- James ------- http://radio.weblogs.com/0112098/
