Author: foconer
Date: Wed May 31 01:28:21 2006
New Revision: 410462
URL: http://svn.apache.org/viewvc?rev=410462&view=rev
Log:
Plugin to start the broker, run a consumer and producer.
Added:
incubator/activemq/trunk/tooling/
incubator/activemq/trunk/tooling/maven-perf-plugin/
incubator/activemq/trunk/tooling/maven-perf-plugin/pom.xml
incubator/activemq/trunk/tooling/maven-perf-plugin/src/
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ServerMojo.java
Added: incubator/activemq/trunk/tooling/maven-perf-plugin/pom.xml
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-perf-plugin/pom.xml?rev=410462&view=auto
==============================================================================
--- incubator/activemq/trunk/tooling/maven-perf-plugin/pom.xml (added)
+++ incubator/activemq/trunk/tooling/maven-perf-plugin/pom.xml Wed May 31
01:28:21 2006
@@ -0,0 +1,62 @@
+<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>
+ <groupId>incubator-activemq</groupId>
+ <artifactId>activemq-parent</artifactId>
+ <version>4.0-SNAPSHOT</version>
+ <relativePath>../../pom.xml</relativePath>
+ </parent>
+
+
+ <groupId>incubator-activemq</groupId>
+ <artifactId>maven-perf-plugin</artifactId>
+ <packaging>maven-plugin</packaging>
+ <name>ActiveMQ :: Performance Test Plugin</name>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.maven</groupId>
+ <artifactId>maven-plugin-api</artifactId>
+ <version>2.0</version>
+ </dependency>
+ <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>
+ </dependency>
+ <dependency>
+ <groupId>incubator-activemq</groupId>
+ <artifactId>activemq-console</artifactId>
+ <version>4.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>incubator-activemq</groupId>
+ <artifactId>activemq-perftest</artifactId>
+ <version>4.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.derby</groupId>
+ <artifactId>derby</artifactId>
+ <version>10.1.1.0</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.derby</groupId>
+ <artifactId>derbynet</artifactId>
+ <version>10.1.1.0</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.geronimo.specs</groupId>
+ <artifactId>geronimo-j2ee-management_1.0_spec</artifactId>
+ <version>1.0</version>
+ </dependency>
+ </dependencies>
+</project>
\ No newline at end of file
Added:
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java?rev=410462&view=auto
==============================================================================
---
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java
(added)
+++
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java
Wed May 31 01:28:21 2006
@@ -0,0 +1,69 @@
+package org.apache.activemq.maven;
+
+/*
+ * Copyright 2001-2005 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.
+ */
+
+import org.apache.activemq.tool.ConsumerTool;
+import org.apache.maven.plugin.AbstractMojo;
+import org.apache.maven.plugin.MojoExecutionException;
+
+
+/**
+ * Goal which touches a timestamp file.
+ *
+ * @goal consumer
+ * @phase process
+ */
+public class ConsumerMojo
+ extends AbstractMojo {
+
+ /**
+ * @parameter expression="${url}" default-value="tcp://localhost:61616"
+ * @required
+ */
+ private String url;
+
+ /**
+ * @parameter expression="${topic}" default-value="true"
+ * @required
+ */
+ private String topic;
+
+ /**
+ * @parameter expression="${subject}" default-value="FOO.BAR"
+ * @required
+ */
+ private String subject;
+
+ /**
+ * @parameter expression="${durable}" default-value="false"
+ * @required
+ */
+ private String durable;
+
+ /**
+ * @parameter expression="${maximumMessage}" default-value="10"
+ * @required
+ */
+ private String maximumMessage;
+
+ public void execute()
+ throws MojoExecutionException {
+
+ String[] args = {url, topic, subject, durable, maximumMessage};
+ ConsumerTool.main(args);
+ }
+}
Added:
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java?rev=410462&view=auto
==============================================================================
---
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java
(added)
+++
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java
Wed May 31 01:28:21 2006
@@ -0,0 +1,71 @@
+package org.apache.activemq.maven;
+
+import org.apache.activemq.tool.ConsumerTool;
+import org.apache.activemq.tool.ProducerTool;
+import org.apache.maven.plugin.AbstractMojo;
+import org.apache.maven.plugin.MojoExecutionException;
+
+/*
+ * Copyright 2001-2005 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.
+ */
+
+
+/**
+ * Goal which touches a timestamp file.
+ *
+ * @goal producer
+ * @phase process
+ */
+public class ProducerMojo
+ extends AbstractMojo {
+
+ /**
+ * @parameter expression="${url}" default-value="tcp://localhost:61616"
+ * @required
+ */
+ private String url;
+ /**
+ * @parameter expression="${topic}" default-value="true"
+ * @required
+ */
+ private String topic;
+ /**
+ * @parameter expression="${subject}" default-value="FOO.BAR"
+ * @required
+ */
+ private String subject;
+ /**
+ * @parameter expression="${durable}" default-value="false"
+ * @required
+ */
+ private String durable;
+ /**
+ * @parameter expression="${messageCount}" default-value="10"
+ * @required
+ */
+ private String messageCount;
+ /**
+ * @parameter expression="${messageSize}" default-value="255"
+ * @required
+ */
+ private String messageSize;
+
+ public void execute()
+ throws MojoExecutionException {
+
+ String[] args = {url,topic,subject,durable,messageCount,messageSize};
+ ProducerTool.main(args);
+ }
+}
Added:
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ServerMojo.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ServerMojo.java?rev=410462&view=auto
==============================================================================
---
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ServerMojo.java
(added)
+++
incubator/activemq/trunk/tooling/maven-perf-plugin/src/main/java/org/apache/activemq/maven/ServerMojo.java
Wed May 31 01:28:21 2006
@@ -0,0 +1,124 @@
+package org.apache.activemq.maven;
+
+/*
+ * Copyright 2001-2005 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.
+ */
+
+import org.apache.activemq.console.Main;
+import org.apache.maven.plugin.AbstractMojo;
+import org.apache.maven.plugin.MojoExecutionException;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.nio.MappedByteBuffer;
+import java.nio.channels.FileChannel;
+
+/**
+ * Goal which starts activemq broker.
+ *
+ * @goal server
+ * @phase process
+ */
+public class ServerMojo
+ extends AbstractMojo {
+ /**
+ * Location of the output directory. Defaults to target.
+ *
+ * @parameter expression="${project.build.directory}"
+ * @required
+ */
+ private File outputDirectory;
+
+ /**
+ * Location of the predefined config files.
+ *
+ * @parameter expression="${configDirectory}"
default-value="${basedir}/src/main/resources/config"
+ * @required
+ */
+ private String configDirectory;
+
+ /**
+ * Type of activemq configuration to use. This is also the filename used.
+ *
+ * @parameter expression="${configType}" default-value="activemq"
+ * @required
+ */
+ private String configType;
+
+ /**
+ * Location of activemq config file other those found in resources/config.
+ *
+ * @parameter expression="${configFile}"
+ */
+ private File configFile;
+
+ public void execute()
+ throws MojoExecutionException {
+
+ File out = outputDirectory;
+
+ // Create output directory if it doesn't exist.
+ if (!out.exists()) {
+ out.mkdirs();
+ }
+
+ File config;
+ if (configFile != null) {
+ config = configFile;
+ } else {
+ config = new File(configDirectory + File.separator + configType +
".xml");
+ }
+
+ try {
+ config = copy(config);
+ } catch (IOException e) {
+ throw new MojoExecutionException(e.getMessage());
+ }
+
+ String[] args = {"start", "xbean:" + (config.toURI()).toString()};
+ Main.main(args);
+ }
+
+ /**
+ * Copy activemq configuration file to output directory.
+ *
+ * @param source
+ * @return
+ * @throws IOException
+ */
+ public File copy(File source) throws IOException {
+ FileChannel in = null, out = null;
+
+ File dest = new File(outputDirectory.getAbsolutePath() +
File.separator + "activemq.xml");
+
+ try {
+ in = new FileInputStream(source).getChannel();
+ out = new FileOutputStream(dest).getChannel();
+
+ long size = in.size();
+ MappedByteBuffer buf = in.map(FileChannel.MapMode.READ_ONLY, 0,
size);
+
+ out.write(buf);
+
+ } finally {
+ if (in != null) in.close();
+ if (out != null) out.close();
+ }
+
+ return dest;
+ }
+}
\ No newline at end of file
