Re: Consumer Sampler: How to configure No. of Consumers

[James Strachan <ja...@gmail.com>]

Are you providing a unique clientID and subscriberName for each topic
subscription?

On 12/12/06, Hemant Gaur <hg...@interwoven.com> 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:hgaur@interwoven.com]
> 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/