This commit has improvements on the examples including:

https://issues.apache.org/jira/browse/ARTEMIS-113 Better organize examples
https://issues.apache.org/jira/browse/ARTEMIS-114 Some openwire examples
This commit is contained in:
Clebert Suconic 2015-08-10 10:41:52 -04:00
parent f48fc9bf76
commit 21bf440636
604 changed files with 2296 additions and 3920 deletions

View File

@ -26,12 +26,8 @@ import java.io.InputStream;
import java.io.OutputStream; import java.io.OutputStream;
import java.io.PrintWriter; import java.io.PrintWriter;
import java.io.StringWriter; import java.io.StringWriter;
import java.nio.file.Files;
import java.nio.file.attribute.PosixFilePermission;
import java.text.DecimalFormat; import java.text.DecimalFormat;
import java.util.Arrays;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet;
import java.util.Map; import java.util.Map;
import java.util.regex.Matcher; import java.util.regex.Matcher;
import java.util.regex.Pattern; 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.core.server.cluster.impl.MessageLoadBalancingType;
import org.apache.activemq.artemis.jlibaio.LibaioContext; import org.apache.activemq.artemis.jlibaio.LibaioContext;
import org.apache.activemq.artemis.jlibaio.LibaioFile; import org.apache.activemq.artemis.jlibaio.LibaioFile;
import org.apache.activemq.artemis.utils.FileUtil;
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;
/** /**
* CLI action that creates a broker instance directory. * CLI action that creates a broker instance directory.
@ -701,13 +689,7 @@ public class Create extends InputAbstract {
} }
private void makeExec(String path) throws IOException { private void makeExec(String path) throws IOException {
try { FileUtil.makeExec(new File(directory, path));
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 :)
}
} }
private String[] getQueueList() { 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" <meta content="text/html; charset=ISO-8859-1"
http-equiv="content-type"> http-equiv="content-type">
<title>Apache ActiveMQ Artemis README</title> <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/common/common.css" />
<link rel="stylesheet" type="text/css" href="./examples/jms/common/prettify.css" /> <link rel="stylesheet" type="text/css" href="./examples/common/prettify.css" />
<script type="text/javascript" src="./examples/jms/common/prettify.js"></script> <script type="text/javascript" src="./examples/common/prettify.js"></script>
</head> </head>
<body> <body>
@ -67,12 +67,12 @@ NAME
SYNOPSIS SYNOPSIS
artemis create [--allow-anonymous] artemis create [--allow-anonymous]
[--cluster-password <clusterPassword>] [--cluster-user <clusterUser>] [--cluster-password &lt;clusterPassword&gt;] [--cluster-user &lt;clusterUser&gt;]
[--clustered] [--data <data>] [--encoding <encoding>] [--force] [--clustered] [--data &lt;data&gt;] [--encoding &lt;encoding&gt;] [--force]
[--home <home>] [--host <host>] [--java-options <javaOptions>] [--home &lt;home&gt;] [--host &lt;host&gt;] [--java-options &lt;javaOptions&gt;]
[--password <password>] [--port-offset <portOffset>] [--replicated] [--password &lt;password&gt;] [--port-offset &lt;portOffset&gt;] [--replicated]
[--role <role>] [--shared-store] [--silent] [--user <user>] [--] [--role &lt;role&gt;] [--shared-store] [--silent] [--user &lt;user&gt;] [--]
<directory> &lt;directory&gt;
... ...
</PRE> </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>. 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.AbstractMojo;
import org.apache.maven.plugin.MojoExecutionException; import org.apache.maven.plugin.MojoExecutionException;
import org.apache.maven.plugin.MojoFailureException; import org.apache.maven.plugin.MojoFailureException;
import org.apache.maven.plugins.annotations.Parameter;
public abstract class ArtemisAbstractPlugin extends AbstractMojo { 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 { public void execute() throws MojoExecutionException, MojoFailureException {
if (ignore) { if (isIgnore()) {
getLog().debug("******************************************************************************************************"); getLog().debug("******************************************************************************************************");
getLog().debug("Execution of " + getClass().getSimpleName() + " is being ignored as ignore has been set to true"); getLog().debug("Execution of " + getClass().getSimpleName() + " is being ignored as ignore has been set to true");
getLog().debug("******************************************************************************************************"); getLog().debug("******************************************************************************************************");
@ -41,5 +35,7 @@ public abstract class ArtemisAbstractPlugin extends AbstractMojo {
} }
} }
protected abstract boolean isIgnore();
protected abstract void doExecute() throws MojoExecutionException, MojoFailureException; protected abstract void doExecute() throws MojoExecutionException, MojoFailureException;
} }

View File

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

View File

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

View File

@ -17,7 +17,9 @@
package org.apache.activemq.artemis.maven; package org.apache.activemq.artemis.maven;
import java.io.File; import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException; import java.io.IOException;
import java.io.PrintStream;
import java.nio.file.Files; import java.nio.file.Files;
import java.nio.file.LinkOption; import java.nio.file.LinkOption;
import java.nio.file.Path; import java.nio.file.Path;
@ -28,6 +30,7 @@ import java.util.Map;
import java.util.Set; import java.util.Set;
import org.apache.activemq.artemis.cli.Artemis; 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.MojoExecutionException;
import org.apache.maven.plugin.MojoFailureException; import org.apache.maven.plugin.MojoFailureException;
import org.apache.maven.plugin.descriptor.PluginDescriptor; import org.apache.maven.plugin.descriptor.PluginDescriptor;
@ -140,6 +143,9 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
@Parameter(defaultValue = "${localRepository}") @Parameter(defaultValue = "${localRepository}")
private org.apache.maven.artifact.repository.ArtifactRepository localRepository; private org.apache.maven.artifact.repository.ArtifactRepository localRepository;
@Parameter(defaultValue = "${noServer}")
boolean ignore;
/** /**
* Validate if the directory is a artemis.home * * Validate if the directory is a artemis.home *
* *
@ -170,11 +176,13 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
} }
} }
@Override
protected boolean isIgnore() {
return ignore;
}
@Override @Override
protected void doExecute() throws MojoExecutionException, MojoFailureException { protected void doExecute() throws MojoExecutionException, MojoFailureException {
if (System.getProperty("bypassAddress") != null) {
System.out.println("BYPASSADDRESS");
}
getLog().info("Local " + localRepository); getLog().info("Local " + localRepository);
MavenProject project = (MavenProject) getPluginContext().get("project"); MavenProject project = (MavenProject) getPluginContext().get("project");
@ -251,6 +259,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
getLog().debug("***** Server created at " + instance + " with home=" + home + " *****"); 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 { try {
Artemis.execute(home, null, listCommands); Artemis.execute(home, null, listCommands);
@ -265,12 +287,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
Path target = instance.toPath().resolve("etc").resolve(file); Path target = instance.toPath().resolve("etc").resolve(file);
getLog().debug("Replacing " + file + " into " + target); 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) { 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++) { for (int i = 0; i < libList.length; i++) {
String[] splitString = libList[i].split(":"); String[] splitString = libList[i].split(":");
@ -302,11 +332,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
getLog().debug("Artifact:: " + artifact + " file = " + artifactFile); 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) { catch (Exception e) {
getLog().error(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()); Path target = instance.toPath().resolve("lib").resolve(projectLib.getName());
target.toFile().mkdirs(); target.toFile().mkdirs();
commandLineStream.println("cp " + projectLib.getAbsolutePath() + " " + target);
getLog().debug("Copying " + projectLib.getName() + " as " + target.toFile().getAbsolutePath()); getLog().debug("Copying " + projectLib.getName() + " as " + target.toFile().getAbsolutePath());
Files.copy(projectLib.toPath(), target, StandardCopyOption.REPLACE_EXISTING); Files.copy(projectLib.toPath(), target, StandardCopyOption.REPLACE_EXISTING);
} }

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>jms-examples</artifactId> <artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version> <version>1.0.1-SNAPSHOT</version>
</parent> </parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Client Side Load Balancing Example</name> <name>ActiveMQ Artemis JMS Client Side Load Balancing Example</name>
<properties> <properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir> <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties> </properties>
<dependencies> <dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency> </dependency>
</dependencies> </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> <build>
<plugins> <plugins>
<plugin> <plugin>
@ -193,7 +184,7 @@ under the License.
</executions> </executions>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>client-side-load-balancing</artifactId> <artifactId>client-side-load-balancing</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

View File

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

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>jms-examples</artifactId> <artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version> <version>1.0.1-SNAPSHOT</version>
</parent> </parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered Durable Subscription Example</name> <name>ActiveMQ Artemis JMS Clustered Durable Subscription Example</name>
<properties> <properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir> <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties> </properties>
<dependencies> <dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency> </dependency>
</dependencies> </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> <build>
<plugins> <plugins>
<plugin> <plugin>
@ -155,7 +146,7 @@ under the License.
</executions> </executions>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-durable-subscription</artifactId> <artifactId>clustered-durable-subscription</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

View File

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

View File

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

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>jms-examples</artifactId> <artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version> <version>1.0.1-SNAPSHOT</version>
</parent> </parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS CLustered Grouping Example</name> <name>ActiveMQ Artemis JMS CLustered Grouping Example</name>
<properties> <properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir> <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties> </properties>
<dependencies> <dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency> </dependency>
</dependencies> </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> <build>
<plugins> <plugins>
<plugin> <plugin>
@ -191,7 +182,7 @@ under the License.
</executions> </executions>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-grouping</artifactId> <artifactId>clustered-grouping</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

View File

@ -20,7 +20,7 @@ under the License.
<html> <html>
<head> <head>
<title>ActiveMQ Artemis JMS Clustered Grouping Example</title> <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> </head>
<body> <body>
<h1>JMS Clustered Grouping Example</h1> <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.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; 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 * 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> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>jms-examples</artifactId> <artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version> <version>1.0.1-SNAPSHOT</version>
</parent> </parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered JGroups Example</name> <name>ActiveMQ Artemis JMS Clustered JGroups Example</name>
<properties> <properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir> <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties> </properties>
<dependencies> <dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency> </dependency>
</dependencies> </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> <build>
<plugins> <plugins>
<plugin> <plugin>
@ -158,7 +149,7 @@ under the License.
</executions> </executions>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-jgroups</artifactId> <artifactId>clustered-jgroups</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

View File

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

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>jms-examples</artifactId> <artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version> <version>1.0.1-SNAPSHOT</version>
</parent> </parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered Queue Example</name> <name>ActiveMQ Artemis JMS Clustered Queue Example</name>
<properties> <properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir> <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties> </properties>
<dependencies> <dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency> </dependency>
</dependencies> </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> <build>
<plugins> <plugins>
<plugin> <plugin>
@ -151,7 +142,7 @@ under the License.
</executions> </executions>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-queue</artifactId> <artifactId>clustered-queue</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html> <html>
<head> <head>
<title>ActiveMQ Artemis JMS Load Balanced Clustered Queue Example</title> <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/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" /> <link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script> <script type="text/javascript" src="../../../common/prettify.js"></script>
</head> </head>
<body onload="prettyPrint()"> <body onload="prettyPrint()">
<h1>JMS Load Balanced Clustered Queue Example</h1> <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.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; 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 * 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> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>jms-examples</artifactId> <artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version> <version>1.0.1-SNAPSHOT</version>
</parent> </parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered Static Discovery Example</name> <name>ActiveMQ Artemis JMS Clustered Static Discovery Example</name>
<properties> <properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir> <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties> </properties>
<dependencies> <dependencies>
@ -49,15 +49,6 @@ under the License.
</dependency> </dependency>
</dependencies> </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> <build>
<plugins> <plugins>
<plugin> <plugin>
@ -236,7 +227,7 @@ under the License.
</executions> </executions>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-static-discovery</artifactId> <artifactId>clustered-static-discovery</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

View File

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

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>jms-examples</artifactId> <artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version> <version>1.0.1-SNAPSHOT</version>
</parent> </parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered Static One Way Example</name> <name>ActiveMQ Artemis JMS Clustered Static One Way Example</name>
<properties> <properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir> <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties> </properties>
<dependencies> <dependencies>
@ -49,15 +49,6 @@ under the License.
</dependency> </dependency>
</dependencies> </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> <build>
<plugins> <plugins>
<plugin> <plugin>
@ -196,7 +187,7 @@ under the License.
</executions> </executions>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-static-oneway</artifactId> <artifactId>clustered-static-oneway</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html> <html>
<head> <head>
<title>ActiveMQ Artemis JMS Load Balanced Static Clustered Queue Example</title> <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/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" /> <link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script> <script type="text/javascript" src="../../../common/prettify.js"></script>
</head> </head>
<body onload="prettyPrint()"> <body onload="prettyPrint()">
<h1>JMS Load Balanced Static Clustered One Way Queue Example</h1> <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> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>jms-examples</artifactId> <artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version> <version>1.0.1-SNAPSHOT</version>
</parent> </parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Clustered Topic Example</name> <name>ActiveMQ Artemis JMS Clustered Topic Example</name>
<properties> <properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir> <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties> </properties>
<dependencies> <dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency> </dependency>
</dependencies> </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> <build>
<plugins> <plugins>
<plugin> <plugin>
@ -151,7 +142,7 @@ under the License.
</executions> </executions>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>clustered-topic</artifactId> <artifactId>clustered-topic</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

View File

@ -20,9 +20,9 @@ under the License.
<html> <html>
<head> <head>
<title>ActiveMQ Artemis JMS Clustered Topic Example</title> <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/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" /> <link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script> <script type="text/javascript" src="../../../common/prettify.js"></script>
</head> </head>
<body onload="prettyPrint()"> <body onload="prettyPrint()">
<h1>JMS Clustered Topic Example</h1> <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> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>jms-examples</artifactId> <artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version> <version>1.0.1-SNAPSHOT</version>
</parent> </parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Queue Message Redistribution Example</name> <name>ActiveMQ Artemis JMS Queue Message Redistribution Example</name>
<properties> <properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir> <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties> </properties>
<dependencies> <dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency> </dependency>
</dependencies> </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> <build>
<plugins> <plugins>
<plugin> <plugin>
@ -152,7 +143,7 @@ under the License.
</executions> </executions>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>queue-message-redistribution</artifactId> <artifactId>queue-message-redistribution</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

View File

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

View File

@ -23,8 +23,6 @@ import javax.jms.MessageProducer;
import javax.jms.Queue; import javax.jms.Queue;
import javax.jms.Session; import javax.jms.Session;
import javax.jms.TextMessage; 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.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;

View File

@ -23,8 +23,8 @@ under the License.
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>jms-examples</artifactId> <artifactId>broker-clustered</artifactId>
<version>1.0.1-SNAPSHOT</version> <version>1.0.1-SNAPSHOT</version>
</parent> </parent>
@ -33,7 +33,7 @@ under the License.
<name>ActiveMQ Artemis JMS Symmetric Cluster Example</name> <name>ActiveMQ Artemis JMS Symmetric Cluster Example</name>
<properties> <properties>
<activemq.basedir>${project.basedir}/../../..</activemq.basedir> <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties> </properties>
<dependencies> <dependencies>
@ -44,15 +44,6 @@ under the License.
</dependency> </dependency>
</dependencies> </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> <build>
<plugins> <plugins>
<plugin> <plugin>
@ -317,7 +308,7 @@ under the License.
</executions> </executions>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.activemq.examples.jms</groupId> <groupId>org.apache.activemq.examples.clustered</groupId>
<artifactId>symmetric-cluster</artifactId> <artifactId>symmetric-cluster</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

@ -20,9 +20,9 @@ under the License.
<html> <html>
<head> <head>
<title>ActiveMQ Artemis JMS Colocated Failover Scale Down Example</title> <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/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" /> <link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script> <script type="text/javascript" src="../../../common/prettify.js"></script>
</head> </head>
<body onload="prettyPrint()"> <body onload="prettyPrint()">
<h1>JMS Colocated Failover Recover Only Example</h1> <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.Session;
import javax.jms.TextMessage; import javax.jms.TextMessage;
import javax.naming.InitialContext; import javax.naming.InitialContext;
import java.lang.IllegalStateException;
import java.util.Hashtable; import java.util.Hashtable;
/** /**

View File

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

View File

@ -20,9 +20,9 @@ under the License.
<html> <html>
<head> <head>
<title>ActiveMQ Artemis JMS Colocated Failover Example</title> <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/common.css" />
<link rel="stylesheet" type="text/css" href="../common/prettify.css" /> <link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
<script type="text/javascript" src="../common/prettify.js"></script> <script type="text/javascript" src="../../../common/prettify.js"></script>
</head> </head>
<body onload="prettyPrint()"> <body onload="prettyPrint()">
<h1>JMS Colocated Failover Shared Store Example</h1> <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.Session;
import javax.jms.TextMessage; import javax.jms.TextMessage;
import javax.naming.InitialContext; import javax.naming.InitialContext;
import java.lang.IllegalStateException;
import java.util.Hashtable; import java.util.Hashtable;
/** /**

View File

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

View File

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

View File

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

View File

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

View File

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

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