Author: foconer
Date: Tue May 30 21:39:26 2006
New Revision: 410428
URL: http://svn.apache.org/viewvc?rev=410428&view=rev
Log:
Module for performance testing. Temporarily used Tools from activemq-optional.
Added:
incubator/activemq/trunk/activemq-perftest/
incubator/activemq/trunk/activemq-perftest/pom.xml
incubator/activemq/trunk/activemq-perftest/src/
incubator/activemq/trunk/activemq-perftest/src/main/
incubator/activemq/trunk/activemq-perftest/src/main/java/
incubator/activemq/trunk/activemq-perftest/src/main/java/org/
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ConsumerTool.java
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ProducerTool.java
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ToolSupport.java
incubator/activemq/trunk/activemq-perftest/src/main/resources/
incubator/activemq/trunk/activemq-perftest/src/main/resources/config/
incubator/activemq/trunk/activemq-perftest/src/main/resources/config/activemq.xml
Added: incubator/activemq/trunk/activemq-perftest/pom.xml
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-perftest/pom.xml?rev=410428&view=auto
==============================================================================
--- incubator/activemq/trunk/activemq-perftest/pom.xml (added)
+++ incubator/activemq/trunk/activemq-perftest/pom.xml Tue May 30 21:39:26 2006
@@ -0,0 +1,47 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/maven-v4_0_0.xsd";>
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <artifactId>activemq-parent</artifactId>
+ <groupId>incubator-activemq</groupId>
+ <version>4.0-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>activemq-perftest</artifactId>
+ <packaging>jar</packaging>
+ <name>ActiveMQ :: Performance Test</name>
+ <description>Performance Testing Framework for ActiveMQ</description>
+
+ <dependencies>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>3.8.1</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>incubator-activemq</groupId>
+ <artifactId>activemq-core</artifactId>
+ <version>4.0-SNAPSHOT</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>incubator-activemq</groupId>
+ <artifactId>activemq-console</artifactId>
+ <version>4.0-SNAPSHOT</version>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>incubator-activemq</groupId>
+ <artifactId>maven-perf-plugin</artifactId>
+ <version>4.0-SNAPSHOT</version>
+ </plugin>
+ </plugins>
+ </build>
+
+</project>
\ No newline at end of file
Added:
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ConsumerTool.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ConsumerTool.java?rev=410428&view=auto
==============================================================================
---
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ConsumerTool.java
(added)
+++
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ConsumerTool.java
Tue May 30 21:39:26 2006
@@ -0,0 +1,140 @@
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.tool;
+
+import javax.jms.Connection;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageListener;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import javax.jms.Topic;
+import java.io.IOException;
+
+/**
+ * A simple tool for consuming messages
+ *
+ * @version $Revision$
+ */
+public class ConsumerTool extends ToolSupport implements MessageListener {
+
+ protected int count = 0;
+ protected int dumpCount = 10;
+ protected boolean verbose = true;
+ protected int maxiumMessages = 0;
+ private boolean pauseBeforeShutdown;
+
+
+ public static void main(String[] args) {
+ ConsumerTool tool = new ConsumerTool();
+ if (args.length > 0) {
+ tool.url = args[0];
+ }
+ if (args.length > 1) {
+ tool.topic = args[1].equalsIgnoreCase("true");
+ }
+ if (args.length > 2) {
+ tool.subject = args[2];
+ }
+ if (args.length > 3) {
+ tool.durable = args[3].equalsIgnoreCase("true");
+ }
+ if (args.length > 4) {
+ tool.maxiumMessages = Integer.parseInt(args[4]);
+ }
+ tool.run();
+ }
+
+ public void run() {
+ try {
+ System.out.println("Connecting to URL: " + url);
+ System.out.println("Consuming " + (topic ? "topic" : "queue") + ":
" + subject);
+ System.out.println("Using " + (durable ? "durable" :
"non-durable") + " subscription");
+
+ Connection connection = createConnection();
+ Session session = createSession(connection);
+ MessageConsumer consumer = null;
+ if (durable && topic) {
+ consumer = session.createDurableSubscriber((Topic)
destination, consumerName);
+ }
+ else {
+ consumer = session.createConsumer(destination);
+ }
+ if (maxiumMessages <= 0) {
+ consumer.setMessageListener(this);
+ }
+ connection.start();
+
+ if (maxiumMessages > 0) {
+ consumeMessagesAndClose(connection, session, consumer);
+ }
+ }
+ catch (Exception e) {
+ System.out.println("Caught: " + e);
+ e.printStackTrace();
+ }
+ }
+
+ public void onMessage(Message message) {
+ try {
+ if (message instanceof TextMessage) {
+ TextMessage txtMsg = (TextMessage) message;
+ if (verbose) {
+
+ String msg = txtMsg.getText();
+ if( msg.length() > 50 )
+ msg = msg.substring(0, 50)+"...";
+
+ System.out.println("Received: " + msg);
+ }
+ }
+ else {
+ if (verbose) {
+ System.out.println("Received: " + message);
+ }
+ }
+ /*
+ if (++count % dumpCount == 0) {
+ dumpStats(connection);
+ }
+ */
+ }
+ catch (JMSException e) {
+ System.out.println("Caught: " + e);
+ e.printStackTrace();
+ }
+ }
+
+
+ protected void consumeMessagesAndClose(Connection connection, Session
session, MessageConsumer consumer) throws JMSException, IOException {
+ System.out.println("We are about to wait until we consume: " +
maxiumMessages + " message(s) then we will shutdown");
+
+ for (int i = 0; i < maxiumMessages; i++) {
+ Message message = consumer.receive();
+ onMessage(message);
+ }
+ System.out.println("Closing connection");
+ consumer.close();
+ session.close();
+ connection.close();
+ if (pauseBeforeShutdown) {
+ System.out.println("Press return to shut down");
+ System.in.read();
+ }
+ }
+}
\ No newline at end of file
Added:
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ProducerTool.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ProducerTool.java?rev=410428&view=auto
==============================================================================
---
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ProducerTool.java
(added)
+++
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ProducerTool.java
Tue May 30 21:39:26 2006
@@ -0,0 +1,133 @@
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.tool;
+
+import java.util.Date;
+
+import javax.jms.Connection;
+import javax.jms.DeliveryMode;
+import javax.jms.JMSException;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+
+/**
+ * A simple tool for publishing messages
+ *
+ * @version $Revision$
+ */
+public class ProducerTool extends ToolSupport {
+
+ protected int messageCount = 10;
+ protected long sleepTime = 0L;
+ protected boolean verbose = true;
+ protected int messageSize = 255;
+
+ public static void main(String[] args) {
+ runTool(args, new ProducerTool());
+ }
+
+ protected static void runTool(String[] args, ProducerTool tool) {
+ if (args.length > 0) {
+ tool.url = args[0];
+ }
+ if (args.length > 1) {
+ tool.topic = args[1].equalsIgnoreCase("true");
+ }
+ if (args.length > 2) {
+ tool.subject = args[2];
+ }
+ if (args.length > 3) {
+ tool.durable = args[3].equalsIgnoreCase("true");
+ }
+ if (args.length > 4) {
+ tool.messageCount = Integer.parseInt(args[4]);
+ }
+ if (args.length > 5) {
+ tool.messageSize = Integer.parseInt(args[5]);
+ }
+ tool.run();
+ }
+
+ public void run() {
+ try {
+ System.out.println("Connecting to URL: " + url);
+ System.out.println("Publishing a Message with size "+messageSize+"
to " + (topic ? "topic" : "queue") + ": " + subject);
+ System.out.println("Using " + (durable ? "durable" :
"non-durable") + " publishing");
+
+ Connection connection = createConnection();
+ Session session = createSession(connection);
+ MessageProducer producer = createProducer(session);
+ //connection.start();
+
+ sendLoop(session, producer);
+
+ System.out.println("Done.");
+ close(connection, session);
+ }
+ catch (Exception e) {
+ System.out.println("Caught: " + e);
+ e.printStackTrace();
+ }
+ }
+
+ protected MessageProducer createProducer(Session session) throws
JMSException {
+ MessageProducer producer = session.createProducer(destination);
+ if (durable) {
+ producer.setDeliveryMode(DeliveryMode.PERSISTENT);
+ }
+ else {
+ producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
+ }
+ return producer;
+ }
+
+ protected void sendLoop(Session session, MessageProducer producer) throws
Exception {
+
+ for (int i = 0; i < messageCount; i++) {
+
+
+ TextMessage message =
session.createTextMessage(createMessageText(i));
+
+ if (verbose) {
+ String msg = message.getText();
+ if( msg.length() > 50 )
+ msg = msg.substring(0, 50)+"...";
+ System.out.println("Sending message: " + msg);
+ }
+
+ producer.send(message);
+ Thread.sleep(sleepTime);
+ }
+ producer.send(session.createMessage());
+ }
+
+ /**
+ * @param i
+ * @return
+ */
+ private String createMessageText(int index) {
+ StringBuffer buffer = new StringBuffer(messageSize);
+ buffer.append("Message: " + index + " sent at: " + new Date());
+ if( buffer.length() > messageSize ) {
+ return buffer.substring(0, messageSize);
+ }
+ for( int i=buffer.length(); i < messageSize; i++)
+ buffer.append(' ');
+ return buffer.toString();
+ }
+}
\ No newline at end of file
Added:
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ToolSupport.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ToolSupport.java?rev=410428&view=auto
==============================================================================
---
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ToolSupport.java
(added)
+++
incubator/activemq/trunk/activemq-perftest/src/main/java/org/apache/activemq/tool/ToolSupport.java
Tue May 30 21:39:26 2006
@@ -0,0 +1,84 @@
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.tool;
+
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.util.IndentPrinter;
+
+import javax.jms.Connection;
+import javax.jms.Destination;
+import javax.jms.JMSException;
+import javax.jms.Session;
+
+/**
+ * Abstract base class useful for implementation inheritence
+ *
+ * @version $Revision$
+ */
+public class ToolSupport {
+
+
+ protected Destination destination;
+ protected String subject = "TOOL.DEFAULT";
+ protected boolean topic = true;
+ protected String user = ActiveMQConnection.DEFAULT_USER;
+ protected String pwd = ActiveMQConnection.DEFAULT_PASSWORD;
+ protected String url = ActiveMQConnection.DEFAULT_BROKER_URL;
+ protected boolean transacted = false;
+ protected boolean durable = false;
+ protected String clientID = getClass().getName();
+ protected int ackMode = Session.AUTO_ACKNOWLEDGE;
+ protected String consumerName = "James";
+
+
+ protected Session createSession(Connection connection) throws Exception {
+ if (durable) {
+ connection.setClientID(clientID);
+ }
+ Session session = connection.createSession(transacted, ackMode);
+ if (topic) {
+ destination = session.createTopic(subject);
+ }
+ else {
+ destination = session.createQueue(subject);
+ }
+ return session;
+ }
+
+ protected Connection createConnection() throws JMSException, Exception {
+ ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(user, pwd, url);
+ return connectionFactory.createConnection();
+ }
+
+ protected void close(Connection connection, Session session) throws
JMSException {
+ // lets dump the stats
+ dumpStats(connection);
+
+ if (session != null) {
+ session.close();
+ }
+ if (connection != null) {
+ connection.close();
+ }
+ }
+
+ protected void dumpStats(Connection connection) {
+ ActiveMQConnection c = (ActiveMQConnection) connection;
+ c.getConnectionStats().dump(new IndentPrinter());
+ }
+}
\ No newline at end of file
Added:
incubator/activemq/trunk/activemq-perftest/src/main/resources/config/activemq.xml
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-perftest/src/main/resources/config/activemq.xml?rev=410428&view=auto
==============================================================================
---
incubator/activemq/trunk/activemq-perftest/src/main/resources/config/activemq.xml
(added)
+++
incubator/activemq/trunk/activemq-perftest/src/main/resources/config/activemq.xml
Tue May 30 21:39:26 2006
@@ -0,0 +1,94 @@
+<!-- START SNIPPET: xbean -->
+<beans xmlns="http://activemq.org/config/1.0";>
+
+ <broker useJmx="true">
+
+ <!-- Use the following to set the broker memory limit (in bytes)
+ <memoryManager>
+ <usageManager id="memory-manager" limit="1048576"/>
+ </memoryManager>
+ -->
+
+ <!-- Use the following to configure how ActiveMQ is exposed in JMX
+ <managementContext>
+ <managementContext connectorPort="1099"
jmxDomainName="org.apache.activemq"/>
+ </managementContext>
+ -->
+
+ <!-- In ActiveMQ 4, you can setup destination policies -->
+ <destinationPolicy>
+ <policyMap><policyEntries>
+
+ <policyEntry topic="FOO.>">
+ <dispatchPolicy>
+ <strictOrderDispatchPolicy />
+ </dispatchPolicy>
+ <subscriptionRecoveryPolicy>
+ <lastImageSubscriptionRecoveryPolicy />
+ </subscriptionRecoveryPolicy>
+ </policyEntry>
+
+ </policyEntries></policyMap>
+ </destinationPolicy>
+
+
+ <persistenceAdapter>
+ <journaledJDBC journalLogFiles="5" dataDirectory="target/activemq-data"/>
+ <!-- To use a different datasource, use th following syntax : -->
+ <!--
+ <journaledJDBC journalLogFiles="5" dataDirectory="../activemq-data"
dataSource="#postgres-ds"/>
+ -->
+ </persistenceAdapter>
+
+ <transportConnectors>
+ <transportConnector name="default" uri="tcp://localhost:61616"
discoveryUri="multicast://default"/>
+ <transportConnector name="stomp" uri="stomp://localhost:61613"/>
+ </transportConnectors>
+
+ <networkConnectors>
+ <!-- by default just auto discover the other brokers -->
+ <networkConnector name="default" uri="multicast://default"/>
+ <!--
+ <networkConnector name="host1 and host2"
uri="static://(tcp://host1:61616,tcp://host2:61616)" failover="true"/>
+ -->
+ </networkConnectors>
+
+ </broker>
+
+ <!-- This xbean configuration file supports all the standard spring xml
configuration options -->
+
+ <!-- Postgres DataSource Sample Setup -->
+ <!--
+ <bean id="postgres-ds" class="org.postgresql.ds.PGPoolingDataSource">
+ <property name="serverName" value="localhost"/>
+ <property name="databaseName" value="activemq"/>
+ <property name="portNumber" value="0"/>
+ <property name="user" value="activemq"/>
+ <property name="password" value="activemq"/>
+ <property name="dataSourceName" value="postgres"/>
+ <property name="initialConnections" value="1"/>
+ <property name="maxConnections" value="10"/>
+ </bean>
+ -->
+
+ <!-- MySql DataSource Sample Setup -->
+ <!--
+ <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
+ <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
+ <property name="url"
value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>
+ <property name="username" value="activemq"/>
+ <property name="password" value="activemq"/>
+ <property name="poolPreparedStatements" value="true"/>
+ </bean>
+ -->
+
+ <!-- Embedded Derby DataSource Sample Setup -->
+ <!--
+ <bean id="derby-ds" class="org.apache.derby.jdbc.EmbeddedDataSource">
+ <property name="databaseName" value="derbydb"/>
+ <property name="createDatabase" value="create"/>
+ </bean>
+ -->
+
+</beans>
+<!-- END SNIPPET: xbean -->
