This closes #120 examples improvements

This commit is contained in:
Clebert Suconic 2015-08-11 23:46:05 -04:00
commit 302c06d4e1
603 changed files with 2558 additions and 3796 deletions

View File

@ -26,12 +26,8 @@ import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.io.StringWriter;
import java.nio.file.Files;
import java.nio.file.attribute.PosixFilePermission;
import java.text.DecimalFormat;
import java.util.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@ -43,15 +39,7 @@ import org.apache.activemq.artemis.cli.commands.util.SyncCalculation;
import org.apache.activemq.artemis.core.server.cluster.impl.MessageLoadBalancingType;
import org.apache.activemq.artemis.jlibaio.LibaioContext;
import org.apache.activemq.artemis.jlibaio.LibaioFile;
import static java.nio.file.attribute.PosixFilePermission.GROUP_EXECUTE;
import static java.nio.file.attribute.PosixFilePermission.GROUP_READ;
import static java.nio.file.attribute.PosixFilePermission.GROUP_WRITE;
import static java.nio.file.attribute.PosixFilePermission.OTHERS_EXECUTE;
import static java.nio.file.attribute.PosixFilePermission.OTHERS_READ;
import static java.nio.file.attribute.PosixFilePermission.OWNER_EXECUTE;
import static java.nio.file.attribute.PosixFilePermission.OWNER_READ;
import static java.nio.file.attribute.PosixFilePermission.OWNER_WRITE;
import org.apache.activemq.artemis.utils.FileUtil;
/**
* CLI action that creates a broker instance directory.
@ -701,13 +689,7 @@ public class Create extends InputAbstract {
}
private void makeExec(String path) throws IOException {
try {
File file = new File(directory, path);
Files.setPosixFilePermissions(file.toPath(), new HashSet<PosixFilePermission>(Arrays.asList(OWNER_READ, OWNER_WRITE, OWNER_EXECUTE, GROUP_READ, GROUP_WRITE, GROUP_EXECUTE, OTHERS_READ, OTHERS_EXECUTE)));
}
catch (Throwable ignore) {
// Our best effort was not good enough :)
}
FileUtil.makeExec(new File(directory, path));
}
private String[] getQueueList() {

View File

@ -0,0 +1,47 @@
/**
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You 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.artemis.utils;
import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.attribute.PosixFilePermission;
import java.util.Arrays;
import java.util.HashSet;
import static java.nio.file.attribute.PosixFilePermission.GROUP_EXECUTE;
import static java.nio.file.attribute.PosixFilePermission.GROUP_READ;
import static java.nio.file.attribute.PosixFilePermission.GROUP_WRITE;
import static java.nio.file.attribute.PosixFilePermission.OTHERS_EXECUTE;
import static java.nio.file.attribute.PosixFilePermission.OTHERS_READ;
import static java.nio.file.attribute.PosixFilePermission.OWNER_EXECUTE;
import static java.nio.file.attribute.PosixFilePermission.OWNER_READ;
import static java.nio.file.attribute.PosixFilePermission.OWNER_WRITE;
public class FileUtil {
public static void makeExec(File file) throws IOException {
try {
Files.setPosixFilePermissions(file.toPath(), new HashSet<PosixFilePermission>(Arrays.asList(OWNER_READ, OWNER_WRITE, OWNER_EXECUTE, GROUP_READ, GROUP_WRITE, GROUP_EXECUTE, OTHERS_READ, OTHERS_EXECUTE)));
}
catch (Throwable ignore) {
// Our best effort was not good enough :)
}
}
}

View File

@ -23,9 +23,9 @@ under the License.
<meta content="text/html; charset=ISO-8859-1"
http-equiv="content-type">
<title>Apache ActiveMQ Artemis README</title>
<link rel="stylesheet" type="text/css" href="./examples/jms/common/common.css" />
<link rel="stylesheet" type="text/css" href="./examples/jms/common/prettify.css" />
<script type="text/javascript" src="./examples/jms/common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="./examples/common/common.css" />
<link rel="stylesheet" type="text/css" href="./examples/common/prettify.css" />
<script type="text/javascript" src="./examples/common/prettify.js"></script>
</head>
<body>
@ -67,12 +67,12 @@ NAME
SYNOPSIS
artemis create [--allow-anonymous]
[--cluster-password <clusterPassword>] [--cluster-user <clusterUser>]
[--clustered] [--data <data>] [--encoding <encoding>] [--force]
[--home <home>] [--host <host>] [--java-options <javaOptions>]
[--password <password>] [--port-offset <portOffset>] [--replicated]
[--role <role>] [--shared-store] [--silent] [--user <user>] [--]
<directory>
[--cluster-password &lt;clusterPassword&gt;] [--cluster-user &lt;clusterUser&gt;]
[--clustered] [--data &lt;data&gt;] [--encoding &lt;encoding&gt;] [--force]
[--home &lt;home&gt;] [--host &lt;host&gt;] [--java-options &lt;javaOptions&gt;]
[--password &lt;password&gt;] [--port-offset &lt;portOffset&gt;] [--replicated]
[--role &lt;role&gt;] [--shared-store] [--silent] [--user &lt;user&gt;] [--]
&lt;directory&gt;
...
</PRE>
@ -113,3 +113,4 @@ The examples are shipped inside the distribution folder under "examples"</br></b
The ActiveMQ Artemis 1.0.0 release notes can be found in the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315920&version=12328953">Apache ActiveMQ Artemis project JIRA</a>.
</body>

View File

@ -20,18 +20,12 @@ package org.apache.activemq.artemis.maven;
import org.apache.maven.plugin.AbstractMojo;
import org.apache.maven.plugin.MojoExecutionException;
import org.apache.maven.plugin.MojoFailureException;
import org.apache.maven.plugins.annotations.Parameter;
public abstract class ArtemisAbstractPlugin extends AbstractMojo {
/**
* It will ignore executioni if ignore has been set to true. This is useful as a property from the build.
*/
@Parameter(defaultValue = "")
private boolean ignore;
public void execute() throws MojoExecutionException, MojoFailureException {
if (ignore) {
if (isIgnore()) {
getLog().debug("******************************************************************************************************");
getLog().debug("Execution of " + getClass().getSimpleName() + " is being ignored as ignore has been set to true");
getLog().debug("******************************************************************************************************");
@ -41,5 +35,7 @@ public abstract class ArtemisAbstractPlugin extends AbstractMojo {
}
}
protected abstract boolean isIgnore();
protected abstract void doExecute() throws MojoExecutionException, MojoFailureException;
}

View File

@ -37,6 +37,9 @@ public class ArtemisCLIPlugin extends ArtemisAbstractPlugin {
private PluginDescriptor descriptor;
@Parameter(defaultValue = "${noServer}")
boolean ignore;
@Parameter(defaultValue = "server")
String name;
@ -91,6 +94,11 @@ public class ArtemisCLIPlugin extends ArtemisAbstractPlugin {
}
protected boolean isIgnore() {
return ignore;
}
@Override
protected void doExecute() throws MojoExecutionException, MojoFailureException {
// This is to avoid the Run issuing a kill at any point

View File

@ -37,11 +37,19 @@ public class ArtemisClientPlugin extends ArtemisAbstractPlugin {
@Parameter
String[] args;
@Parameter(defaultValue = "${noClient}")
boolean ignore;
/**
* @parameter
*/
private Properties systemProperties;
@Override
protected boolean isIgnore() {
return ignore;
}
@Override
protected void doExecute() throws MojoExecutionException, MojoFailureException {
try {

View File

@ -17,7 +17,9 @@
package org.apache.activemq.artemis.maven;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.PrintStream;
import java.nio.file.Files;
import java.nio.file.LinkOption;
import java.nio.file.Path;
@ -28,6 +30,7 @@ import java.util.Map;
import java.util.Set;
import org.apache.activemq.artemis.cli.Artemis;
import org.apache.activemq.artemis.utils.FileUtil;
import org.apache.maven.plugin.MojoExecutionException;
import org.apache.maven.plugin.MojoFailureException;
import org.apache.maven.plugin.descriptor.PluginDescriptor;
@ -140,6 +143,9 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
@Parameter(defaultValue = "${localRepository}")
private org.apache.maven.artifact.repository.ArtifactRepository localRepository;
@Parameter(defaultValue = "${noServer}")
boolean ignore;
/**
* Validate if the directory is a artemis.home *
*
@ -170,11 +176,13 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
}
}
@Override
protected boolean isIgnore() {
return ignore;
}
@Override
protected void doExecute() throws MojoExecutionException, MojoFailureException {
if (System.getProperty("bypassAddress") != null) {
System.out.println("BYPASSADDRESS");
}
getLog().info("Local " + localRepository);
MavenProject project = (MavenProject) getPluginContext().get("project");
@ -251,6 +259,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
getLog().debug("***** Server created at " + instance + " with home=" + home + " *****");
File commandLine = new File(instance.getParentFile(), "create-" + instance.getName() + ".sh");
FileOutputStream outputStream;
try {
outputStream = new FileOutputStream(commandLine);
}
catch (Exception e) {
e.printStackTrace();
throw new MojoExecutionException(e.getMessage(), e);
}
PrintStream commandLineStream = new PrintStream(outputStream);
commandLineStream.println("# These are the commands used to create " + instance.getName());
commandLineStream.println(getCommandline(listCommands));
try {
Artemis.execute(home, null, listCommands);
@ -265,12 +287,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
Path target = instance.toPath().resolve("etc").resolve(file);
getLog().debug("Replacing " + file + " into " + target);
Files.copy(configuration.toPath().resolve(file), target, StandardCopyOption.REPLACE_EXISTING);
Path originalFile = configuration.toPath().resolve(file);
Files.copy(originalFile, target, StandardCopyOption.REPLACE_EXISTING);
commandLineStream.println("");
commandLineStream.println("# replacing " + originalFile.getFileName() + " on the default configuration");
commandLineStream.println("cp " + originalFile + " " + target);
}
}
}
if (libList != null) {
commandLineStream.println();
commandLineStream.println("# This is a list of files that need to be installed under ./lib.");
commandLineStream.println("# We are copying them from your maven lib home");
for (int i = 0; i < libList.length; i++) {
String[] splitString = libList[i].split(":");
@ -302,11 +332,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
getLog().debug("Artifact:: " + artifact + " file = " + artifactFile);
copyToLib(artifactFile);
copyToLib(artifactFile, commandLineStream);
}
}
commandLineStream.close();
FileUtil.makeExec(commandLine);
getLog().info("###################################################################################################");
getLog().info(commandLine.getName() + " created with commands to reproduce " + instance.getName());
getLog().info("under " + commandLine.getParent());
getLog().info("###################################################################################################");
}
catch (Exception e) {
getLog().error(e);
@ -314,9 +353,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
}
}
private void copyToLib(File projectLib) throws IOException {
private String getCommandline(ArrayList<String> listCommands) {
StringBuffer buffer = new StringBuffer();
buffer.append(home.getAbsolutePath() + "/bin/artemis ");
for (String string : listCommands) {
buffer.append(string + " ");
}
return buffer.toString();
}
private void copyToLib(File projectLib, PrintStream commandLineStream) throws IOException {
Path target = instance.toPath().resolve("lib").resolve(projectLib.getName());
target.toFile().mkdirs();
commandLineStream.println("cp " + projectLib.getAbsolutePath() + " " + target);
getLog().debug("Copying " + projectLib.getName() + " as " + target.toFile().getAbsolutePath());
Files.copy(projectLib.toPath(), target, StandardCopyOption.REPLACE_EXISTING);
}

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Client Side Load Balancing Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency>
</dependencies>
<profiles>
<profile>
<!-- specify -PnoServer if you don't want to start the server -->
<id>noServer</id>
<properties>
<noServer>true</noServer>
</properties>
</profile>
</profiles>
<build>
<plugins>
<plugin>
@ -193,7 +184,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>client-side-load-balancing</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Client-Side Load-Balancing Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>JMS Client-Side Load-Balancing Example</h1>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered Durable Subscription Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency>
</dependencies>
<profiles>
<profile>
<!-- specify -PnoServer if you don't want to start the server -->
<id>noServer</id>
<properties>
<noServer>true</noServer>
</properties>
</profile>
</profiles>
<build>
<plugins>
<plugin>
@ -155,7 +146,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-durable-subscription</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Durable Subscription Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>JMS Durable Subscription Example</h1>

View File

@ -23,8 +23,6 @@ import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.naming.InitialContext;
import java.util.Hashtable;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS CLustered Grouping Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency>
</dependencies>
<profiles>
<profile>
<!-- specify -PnoServer if you don't want to start the server -->
<id>noServer</id>
<properties>
<noServer>true</noServer>
</properties>
</profile>
</profiles>
<build>
<plugins>
<plugin>
@ -191,7 +182,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-grouping</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,7 +20,7 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Clustered Grouping Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css">
<link rel="stylesheet" type="text/css" href="../../../common/common.css">
</head>
<body>
<h1>JMS Clustered Grouping Example</h1>

View File

@ -26,7 +26,6 @@ import javax.jms.TextMessage;
import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.jms.client.ActiveMQQueue;
/**
* A simple example that demonstrates server side load-balancing of messages between the queue instances on different

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered JGroups Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency>
</dependencies>
<profiles>
<profile>
<!-- specify -PnoServer if you don't want to start the server -->
<id>noServer</id>
<properties>
<noServer>true</noServer>
</properties>
</profile>
</profiles>
<build>
<plugins>
<plugin>
@ -158,7 +149,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-jgroups</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis Clustering with JGroups Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>ActiveMQ Artemis Clustering with JGroups Example</h1>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered Queue Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency>
</dependencies>
<profiles>
<profile>
<!-- specify -PnoServer if you don't want to start the server -->
<id>noServer</id>
<properties>
<noServer>true</noServer>
</properties>
</profile>
</profiles>
<build>
<plugins>
<plugin>
@ -151,7 +142,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-queue</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Load Balanced Clustered Queue Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>JMS Load Balanced Clustered Queue Example</h1>

View File

@ -26,7 +26,6 @@ import javax.jms.TextMessage;
import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.jms.client.ActiveMQQueue;
/**
* A simple example that demonstrates server side load-balancing of messages between the queue instances on different

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered Static Discovery Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -49,15 +49,6 @@ under the License.
</dependency>
</dependencies>
<profiles>
<profile>
<!-- specify -PnoServer if you don't want to start the server -->
<id>noServer</id>
<properties>
<noServer>true</noServer>
</properties>
</profile>
</profiles>
<build>
<plugins>
<plugin>
@ -236,7 +227,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-static-discovery</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Load Balanced Static Clustered Queue Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>JMS Load Balanced Static Clustered Queue Example</h1>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered Static One Way Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -49,15 +49,6 @@ under the License.
</dependency>
</dependencies>
<profiles>
<profile>
<!-- specify -PnoServer if you don't want to start the server -->
<id>noServer</id>
<properties>
<noServer>true</noServer>
</properties>
</profile>
</profiles>
<build>
<plugins>
<plugin>
@ -196,7 +187,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-static-oneway</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Load Balanced Static Clustered Queue Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>JMS Load Balanced Static Clustered One Way Queue Example</h1>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered Topic Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency>
</dependencies>
<profiles>
<profile>
<!-- specify -PnoServer if you don't want to start the server -->
<id>noServer</id>
<properties>
<noServer>true</noServer>
</properties>
</profile>
</profiles>
<build>
<plugins>
<plugin>
@ -151,7 +142,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-topic</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Clustered Topic Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>JMS Clustered Topic Example</h1>

View File

@ -0,0 +1,77 @@
<?xml version='1.0'?>
<!--
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements. See the NOTICE file
distributed with this work for additional information
regarding copyright ownership. The ASF licenses this file
to you 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.
-->
<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>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-features</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<packaging>pom</packaging>
<name>ActiveMQ Artemis Clustered Examples</name>
<!-- Properties -->
<properties>
<!--
Explicitly declaring the source encoding eliminates the following
message: [WARNING] Using platform encoding (UTF-8 actually) to copy
filtered resources, i.e. build is platform dependent!
-->
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
</properties>
<profiles>
<profile>
<id>examples</id>
<modules>
<module>client-side-load-balancing</module>
<module>clustered-durable-subscription</module>
<module>clustered-grouping</module>
<module>clustered-jgroups</module>
<module>clustered-queue</module>
<module>clustered-static-oneway</module>
<module>clustered-static-discovery</module>
<module>clustered-topic</module>
<module>queue-message-redistribution</module>
<module>symmetric-cluster</module>
</modules>
</profile>
<profile>
<id>release</id>
<modules>
<module>clustered-durable-subscription</module>
<module>clustered-grouping</module>
<module>clustered-jgroups</module>
<module>clustered-queue</module>
<module>clustered-static-oneway</module>
<module>clustered-static-discovery</module>
<module>clustered-topic</module>
<module>queue-message-redistribution</module>
<module>symmetric-cluster</module>
</modules>
</profile>
</profiles>
</project>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Queue Message Redistribution Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency>
</dependencies>
<profiles>
<profile>
<!-- specify -PnoServer if you don't want to start the server -->
<id>noServer</id>
<properties>
<noServer>true</noServer>
</properties>
</profile>
</profiles>
<build>
<plugins>
<plugin>
@ -152,7 +143,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>queue-message-redistribution</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis Message Redistribution Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>Message Redistribution Example</h1>

View File

@ -23,8 +23,6 @@ import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.InitialContext;
import java.util.Hashtable;
import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Symmetric Cluster Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency>
</dependencies>
<profiles>
<profile>
<!-- specify -PnoServer if you don't want to start the server -->
<id>noServer</id>
<properties>
<noServer>true</noServer>
</properties>
</profile>
</profiles>
<build>
<plugins>
<plugin>
@ -317,7 +308,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>symmetric-cluster</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Symmetric Cluster Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>JMS Symmetric Cluster Example</h1>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>broker-failover</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Application Layer Failover Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -90,7 +90,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>application-layer-failover</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis Application-Layer Failover Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>Application-Layer Failover Example</h1>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>broker-failover</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Client Side Failover listener Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -97,7 +97,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>client-side-fileoverlistener</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis Client Side Failover Listener Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>Client Side Kickoff Example</h1>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>broker-failover</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Colocated Failover Recover Only Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -91,7 +91,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>colocated-failover-scale-down</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Colocated Failover Scale Down Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>JMS Colocated Failover Recover Only Example</h1>

View File

@ -26,7 +26,6 @@ import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.InitialContext;
import java.lang.IllegalStateException;
import java.util.Hashtable;
/**

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>broker-failover</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Colocated Failover Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -91,7 +91,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>colocated-failover</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Colocated Failover Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>JMS Colocated Failover Shared Store Example</h1>

View File

@ -26,7 +26,6 @@ import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.InitialContext;
import java.lang.IllegalStateException;
import java.util.Hashtable;
/**

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>broker-failover</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS HA Policy Auto backup example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -91,7 +91,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>ha-policy-autobackup</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>broker-failover</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Multiple Failover Failback Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -109,7 +109,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>multiple-failover-failback</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>broker-failover</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Multiple Failover Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -109,7 +109,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>multiple-failover</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq.examples.jms</groupId>
<artifactId>jms-examples</artifactId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>broker-failover</artifactId>
<version>1.0.1-SNAPSHOT</version>
</parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Non Transaction Failover Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<dependencies>
@ -97,7 +97,7 @@ under the License.
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
<groupId>org.apache.activemq.examples.failover</groupId>
<artifactId>non-transaction-failover</artifactId>
<version>${project.version}</version>
</dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html>
<head>
<title>ActiveMQ Artemis JMS Failover Without Transactions Example</title>
<link rel="stylesheet" type="text/css" href="../common/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script>
<link rel="stylesheet" type="text/css" href="../../../common/common.css" />
<link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
<h1>JMS Failover Without Transactions Example</h1>

Some files were not shown because too many files have changed in this diff Show More