activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From foco...@apache.org
Subject svn commit: r410462 - in /incubator/activemq/trunk/tooling: ./ maven-perf-plugin/ maven-perf-plugin/src/ maven-perf-plugin/src/main/ maven-perf-plugin/src/main/java/ maven-perf-plugin/src/main/java/org/ maven-perf-plugin/src/main/java/org/apache/ maven...
Date Wed, 31 May 2006 08:28:22 GMT
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



Mime
View raw message