ActiveMQ - JMX

Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-commits@geronimo.apache.org Received: (qmail 78342 invoked by uid 99); 2 Feb 2006 16:36:12 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 02 Feb 2006 08:36:12 -0800 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received: from [209.237.227.194] (HELO minotaur.apache.org) (209.237.227.194) by apache.org (qpsmtpd/0.29) with SMTP; Thu, 02 Feb 2006 08:35:48 -0800 Received: (qmail 44669 invoked by uid 65534); 2 Feb 2006 16:35:26 -0000 Message-ID: <20060202163526.44668.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r374430 [27/45] - /incubator/activemq/site/ Date: Thu, 02 Feb 2006 16:33:52 -0000 To: activemq-commits@geronimo.apache.org From: jstrachan@apache.org X-Mailer: svnmailer-1.0.5 X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Added: incubator/activemq/site/JMX URL: http://svn.apache.org/viewcvs/incubator/activemq/site/JMX?rev=374430&view=auto ============================================================================== --- incubator/activemq/site/JMX (added) +++ incubator/activemq/site/JMX Thu Feb 2 08:31:10 2006 @@ -0,0 +1,399 @@ + + + + + + + + ActiveMQ - JMX + + + + + + + + + + + + + + + +

+ + + + + + +

Overview

Community

Using ActiveMQ

Features

Connectivitiy

Utilities

JCA Container

External Tools

Related Projects

Support

Developers

Tools we use

+ +

Feeds

+ + + + + + + + + +

+ +	+ Site +
+ +	+ News +

+ +

+ + + + + +

+ JMX +

+ +

+ + +

ActiveMQ 4.x or later has extensive support for JMX to allow you to monitor and control the behaviour of the broker.

Currently, one way to monitor AMQ is to enable JMX and use a JMX console.

For ActiveMQ 4.x:

1. Run a broker setting the broker property useJmx to true.

i.e.

For xbean configuration

<broker useJmx="true" brokerName="BROKER_1">
+...
+</broker>

For url configuration

broker:(tcp://localhost:61616)?useJmx=true

2. Run a JMX console (e.g. jconsole - JMX console included in the JDK <JAVA_HOME>/bin/jconsole.exe)

3. Connect to the given JMX URL:

jconsole service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
+

Using the Apache ActiveMQ version on OS X it appears as follows

For additional references provided below is a brief hierarchy of the mbeans and a listing of the properties, attributes, and operations of each mbeans.

ActiveMQ MBeans Hierarchy

ActiveMQ MBeans Reference

+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
Mbean Type
+ Properties / ObjectName Attributes Operations
Broker +
+
Type=Broker
+
BrokerName=<broker identifier>
+
+ +
+
BrokerId
+
TotalEnqueueCount
+
TotalDequeueCount
+
TotalConsumerCount
+
TotalMessages
+
TotalMessagesCached
+
MemoryLimit
+
MemoryPercentageUsed
+
+ +
+
start
+
stop
+
terminateJVM
+
resetStatistics
+
gc
+
+
Destination +
+
Type=Queue|Topic
+
Destination=<destination identifier>
+
BrokerName=<name of broker>
+
+ +
+
EnqueueCount
+
DequeueCount
+
ConsumerCount
+
Messages
+
MessagesCached
+
+ +
+
resetStatistics
+
gc
+
+
NetworkConnector +
+
Type=NetworkConnector
+
BrokerName=<name of broker>
+
+ +
+ +
+
start
+
stop
+
+
Connector +
+
Type=Connector
+
ConnectorName=<connector identifier>
+
BrokerName=<name of broker>
+
+ +
+
EnqueueCount
+
DequeueCount
+
+ +
+
start
+
stop
+
resetStatistics
+
+
Connection +
+
Type=Connection
+
Connection=<connection identifier>
+
BrokerName=<name of broker>
+
+ +
+
EnqueueCount
+
DequeueCount
+
DispatchQueueSize
+
Active
+
Blocked
+
Connected
+
Slow
+
+ +
+
start
+
stop
+
resetStatistics
+
+
+

Currently, we have just provided basic information to monitor, e.g. number of messages exchanged, consumer count, producer count, etc.

Command line utilities are also available to let you monitor ActiveMQ. Refer to ActiveMQ Command Line Tools Reference for usage information.

+ + +

+ + + + + +

+ +	+ [ edit ] +

+ + +

+ + + + + Added: incubator/activemq/site/JMeter+Performance+Tests URL: http://svn.apache.org/viewcvs/incubator/activemq/site/JMeter%2BPerformance%2BTests?rev=374430&view=auto ============================================================================== --- incubator/activemq/site/JMeter+Performance+Tests (added) +++ incubator/activemq/site/JMeter+Performance+Tests Thu Feb 2 08:31:10 2006 @@ -0,0 +1,277 @@ + + + + + + + + ActiveMQ - JMeter Performance Tests + + + + + + + + + + + + + + + +

+ + + + + + +

Overview

Community

Using ActiveMQ

Features

Connectivitiy

Utilities

JCA Container

External Tools

Related Projects

Support

Developers

Tools we use

+ +

Feeds

+ + + + + + + + + +

+ +	+ Site +
+ +	+ News +

+ +

+ + + + + +

+ JMeter Performance Tests +

+ +

+ + +

JMeter performance test

You can use JMeter to test the performance of your ActiveMQ Server. Please refer to the JMeter site for detailed instructions on using this software.

Downloading the JMeter Performance Test Binary

You can download the latest activemq-jmeter-*.zip distribution from here.

Building the JMeter Performance Test from source

1. Check out the latest head version of ActiveMQ from Source. Build from source.

2. Run maven from the JMeter directory. This will build JMeter into the target directory.

3. Run JMeter.bat from the \bin directory to start JMeter.

4. There are sample Test Plans located at \bin\testfiles directory that you could open to test ActiveMQ.

Building a Test Plan

For a Producer Sampler
1. Add a Thread Group.
2. Add the producer sampler "Producer Sampler" from the Sampler menu.
3. Highlight the Producer Sampler then right click to add the producer listener "View Producer Results" from the Listener menu.
4. Go to the Thread Group element and set the Number of Threads, Ramp-Up Period and Loop Count to 1.

For a Consumer Sampler
1. Add a Thread Group.
2. Add the consumer sampler "Consumer Sampler" from the Sampler menu.
3. Highlight the Consumer Sampler then right click to add the consumer listener "View Consumer Results" from the Listener menu.
4. Go to the Thread Group element and set the Number of Threads, Ramp-Up Period and Loop Count to 1.

The JMeter Performance Test Module consists of:

1. JMeter Producer Sampler

A JMeter Sampler tells JMeter to send requests to the server. Pluggable Samplers allow unlimited testing capabilities.

The Producer Sampler will send messages to an ActiveMQ Server.

The Producer Sampler has the following parameters:

Server URL - defines the server url i.e. tcp://localhost:61616
Duration (min) - the duration of the test.
Ramp Up (min) - the time in which the Producer will reach it's stable/peak state.
No. of Producer - The number of Producer that would be sending the message.
No. of Subject - The number of Subject that would be created then send. Note that the number of Subject should be less than or equal to the No. of Producer.
Message Size (bytes) - The size of the message to send.
Delivery Mode - Default is Non-Persistent.
Messaging Domain - Default is Topic
Message Interval - Default/Custom Interval. When Custom Interval was Selected user must provide Interval Value (mins).
Message Queue Servers - List of available MQ Servers.

2. JMeter Producer Listener

Listeners provide access to the information JMeter gathers about the test cases while JMeter runs.
The Producer Listener would provide statistics with the number of messages sent and average messages per second.

3. JMeter Consumer Sampler

The Consumer Sampler has the following parameters:

Server URL - defines the server url i.e. tcp://localhost:61616
Duration (min) - the duration of the test.
Ramp Up (min) - the time in which the Producer will reach it's stable/peak state.
No. of Consumer - The number of Consumer that would be sending the message.
No. of Subject - The number of Subject that would be created then send. Note that the number of Subject should be less than or equal to the No. of Consumer.
Delivery Mode - Default is non-Durable.
Messaging Domain - Default is Topic.
Message Queue Servers - List of available MQ Servers.

4. JMeter Consumer Listener

The Consumer Listener would provide statistics with the number of messages received and average messages per second.

+ + +

+ + + + + +

+ +	+ [ edit ] +

+ + +

+ + + + + Added: incubator/activemq/site/JNDI+Support URL: http://svn.apache.org/viewcvs/incubator/activemq/site/JNDI%2BSupport?rev=374430&view=auto ============================================================================== --- incubator/activemq/site/JNDI+Support (added) +++ incubator/activemq/site/JNDI+Support Thu Feb 2 08:31:10 2006 @@ -0,0 +1,330 @@ + + + + + + + + ActiveMQ - JNDI Support + + + + + + + + + + + + + + + +

+ + + + + + +

Overview

Community

Using ActiveMQ

Features

Connectivitiy

Utilities

JCA Container

External Tools

Related Projects

Support

Developers

Tools we use

+ +

Feeds

+ + + + + + + + + +

+ +	+ Site +
+ +	+ News +

+ +

+ + + + + +

+ JNDI Support +

+ +

+ + +

ActiveMQ will work with any JNDI provider capable of storing Java objects.

However it is common to require a JNDI initial context to be able to run many JMS example programs, like Sun's JMS tutorial

So we provide a simple JNDI InitialContextFactory which can be used to lookup JMS connection factory objects as well as Destination objects.

For example if you place this jndi.properties file on your classpath, you can look inside the InitialContext and lookup ConnectionFactory objects and Destinations etc.

[Unable to download http://activemq.codehaus.org/checkout/activemq/modules/core/src/test/jndi.properties : http://activemq.codehaus.org/checkout/activemq/modules/core/src/test/jndi.properties]

You can edit the jndi.properties file to configure the ActiveMQConnectionFactory's properties such as brokerURL and whether or not there should be an embedded broker etc. See how to embed a broker in a connection for more details.

ActiveMQ JNDI Tutorial

This is a quick one page tutorial on how to setup and use JNDI to create a connection to ActiveMQ. The first thing is ActiveMQ 1.1 does not provide a full JNDI server. This means JMS clients need to use properties files to create a jndi IntialContextFactory. If you need an example properties file, you can either look at the documentation http://activemq.codehaus.org/JNDI+Support or in the source distribution "activemq-1.1/src/test/jndi.properties." Before we proceed, here are the properties.

+ + + + + + + + + + + + + + + + + + + +
Name Value
java.naming.factory.initial org.activemq.jndi.ActiveMQInitialContextFactory
java.naming.provider.url Tcp://hostname:61616
topic.MyTopic example.MyTopic
+

Make sure to add activemq-1.1.jar and spring-1.1.jar to your classpath. If the libraries are not in the classpath, you will get a "ClassNotFoundException" at runtime. If you get "ClassNotFoundException", try printing out the classpath and check it is present. You can also run activeMQ with "-verbose" option to verify the jar was loaded correctly.

+ + + + + + + + +
Sample code
+

// create a new intial context, which loads from jndi.properties file
+javax.naming.Context ctx = new javax.naming.InitialContext();
+// lookup the connection factory
+javax.jms.TopicConnectionFactory factory = (javax.jms.TopicConnectionFactory)ctx.lookup("ConnectionFactory");
+// create a new TopicConnection for pub/sub messaging
+javax.jms.TopicConnection conn = factory.getTopicConnection();
+// lookup an existing topic
+javax.jms.Topic mytopic = (javax.jms.Topic)ctx.lookup("MyTopic");
+// create a new TopicSession for the client
+javax.jms.TopicSession session = conn.createTopicSession(false,TopicSession.AUTO_ACKNOWLEDGE);
+// create a new subscriber to receive messages
+javax.jms.TopicSubscriber subscriber = session.createSubscriber(mytopic);

+ + + + + +

Notice the name of the topic in the sample is "MyTopic". ActiveMQ will read the jndi.properties files and creates the topics and queues in a lazy fashion. The prefix topic and queue is stripped, so the jndi name begins after the prefix.

Once you have the jndi.properties edited and ready, it needs to be accessible to your application. The easiest way is to add jndi.properties to a jar file. When "new InitialContext()" is called, it will scan the resources and find the file. If you get "javax.naming.NamingException", it usually means the jndi.properties file is not accessible.

You can also try to create a new initial context using either an instance of properties file or a map. For example, the approach recommended by JMS specification will work just fine.

+ + + + + + + + +
Example recommended by specification
+

Properties props = new Properties();
+props.setProperty(Context.INITIAL_CONTEXT_FACTORY,"org.activemq.jndi.ActiveMQInitialContextFactory");
+props.setProperty(Context.PROVIDER_URL,"tcp://hostname:61616");
+javax.naming.Context ctx = new InitialContext(props);||

+ + + + + +

If ActiveMQ is embedded within an EJB container, you will need to look at the containers documentation for the correct jndi values.

Dynamically creating destinations

For the easiest possible configuration with JNDI based programs, there are 2 dynamic contexts as follows

dynamicQueues
dynamicTopics

which allows you to lookup queues and topics using JNDI without any configuration.

e.g. if you use the following name to lookup into JNDI

dynamicQueues/FOO.BAR

you will get back an ActiveMQQueue of the name "FOO.BAR".

This can be very handy if you can easily reconfigure the JNDI name to use to lookup something in JNDI, but don't want to have to double configure a jndi.properties to matchup.

Example Java code

Once you have configured JNDI on the classpath you can run any normal JMS application such as the following example. Notice that the Java code just uses pure JMS APIs and is not in any way ActiveMQ specific

[Unable to download http://activemq.codehaus.org/checkout/activemq/modules/core/src/test/org/activemq/demo/SimpleProducer.java : http://activemq.codehaus.org/checkout/activemq/modules/core/src/test/org/activemq/demo/SimpleProducer.java]

+ + +

+ + + + + +

+ +	+ [ edit ] +

+ + +

+ + + + + Added: incubator/activemq/site/JUnit+Reports URL: http://svn.apache.org/viewcvs/incubator/activemq/site/JUnit%2BReports?rev=374430&view=auto ============================================================================== --- incubator/activemq/site/JUnit+Reports (added) +++ incubator/activemq/site/JUnit+Reports Thu Feb 2 08:31:10 2006 @@ -0,0 +1,274 @@ + + + + + + + + ActiveMQ - JUnit Reports + + + + + + + + + + + + + + + +

+ + + + + + +

Overview

Community

Using ActiveMQ

Features

Connectivitiy

Utilities

JCA Container

External Tools

Related Projects

Support

Developers

Tools we use

+ +

Feeds

+ + + + + + + + + +

+ +	+ Site +
+ +	+ News +

+ +

+ + + + + +

+ JUnit Reports +

+ +

+ + +

+ + + + + + + + + + + + + +
Test Time Messages
JUnit Results 0% + + + +
+ 00:00.0 + + + + + + +
Tests: 0 Failures: 0 Exceptions: 0
+
+ + + + + + + + +
JUnit Results 0% + + + +
+ 00:00.0 + + + + + + +
Tests: 0 Failures: 0 Exceptions: 0
+
+

+ + +