You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ma...@apache.org on 2017/12/15 14:55:22 UTC
[03/14] activemq-artemis git commit: ARTEMIS-1562 Refactor example
documentation
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/features/standard/xa-send/readme.md
----------------------------------------------------------------------
diff --git a/examples/features/standard/xa-send/readme.md b/examples/features/standard/xa-send/readme.md
new file mode 100644
index 0000000..baa35c6
--- /dev/null
+++ b/examples/features/standard/xa-send/readme.md
@@ -0,0 +1,9 @@
+# JMS XA Send Example
+
+To run the example, simply type **mvn verify** from this directory, or **mvn -PnoServer verify** if you want to start and create the broker manually.
+
+This example shows you how message sending behaves in an XA transaction in ActiveMQ Artemis. When a message is sent within the scope of an XA transaction, it will only reach the queue once the transaction is committed. If the transaction is rolled back the sent messages will be discarded by the server.
+
+ActiveMQ Artemis is JTA aware, meaning you can use ActiveMQ Artemis in a XA transactional environment and participate in XA transactions. It provides the `javax.transaction.xa.XAResource` interface for that purpose. Users can get a XAConnectionFactory to create XAConnections and XASessions.
+
+In this example we simulate a transaction manager to control the transactions. First we create an XASession and enlist it in a transaction through its XAResource. We then send two words, `hello` and `world`, with the session, let the transaction roll back. The messages are discarded and never be received. Next we start a new transaction with the same XAResource, but this time we commit the transaction. Both messages are received.
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/features/sub-modules/artemis-ra-rar/pom.xml
----------------------------------------------------------------------
diff --git a/examples/features/sub-modules/artemis-ra-rar/pom.xml b/examples/features/sub-modules/artemis-ra-rar/pom.xml
index 6466710..6c18ca9 100644
--- a/examples/features/sub-modules/artemis-ra-rar/pom.xml
+++ b/examples/features/sub-modules/artemis-ra-rar/pom.xml
@@ -95,7 +95,23 @@ under the License.
<raXmlFile>src/main/resources/ra.xml</raXmlFile>
</configuration>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
</plugins>
</build>
-
-</project>
+ <profiles>
+ <profile>
+ <id>release</id>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/README.md
----------------------------------------------------------------------
diff --git a/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/README.md b/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/README.md
deleted file mode 100644
index 7751380..0000000
--- a/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/README.md
+++ /dev/null
@@ -1,147 +0,0 @@
-# Artemis to 5.x JMS Bridge
-
-This is an example of using the JMS bridge shipped with the Artemis broker to bridge to a 5.x broker.
-
-Notes:
-
-- The Artemis JMS bridge is a general purpose bridge and can be used to bridge to any JMS provider which implements JNDI.
-This example however is just focusing on integration with 5.x.
-- The Artemis JMS bridge can "push" _and_ "pull" messages so it can be used to move messages both ways.
-
-##Prerequisites
-
-- install ActiveMQ 5.x
-- install ActiveMQ Artemis
-
-##Preparing
-
-1) From the root dir run `mvn clean package`.
-
-2) Copy artemis-jms-bridge/target/artemis-jms-bridge-<version>.war to the web directory of the Artemis installation.
-
-3) Create an instance of the Artemis broker `$ARTEMIS_HOME/bin/artemis create --allow-anonymous myBroker`
-
-4) Edit the `$ARTEMIS_INSTANCE/etc/broker.xml` and change the `artemis` acceptor to run on 61617 and add the `invm` acceptor.
-
-```xml
-<acceptors>
- <acceptor name="artemis">tcp://0.0.0.0:61617?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor>
- <acceptor name="invm">vm://0</acceptor>
-</acceptors>
-```
-
-5) Edit `$ARTEMIS_INSTANCE/etc/bootstrap.xml` and add the war file.
-
-```xml
-<app url="bridge" war="artemis-jms-bridge-<version>.war"/>
-```
-
-##Testing
-
-Start the ActiveMQ broker.
-
-`$ACTIVEMQ_HOME/bin/standalone`
-
-Start the Artemis broker.
-
-`$ARTEMIS_INSTANCE/bin/artemis run`
-
-Send some messages to the queue TEST.BAR via the Artemis console.
-
-`$ARTEMIS_INSTANCE/bin/artemis producer --destination queue://TEST.BAR --url tcp://localhost:61617 --message-count 1`
-
-Log into the ActiveMQ 5.x console and browse the messages in the TEST.BAR queue.
-
-# 5.x to Artemis Camel JMS Bridge
-
-This is an alternative to using the Artemis JMS bridge using Camel in the 5.x broker to bridge messages to Artemis.
-There isn't anything to deploy here. It's just a set of instructions.
-
-This approach might be preferred if for example you only have access to the 5.x broker.
-
-## Prerequisites
-
-- install ActiveMQ 5.x
-- install ActiveMQ Artemis
-
-## Preparing
-
-1) Copy `lib/client/artemis-jms-client-all.jar` to the `$5X_HOME/lib` directory.
-
-2) Add the bridge configuration to `activemq.xml`:
-
-```xml
- <bean id="5xConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
- <property name="brokerURL" value="tcp://localhost:61616"/>
- <property name="userName" value="admin"/>
- <property name="password" value="password"/>
- </bean>
-
- <bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
- <property name="connectionFactory" ref="5xConnectionFactory"/>
- <property name="concurrentConsumers" value="10"/>
- </bean>
-
- <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
- <property name="configuration" ref="jmsConfig"/>
- </bean>
-
- <bean id="artemisConnectionFactory" class="org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory">
- <constructor-arg name="url" value="tcp://localhost:61617"/>
- </bean>
-
- <bean id="artemisConfig" class="org.apache.camel.component.jms.JmsConfiguration">
- <property name="connectionFactory" ref="artemisConnectionFactory"/>
- <property name="concurrentConsumers" value="10"/>
- </bean>
-
- <bean id="artemis" class="org.apache.camel.component.jms.JmsComponent">
- <property name="configuration" ref="artemisConfig"/>
- </bean>
-
- <camelContext id="bridgeContext" trace="false" xmlns="http://camel.apache.org/schema/spring">
- <route id="bridge_TEST.FOO">
- <from uri="activemq:queue:TEST.FOO"/>
- <to uri="artemis:queue:TEST.FOO"/>
- </route>
- </camelContext>
-```
-
-3) Ensure the `xsi:schemalocation` in activemq.xml contains the necessary Camel schemas:
-
-```
-http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
-```
-
-4) Create an instance of the Artemis broker `$ARTEMIS_HOME/bin/artemis create --allow-anonymous myBroker`
-
-5) Edit the `$ARTEMIS_INSTANCE/etc/broker.xml` and change the acceptor to listen to port 61617. Comment or remove all other acceptors.
-
-```xml
-<acceptors>
- <acceptor name="artemis">tcp://0.0.0.0:61617?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor>
-</acceptors>
-```
-
-6) Edit `$ARTEMIS_INSTANCE/etc/bootstrap.xml` so that the embedded web server runs on a different port that the 5.x broker (e.g. 8162):
-
-```xml
-<web bind="http://localhost:8162" path="web">
-```
-
-## Testing
-
-Start the Artemis broker.
-
-`$ARTEMIS_INSTANCE/bin/artemis run`
-
-Start the ActiveMQ 5.x broker.
-
-`$5X_HOME/bin/activemq start`
-
-Send some messages to the ActiveMQ 5.x broker.
-
-`$5X_HOME/bin/activemq producer --user admin --password password --destination queue://TEST.FOO`
-
-Log into the ActiveMQ Artemis console and browse the messages in the `TEST.FOO` queue.
-
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/pom.xml
----------------------------------------------------------------------
diff --git a/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/pom.xml b/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/pom.xml
index 1bbccfb..e9809b6 100644
--- a/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/pom.xml
+++ b/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/pom.xml
@@ -89,7 +89,23 @@ under the License.
<artifactId>maven-war-plugin</artifactId>
<version>3.1.0</version>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
</plugins>
</build>
-
-</project>
+ <profiles>
+ <profile>
+ <id>release</id>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/readme.md
----------------------------------------------------------------------
diff --git a/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/readme.md b/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/readme.md
new file mode 100644
index 0000000..6674bbc
--- /dev/null
+++ b/examples/features/sub-modules/inter-broker-bridge/artemis-jms-bridge/readme.md
@@ -0,0 +1,147 @@
+# Artemis to 5.x JMS Bridge
+
+This is an example of using the JMS bridge shipped with the Artemis broker to bridge to a 5.x broker.
+
+Notes:
+
+- The Artemis JMS bridge is a general purpose bridge and can be used to bridge to any JMS provider which implements JNDI.
+This example however is just focusing on integration with 5.x.
+- The Artemis JMS bridge can "push" _and_ "pull" messages so it can be used to move messages both ways.
+
+##Prerequisites
+
+- install ActiveMQ 5.x
+- install ActiveMQ Artemis
+
+##Preparing
+
+1) From the root dir run `mvn clean package`.
+
+2) Copy artemis-jms-bridge/target/artemis-jms-bridge-<version>.war to the web directory of the Artemis installation.
+
+3) Create an instance of the Artemis broker `$ARTEMIS_HOME/bin/artemis create --allow-anonymous myBroker`
+
+4) Edit the `$ARTEMIS_INSTANCE/etc/broker.xml` and change the `artemis` acceptor to run on 61617 and add the `invm` acceptor.
+
+```xml
+<acceptors>
+ <acceptor name="artemis">tcp://0.0.0.0:61617?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor>
+ <acceptor name="invm">vm://0</acceptor>
+</acceptors>
+```
+
+5) Edit `$ARTEMIS_INSTANCE/etc/bootstrap.xml` and add the war file.
+
+```xml
+<app url="bridge" war="artemis-jms-bridge-<version>.war"/>
+```
+
+##Testing
+
+Start the ActiveMQ broker.
+
+`$ACTIVEMQ_HOME/bin/standalone`
+
+Start the Artemis broker.
+
+`$ARTEMIS_INSTANCE/bin/artemis run`
+
+Send some messages to the queue TEST.BAR via the Artemis console.
+
+`$ARTEMIS_INSTANCE/bin/artemis producer --destination queue://TEST.BAR --url tcp://localhost:61617 --message-count 1`
+
+Log into the ActiveMQ 5.x console and browse the messages in the TEST.BAR queue.
+
+# 5.x to Artemis Camel JMS Bridge
+
+This is an alternative to using the Artemis JMS bridge using Camel in the 5.x broker to bridge messages to Artemis.
+There isn't anything to deploy here. It's just a set of instructions.
+
+This approach might be preferred if for example you only have access to the 5.x broker.
+
+## Prerequisites
+
+- install ActiveMQ 5.x
+- install ActiveMQ Artemis
+
+## Preparing
+
+1) Copy `lib/client/artemis-jms-client-all.jar` to the `$5X_HOME/lib` directory.
+
+2) Add the bridge configuration to `activemq.xml`:
+
+```xml
+ <bean id="5xConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="tcp://localhost:61616"/>
+ <property name="userName" value="admin"/>
+ <property name="password" value="password"/>
+ </bean>
+
+ <bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
+ <property name="connectionFactory" ref="5xConnectionFactory"/>
+ <property name="concurrentConsumers" value="10"/>
+ </bean>
+
+ <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
+ <property name="configuration" ref="jmsConfig"/>
+ </bean>
+
+ <bean id="artemisConnectionFactory" class="org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory">
+ <constructor-arg name="url" value="tcp://localhost:61617"/>
+ </bean>
+
+ <bean id="artemisConfig" class="org.apache.camel.component.jms.JmsConfiguration">
+ <property name="connectionFactory" ref="artemisConnectionFactory"/>
+ <property name="concurrentConsumers" value="10"/>
+ </bean>
+
+ <bean id="artemis" class="org.apache.camel.component.jms.JmsComponent">
+ <property name="configuration" ref="artemisConfig"/>
+ </bean>
+
+ <camelContext id="bridgeContext" trace="false" xmlns="http://camel.apache.org/schema/spring">
+ <route id="bridge_TEST.FOO">
+ <from uri="activemq:queue:TEST.FOO"/>
+ <to uri="artemis:queue:TEST.FOO"/>
+ </route>
+ </camelContext>
+```
+
+3) Ensure the `xsi:schemalocation` in activemq.xml contains the necessary Camel schemas:
+
+```
+http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
+```
+
+4) Create an instance of the Artemis broker `$ARTEMIS_HOME/bin/artemis create --allow-anonymous myBroker`
+
+5) Edit the `$ARTEMIS_INSTANCE/etc/broker.xml` and change the acceptor to listen to port 61617. Comment or remove all other acceptors.
+
+```xml
+<acceptors>
+ <acceptor name="artemis">tcp://0.0.0.0:61617?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor>
+</acceptors>
+```
+
+6) Edit `$ARTEMIS_INSTANCE/etc/bootstrap.xml` so that the embedded web broker runs on a different port that the 5.x broker (e.g. 8162):
+
+```xml
+<web bind="http://localhost:8162" path="web">
+```
+
+## Testing
+
+Start the Artemis broker.
+
+`$ARTEMIS_INSTANCE/bin/artemis run`
+
+Start the ActiveMQ 5.x broker.
+
+`$5X_HOME/bin/activemq start`
+
+Send some messages to the ActiveMQ 5.x broker.
+
+`$5X_HOME/bin/activemq producer --user admin --password password --destination queue://TEST.FOO`
+
+Log into the ActiveMQ Artemis console and browse the messages in the `TEST.FOO` queue.
+
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/perf/jmeter/README.md
----------------------------------------------------------------------
diff --git a/examples/perf/jmeter/README.md b/examples/perf/jmeter/README.md
deleted file mode 100644
index b1b2c6a..0000000
--- a/examples/perf/jmeter/README.md
+++ /dev/null
@@ -1,45 +0,0 @@
-####Running the ActiveMQ Artemis JMeter Performance Testing Examples
-
-######Create and run a sample broker for performance testing:
-
-```sh
-artemis create my-broker --queues exampleQueue --topics exampleTopic
-
-my-broker/bin/artemis run
-```
-######Download and Install JMeter's latest release: http://jmeter.apache.org/download_jmeter.cgi
-
-######Copy artemis-jms-client dependencies under $JMETER_HOME/lib folder:
-
-- artemis-jms-client.jar
-- artemis-core-client.jar
-- jgroups.jar
-- artemis-commons.jar
-- jboss-logmanager.jar
-- jboss-logging.jar
-- commons-beanutils.jar
-- commons-logging.jar (already present under JMeter's lib folder - may not be needed)
-- commons-collections.jar (already present under JMeter's lib folder - may not be needed)
-- artemis-selector.jar
-- artemis-journal.jar
-- artemis-native.jar
-- netty-all.jar
-- javax.inject.jar
-- geronimo-jms_2.0_spec.jar
-
-######Create a jndi.properties file with the connectionFactory Server Information:
-
-```
-connectionFactory.ConnectionFactory=tcp://localhost:61616
-```
-
-######Pack jndi.properties file into a jar file and put it under $JMETER_HOME/lib folder:
-
-```sh
-jar -cf artemis-jndi.jar jndi.properties
-```
-
-######Open jMeter and run the available Test Plan examples:
-
-- 1.jms_p2p_test.jmx
-- 2.pub_sub_test.jmx
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/perf/jmeter/readme.md
----------------------------------------------------------------------
diff --git a/examples/perf/jmeter/readme.md b/examples/perf/jmeter/readme.md
new file mode 100644
index 0000000..4c6b3dc
--- /dev/null
+++ b/examples/perf/jmeter/readme.md
@@ -0,0 +1,33 @@
+#Running the ActiveMQ Artemis JMeter Performance Testing Examples
+
+##Create and run a sample broker for performance testing:
+
+```sh
+artemis create my-broker --queues exampleQueue --topics exampleTopic
+
+my-broker/bin/artemis run
+```
+##Download and Install JMeter's latest release:
+
+http://jmeter.apache.org/download_jmeter.cgi
+
+##Copy artemis-jms-client dependencies under $JMETER_HOME/lib folder:
+
+- artemis-jms-client-all.jar
+
+######Create a jndi.properties file with the connectionFactory:
+
+```
+connectionFactory.ConnectionFactory=tcp://localhost:61616
+```
+
+######Pack jndi.properties file into a jar file and put it under $JMETER_HOME/lib folder:
+
+```sh
+jar -cf artemis-jndi.jar jndi.properties
+```
+
+######Open jMeter and run the available Test Plan examples:
+
+- 1.jms_p2p_test.jmx
+- 2.pub_sub_test.jmx
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/pom.xml
----------------------------------------------------------------------
diff --git a/examples/pom.xml b/examples/pom.xml
index 35026a5..224ea78 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -49,6 +49,28 @@ under the License.
</repository>
</repositories>
+ <build>
+ <pluginManagement>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ <version>3.0.0</version>
+ <configuration>
+ <filesets>
+ <fileset>
+ <directory>${basedir}</directory>
+ <includes>
+ <include>readme.html</include>
+ </includes>
+ </fileset>
+ </filesets>
+ </configuration>
+ </plugin>
+ </plugins>
+ </pluginManagement>
+ </build>
+
<pluginRepositories>
<pluginRepository>
<id>apache.snapshots</id>
@@ -82,6 +104,31 @@ under the License.
<noServer>true</noServer>
<noClient>true</noClient>
</properties>
+ <build>
+ <pluginManagement>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ <version>0.27.0</version>
+ <executions>
+ <execution>
+ <phase>package</phase>
+ <goals>
+ <goal>generate</goal>
+ </goals>
+ </execution>
+ </executions>
+ <configuration>
+ <headerHtmlFile>${activemq.basedir}/examples/common/header.html</headerHtmlFile>
+ <footerHtmlFile>${activemq.basedir}/examples/common/footer.html</footerHtmlFile>
+ <inputDirectory>${basedir}</inputDirectory>
+ <outputDirectory>${basedir}</outputDirectory>
+ </configuration>
+ </plugin>
+ </plugins>
+ </pluginManagement>
+ </build>
</profile>
<profile>
<!-- the profile release won't execute anything. just compile and whatever else is needed -->
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-clustered-cpp/pom.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-clustered-cpp/pom.xml b/examples/protocols/amqp/proton-clustered-cpp/pom.xml
index 9fab41e..db2fbf9 100644
--- a/examples/protocols/amqp/proton-clustered-cpp/pom.xml
+++ b/examples/protocols/amqp/proton-clustered-cpp/pom.xml
@@ -151,7 +151,6 @@ under the License.
</args>
</configuration>
</execution>
-
</executions>
<dependencies>
<dependency>
@@ -161,7 +160,23 @@ under the License.
</dependency>
</dependencies>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
</plugins>
</build>
-
-</project>
+ <profiles>
+ <profile>
+ <id>release</id>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-clustered-cpp/readme.html
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-clustered-cpp/readme.html b/examples/protocols/amqp/proton-clustered-cpp/readme.html
deleted file mode 100644
index 6a5ea8b..0000000
--- a/examples/protocols/amqp/proton-clustered-cpp/readme.html
+++ /dev/null
@@ -1,61 +0,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.
--->
-
-<html>
-<head>
- <title>ActiveMQ Artemis QPID cpp 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>
-</head>
-<body onload="prettyPrint()">
-<h1>AMQP CPP example</h1>
-
-<p>ActiveMQ Artemis is a multi protocol broker. It will inspect the initial handshake of clients to determine what protocol to use.</p>
-<p>All you need to do is to connect a client into activemq's configured port and you should be able connect.</p>
-<p>To run this example simply run the command <literal>mvn verify -Pexample</literal>, execute the compile.sh script and start the executable called ./hello</p>
-<pre>
- # first make sure you have the dependencies you need to compile and run the client
- # You will have to adapt this step according to your platform. Consult the <a href="http://qpid.apache.org/releases/qpid-0.30/programming/book/">qpid docs</a> for more information.
- # There is a list of <a href="http://qpid.apache.org/packages.html">packages</a> you can install as well.
- [proton-cpp]$ sudo yum install qpid-cpp-client-devel
-
- # on a first window
- [proton-cpp]$ mvn verify -Pexample
-
- # on a second window
- # That goes without saying but you will of course need g++ (the C++ compiler) installed
- [proton-cpp]$ ./compile.sh
- [proton-cpp]$ ./hello
-</pre>
-
-
-<p>You don't need to do anything special to configure the ActiveMQ Artemis server to accept AMQP clients. </p>
-<p>Just for the sake of documentation though we are setting the port of ActiveMQ Artemis on this example as 5672 which is the port qpid have by default. </p>
-<p>This is totally optional and you don't need to follow this convention. You can use any port you chose including ActiveMQ's 61616 default port</p>
- <pre class="prettyprint">
- <code>
- <acceptor name="proton-acceptor">tcp://localhost:5672</acceptor>
- </code>
- </pre>
-<h2>Example step-by-step</h2>
-<p> We are using qpid cpp client on this example. There are several libraries you may chose from for AMQP. We have ellect one that we consider simple enough for users.</p>
-
-</body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-clustered-cpp/readme.md
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-clustered-cpp/readme.md b/examples/protocols/amqp/proton-clustered-cpp/readme.md
new file mode 100644
index 0000000..8e87fed
--- /dev/null
+++ b/examples/protocols/amqp/proton-clustered-cpp/readme.md
@@ -0,0 +1,32 @@
+# AMQP CPP example
+
+ActiveMQ Artemis is a multi protocol broker. It will inspect the initial handshake of clients to determine what protocol to use.
+
+All you need to do is to connect a client into activemq's configured port and you should be able connect.
+
+To run this example simply run the command **mvn verify -Pexample**, execute the compile.sh script and start the executable called ./hello
+
+ # first make sure you have the dependencies you need to compile and run the client
+ # You will have to adapt this step according to your platform. Consult the [qpid docs](http://qpid.apache.org/releases/qpid-0.30/programming/book/) for more information.
+ # There is a list of [packages](http://qpid.apache.org/packages.html) you can install as well.
+ [proton-cpp]$ sudo yum install qpid-cpp-client-devel
+
+ # on a first window
+ [proton-cpp]$ mvn verify -Pexample
+
+ # on a second window
+ # That goes without saying but you will of course need g++ (the C++ compiler) installed
+ [proton-cpp]$ ./compile.sh
+ [proton-cpp]$ ./hello
+
+You don't need to do anything special to configure the ActiveMQ Artemis broker to accept AMQP clients.
+
+Just for the sake of documentation though we are setting the port of ActiveMQ Artemis on this example as 5672 which is the port qpid have by default.
+
+This is totally optional and you don't need to follow this convention. You can use any port you chose including ActiveMQ's 61616 default port
+
+ <acceptor name="proton-acceptor">tcp://localhost:5672</acceptor>
+
+## Example step-by-step
+
+We are using qpid cpp client on this example. There are several libraries you may chose from for AMQP. We have ellect one that we consider simple enough for users.
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-clustered-cpp/src/main/java/org/apache/activemq/artemis/jms/example/ProtonCPPExample.java
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-clustered-cpp/src/main/java/org/apache/activemq/artemis/jms/example/ProtonCPPExample.java b/examples/protocols/amqp/proton-clustered-cpp/src/main/java/org/apache/activemq/artemis/jms/example/ProtonCPPExample.java
index 961a56b..d8de751 100644
--- a/examples/protocols/amqp/proton-clustered-cpp/src/main/java/org/apache/activemq/artemis/jms/example/ProtonCPPExample.java
+++ b/examples/protocols/amqp/proton-clustered-cpp/src/main/java/org/apache/activemq/artemis/jms/example/ProtonCPPExample.java
@@ -31,7 +31,7 @@ import org.apache.qpid.jms.JmsConnectionFactory;
* This example demonstrates the use of ActiveMQ Artemis "pre-acknowledge" functionality where
* messages are acknowledged before they are delivered to the consumer.
* <p>
- * Please see the readme.html for more details.
+ * Please see the readme for more details.
*/
public class ProtonCPPExample {
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-clustered-cpp/src/main/resources/activemq/server0/broker.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-clustered-cpp/src/main/resources/activemq/server0/broker.xml b/examples/protocols/amqp/proton-clustered-cpp/src/main/resources/activemq/server0/broker.xml
index 240d256..bcfc677 100644
--- a/examples/protocols/amqp/proton-clustered-cpp/src/main/resources/activemq/server0/broker.xml
+++ b/examples/protocols/amqp/proton-clustered-cpp/src/main/resources/activemq/server0/broker.xml
@@ -17,10 +17,7 @@ KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
-->
-<configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="urn:activemq /schema/artemis-server.xsd">
-
-
+<configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
<core xmlns="urn:activemq:core">
<bindings-directory>./data/bindings</bindings-directory>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-clustered-cpp/src/main/resources/activemq/server1/broker.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-clustered-cpp/src/main/resources/activemq/server1/broker.xml b/examples/protocols/amqp/proton-clustered-cpp/src/main/resources/activemq/server1/broker.xml
index 115f28c..bad1eb8 100644
--- a/examples/protocols/amqp/proton-clustered-cpp/src/main/resources/activemq/server1/broker.xml
+++ b/examples/protocols/amqp/proton-clustered-cpp/src/main/resources/activemq/server1/broker.xml
@@ -17,10 +17,7 @@ KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
-->
-<configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="urn:activemq /schema/artemis-server.xsd">
-
-
+<configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
<core xmlns="urn:activemq:core">
<bindings-directory>./data/bindings</bindings-directory>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-cpp/pom.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-cpp/pom.xml b/examples/protocols/amqp/proton-cpp/pom.xml
index d2f0aef..2bfffbd 100644
--- a/examples/protocols/amqp/proton-cpp/pom.xml
+++ b/examples/protocols/amqp/proton-cpp/pom.xml
@@ -111,7 +111,23 @@ under the License.
</dependency>
</dependencies>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
</plugins>
</build>
-
-</project>
+ <profiles>
+ <profile>
+ <id>release</id>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-cpp/readme.html
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-cpp/readme.html b/examples/protocols/amqp/proton-cpp/readme.html
deleted file mode 100644
index ba9e635..0000000
--- a/examples/protocols/amqp/proton-cpp/readme.html
+++ /dev/null
@@ -1,120 +0,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.
--->
-
-<html>
-<head>
- <title>ActiveMQ Artemis QPID cpp 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>
-</head>
-<body onload="prettyPrint()">
-<h1>AMQP CPP example</h1>
-
-<p>ActiveMQ Artemis is a multi protocol broker. It will inspect the initial handshake of clients to determine what protocol to use.</p>
-<p>All you need to do is to connect a client into activemq's configured port and you should be able connect.</p>
-<p>To run this example simply run the command <literal>mvn verify -Pexample</literal>, execute the compile.sh script and start the executable called ./hello</p>
-<pre>
- # first make sure you have the dependencies you need to compile and run the client
- # You will have to adapt this step according to your platform. Consult the <a href="http://qpid.apache.org/releases/qpid-0.30/programming/book/">qpid docs</a> for more information.
- # There is a list of <a href="http://qpid.apache.org/packages.html">packages</a> you can install as well.
- [proton-cpp]$ sudo yum install qpid-cpp-client-devel
-
- # on a first window
- [proton-cpp]$ mvn verify -Pexample
-
- # on a second window
- # That goes without saying but you will of course need g++ (the C++ compiler) installed
- [proton-cpp]$ ./compile.sh
- [proton-cpp]$ ./hello
-</pre>
-
-
-<p>You don't need to do anything special to configure the ActiveMQ Artemis server to accept AMQP clients. </p>
-<p>Just for the sake of documentation though we are setting the port of ActiveMQ Artemis on this example as 5672 which is the port qpid have by default. </p>
-<p>This is totally optional and you don't need to follow this convention. You can use any port you chose including ActiveMQ's 61616 default port</p>
- <pre class="prettyprint">
- <code>
- <acceptor name="proton-acceptor">tcp://localhost:5672</acceptor>
- </code>
- </pre>
-<h2>Example step-by-step</h2>
-<p> We are using qpid cpp client on this example. There are several libraries you may chose from for AMQP. We have ellect one that we consider simple enough for users.</p>
-
-<p> This example is based on <a href='http://qpid.apache.org/releases/qpid-0.30/messaging-api/cpp/examples/hello_world.cpp.html'>qpid's hello world example</a>.</p>
-<ol>
- <li>qpid-cpp-client-devel installed.</li>
- <p>Assuming you are on Linux Fedora, you will need to run this following command</p>
- <pre class="prettyprint">
- <code>yum install qpid-cpp-client-devel</code>
- </pre>
- <p>Consult the <a href="http://qpid.apache.org/releases/qpid-0.30/programming/book/">qpid documentation</a>, and <a href="http://qpid.apache.org/packages.html">the required </a> packages for information on other platoforms.</p>
- <li>Make the proper C++ imports</li>
-
- <li> Create an amqp qpid 1.0 connection.</li>
- <pre class="prettyprint">
- <code>
- std::string broker = argc > 1 ? argv[1] : "localhost:61616";
- std::string address = argc > 2 ? argv[2] : "jms.queue.exampleQueue";
- std::string connectionOptions = argc > 3 ? argv[3] : "{protocol:amqp1.0}"; // Look at the <a href="http://qpid.apache.org/releases/qpid-0.30/programming/book/connections.html#connection-options">docs</a> for more options
-
- Connection connection(broker, connectionOptions);
- connection.open();
- </code>
- </pre>
-
- <li>Create a session</li>
- <pre class="prettyprint">
- <code>Session session = connection.createSession();</code>
- </pre>
-
- <li>Create a sender</li>
- <pre class="prettyprint">
- <code>Sender sender = session.createSender(address);</code>
- </pre>
-
- <li>send a simple message</li>
- <pre class="prettyprint">
- <code>sender.send(Message("Hello world!"));</code>
- </pre>
-
- <li>create a receiver</li>
- <pre class="prettyprint">
- <code>Receiver receiver = session.createReceiver(address);</code>
- </pre>
-
- <li>receive the simple message</li>
- <pre class="prettyprint">
- <code>Message message = receiver.fetch(Duration::SECOND * 1);
- </code>
- </pre>
-
- <li>acknowledge the message</li>
- <pre class="prettyprint">
- <code>session.acknowledge();</code>
- </pre>
-
- <li>close the connection</li>
- <pre class="prettyprint">
- <code>connection.close();</code>
- </pre>
-</ol>
-
-</body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-cpp/readme.md
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-cpp/readme.md b/examples/protocols/amqp/proton-cpp/readme.md
new file mode 100644
index 0000000..2acf171
--- /dev/null
+++ b/examples/protocols/amqp/proton-cpp/readme.md
@@ -0,0 +1,80 @@
+# AMQP CPP example
+
+ActiveMQ Artemis is a multi protocol broker. It will inspect the initial handshake of clients to determine what protocol to use.
+
+All you need to do is to connect a client into ActiveMQ's configured port and you should be able connect.
+
+To run this example simply run the command **mvn verify -Pexample**, execute the compile.sh script and start the executable called ./hello
+
+ # first make sure you have the dependencies you need to compile and run the client
+ # You will have to adapt this step according to your platform. Consult the [qpid docs](http://qpid.apache.org/releases/qpid-0.30/programming/book/) for more information.
+ # There is a list of [packages](http://qpid.apache.org/packages.html) you can install as well.
+ [proton-cpp]$ sudo yum install qpid-cpp-client-devel
+
+ # on a first window
+ [proton-cpp]$ mvn verify -Pexample
+
+ # on a second window
+ # That goes without saying but you will of course need g++ (the C++ compiler) installed
+ [proton-cpp]$ ./compile.sh
+ [proton-cpp]$ ./hello
+
+You don't need to do anything special to configure the ActiveMQ Artemis broker to accept AMQP clients.
+
+Just for the sake of documentation though we are setting the port of ActiveMQ Artemis on this example as 5672 which is the port qpid have by default.
+
+This is totally optional and you don't need to follow this convention. You can use any port you chose including ActiveMQ's 61616 default port:
+
+ <acceptor name="proton-acceptor">tcp://localhost:5672</acceptor>
+
+## Example step-by-step
+
+We are using qpid cpp client on this example. There are several libraries you may chose from for AMQP. We have ellect one that we consider simple enough for users.
+
+This example is based on [qpid's hello world example](http://qpid.apache.org/releases/qpid-0.30/messaging-api/cpp/examples/hello_world.cpp.html).
+
+1. qpid-cpp-client-devel installed.
+
+Assuming you are on Linux Fedora, you will need to run this following command
+
+ yum install qpid-cpp-client-devel
+
+Consult the [qpid documentation](http://qpid.apache.org/releases/qpid-0.30/programming/book/), and [the required](http://qpid.apache.org/packages.html) packages for information on other platoforms.
+
+5. Make the proper C++ imports
+6. Create an amqp qpid 1.0 connection.
+
+ std::string broker = argc > 1 ? argv[1] : "localhost:61616";
+ std::string address = argc > 2 ? argv[2] : "jms.queue.exampleQueue";
+ std::string connectionOptions = argc > 3 ? argv[3] : "{protocol:amqp1.0}"; // Look at the [docs](http://qpid.apache.org/releases/qpid-0.30/programming/book/connections.html#connection-options) for more options
+
+ Connection connection(broker, connectionOptions);
+ connection.open();
+
+8. Create a session
+
+ Session session = connection.createSession();
+
+10. Create a sender
+
+ Sender sender = session.createSender(address);
+
+12. send a simple message
+
+ sender.send(Message("Hello world!"));
+
+14. create a receiver
+
+ Receiver receiver = session.createReceiver(address);
+
+16. receive the simple message
+
+ Message message = receiver.fetch(Duration::SECOND * 1);
+
+18. acknowledge the message
+
+ session.acknowledge();
+
+20. close the connection
+
+ connection.close();
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-cpp/src/main/java/org/apache/activemq/artemis/jms/example/ProtonCPPExample.java
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-cpp/src/main/java/org/apache/activemq/artemis/jms/example/ProtonCPPExample.java b/examples/protocols/amqp/proton-cpp/src/main/java/org/apache/activemq/artemis/jms/example/ProtonCPPExample.java
index 961a56b..d8de751 100644
--- a/examples/protocols/amqp/proton-cpp/src/main/java/org/apache/activemq/artemis/jms/example/ProtonCPPExample.java
+++ b/examples/protocols/amqp/proton-cpp/src/main/java/org/apache/activemq/artemis/jms/example/ProtonCPPExample.java
@@ -31,7 +31,7 @@ import org.apache.qpid.jms.JmsConnectionFactory;
* This example demonstrates the use of ActiveMQ Artemis "pre-acknowledge" functionality where
* messages are acknowledged before they are delivered to the consumer.
* <p>
- * Please see the readme.html for more details.
+ * Please see the readme for more details.
*/
public class ProtonCPPExample {
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-ruby/pom.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-ruby/pom.xml b/examples/protocols/amqp/proton-ruby/pom.xml
index 676355f..9b2efbf 100644
--- a/examples/protocols/amqp/proton-ruby/pom.xml
+++ b/examples/protocols/amqp/proton-ruby/pom.xml
@@ -60,7 +60,23 @@ under the License.
</dependency>
</dependencies>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
</plugins>
</build>
-
-</project>
+ <profiles>
+ <profile>
+ <id>release</id>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-ruby/readme.html
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-ruby/readme.html b/examples/protocols/amqp/proton-ruby/readme.html
deleted file mode 100644
index f7f83fb..0000000
--- a/examples/protocols/amqp/proton-ruby/readme.html
+++ /dev/null
@@ -1,51 +0,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.
--->
-
-<html>
- <head>
- <title>ActiveMQ Artemis Proton Ruby 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>
- </head>
- <body onload="prettyPrint()">
- <h1>Proton Ruby Example</h1>
-
- <p>ActiveMQ Artemis can be configured to accept requests from any AMQP client that supports the 1.0 version of the protocol.
- This example shows a simply proton ruby client that sends and receives messages</p>
- <p>To run the example you will need the following packages installed, alsa-lib.i686 libXv.i686 libXScrnSaver.i686 qt.i686 qt-x11.i686 qtwebkit-2.2.2-2.fc18.i686, gcc, ruby</p>
- <p>On fedora you can install these via the <literal>yum install alsa-lib.i686 libXv.i686 libXScrnSaver.i686 qt.i686 qt-x11.i686 qtwebkit-2.2.2-2.fc18.i686, gcc, ruby</literal>
- command</p>
- <p>you will also need the qpid-proton libraries installed, again <literal>yum install qpid-proton</literal></p>
- <p>lastly you wull have to create the gems <literal>gem install qpid_proton</literal></p>
-
- <p>To configure ActiveMQ Artemis to accept AMQP client connections you need to add an Acceptor like so:</p>
- <pre class="prettyprint">
- <code>
- <acceptor name="proton-acceptor">tcp://localhost:5672?protocols=AMQP</acceptor>
- </code>
- </pre>
- <h2>Example step-by-step</h2>
- <p>Firstly create the server by running the command <literal>mvn verify</literal></p>
- <p>Start the server manually under ./target/server1/bin by calling ./artemis run</p>
- <p>Then in a separate window you can run the send ruby script by running the command <literal>ruby src/main/scripts/send.rb</literal></p>
- <p>You can then receive the message via the receive ruby script by running <literal>ruby src/main/scripts/receive.rb</literal></p>
-
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-ruby/readme.md
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-ruby/readme.md b/examples/protocols/amqp/proton-ruby/readme.md
new file mode 100644
index 0000000..8e01056
--- /dev/null
+++ b/examples/protocols/amqp/proton-ruby/readme.md
@@ -0,0 +1,25 @@
+# Proton Ruby Example
+
+ActiveMQ Artemis can be configured to accept requests from any AMQP client that supports the 1.0 version of the protocol. This example shows a simply proton ruby client that sends and receives messages.
+
+To run the example you will need the following packages installed, alsa-lib.i686 libXv.i686 libXScrnSaver.i686 qt.i686 qt-x11.i686 qtwebkit-2.2.2-2.fc18.i686, gcc, ruby.
+
+On fedora you can install these via the `yum install alsa-lib.i686 libXv.i686 libXScrnSaver.i686 qt.i686 qt-x11.i686 qtwebkit-2.2.2-2.fc18.i686, gcc, ruby` command.
+
+you will also need the qpid-proton libraries installed, again `yum install qpid-proton`.
+
+lastly you wull have to create the gems `gem install qpid_proton`.
+
+To configure ActiveMQ Artemis to accept AMQP client connections you need to add an Acceptor like so:
+
+ <acceptor name="proton-acceptor">tcp://localhost:5672?protocols=AMQP</acceptor>
+
+## Example step-by-step
+
+Firstly create the broker by running the command **mvn verify**.
+
+Start the broker manually under ./target/server1/bin by calling `./artemis run`.
+
+Then in a separate window you can run the send ruby script by running the command `ruby src/main/scripts/send.rb`.
+
+You can then receive the message via the receive ruby script by running `ruby src/main/scripts/receive.rb`.
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/proton-ruby/src/main/resources/activemq/server0/broker.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/proton-ruby/src/main/resources/activemq/server0/broker.xml b/examples/protocols/amqp/proton-ruby/src/main/resources/activemq/server0/broker.xml
index 50f0a67..c759bc5 100644
--- a/examples/protocols/amqp/proton-ruby/src/main/resources/activemq/server0/broker.xml
+++ b/examples/protocols/amqp/proton-ruby/src/main/resources/activemq/server0/broker.xml
@@ -16,10 +16,8 @@ software distributed under the License is distributed on an
KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
---><configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-server.xsd">
-
-
-
+-->
+<configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
<core xmlns="urn:activemq:core">
<bindings-directory>${data.dir}/server0/data/messaging/bindings</bindings-directory>
@@ -50,7 +48,7 @@ under the License.
</security-setting>
</security-settings>
- <addresses>
+ <addresses>
<address name="testQueue">
<multicast>
<queue name="testQueue"/>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/queue/pom.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/queue/pom.xml b/examples/protocols/amqp/queue/pom.xml
index b897f4b..5889529 100644
--- a/examples/protocols/amqp/queue/pom.xml
+++ b/examples/protocols/amqp/queue/pom.xml
@@ -102,7 +102,23 @@ under the License.
</dependency>
</dependencies>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
</plugins>
</build>
-
-</project>
+ <profiles>
+ <profile>
+ <id>release</id>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/queue/readme.html
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/queue/readme.html b/examples/protocols/amqp/queue/readme.html
deleted file mode 100644
index 4eb1f0c..0000000
--- a/examples/protocols/amqp/queue/readme.html
+++ /dev/null
@@ -1,46 +0,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.
--->
-
-<html>
-<head>
- <title>ActiveMQ Artemis QPID java 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>
-</head>
-<body onload="prettyPrint()">
-<h1>Proton qpid java example</h1>
-
-<pre>To run the example, simply type <b>mvn verify</b> from this directory, <br>or <b>mvn -PnoServer verify</b> if you want to start and create the server manually.</pre>
-
-
-<<p>ActiveMQ Artemis is a multi protocol broker. It will inspect the initial handshake of clients to determine what protocol to use.</p>
-<p>All you need to do is to connect a client into activemq's configured port and you should be able connect.</p>
-<p>To run this example simply run the command <literal>mvn verify -Pexample</literal>, execute the compile.sh script and start the executable called ./hello</p>
-
-<p>You don't need to do anything special to configure the ActiveMQ Artemis server to accept AMQP clients. </p>
-<p>Just for the sake of documentation though we are setting the port of ActiveMQ Artemis on this example as 5672 which is the port qpid have by default. </p>
-<p>This is totally optional and you don't need to follow this convention. You can use any port you chose including ActiveMQ's 61616 default port</p>
- <pre class="prettyprint">
- <code>
- <acceptor name="proton-acceptor">tcp://localhost:5672</acceptor>
- </code>
- </pre>
-</body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/amqp/queue/readme.md
----------------------------------------------------------------------
diff --git a/examples/protocols/amqp/queue/readme.md b/examples/protocols/amqp/queue/readme.md
new file mode 100644
index 0000000..9b34e7e
--- /dev/null
+++ b/examples/protocols/amqp/queue/readme.md
@@ -0,0 +1,17 @@
+# Proton qpid java example
+
+To run the example, simply type **mvn verify** from this directory, or **mvn -PnoServer verify** if you want to start and create the broker manually.
+
+ActiveMQ Artemis is a multi protocol broker. It will inspect the initial handshake of clients to determine what protocol to use.
+
+All you need to do is to connect a client into activemq's configured port and you should be able connect.
+
+To run this example simply run the command **mvn verify -Pexample**, execute the `compile.sh` script and start the executable called `./hello`.
+
+You don't need to do anything special to configure the ActiveMQ Artemis broker to accept AMQP clients.
+
+Just for the sake of documentation though we are setting the port of ActiveMQ Artemis on this example as 5672 which is the port qpid have by default.
+
+This is totally optional and you don't need to follow this convention. You can use any port you chose including ActiveMQ's 61616 default port
+
+ <acceptor name="proton-acceptor">tcp://localhost:5672</acceptor>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/mqtt/basic-pubsub/pom.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/mqtt/basic-pubsub/pom.xml b/examples/protocols/mqtt/basic-pubsub/pom.xml
index 05252fb..73671b4 100644
--- a/examples/protocols/mqtt/basic-pubsub/pom.xml
+++ b/examples/protocols/mqtt/basic-pubsub/pom.xml
@@ -99,7 +99,23 @@ under the License.
</dependency>
</dependencies>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
</plugins>
</build>
-
-</project>
+ <profiles>
+ <profile>
+ <id>release</id>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/mqtt/basic-pubsub/readme.html
----------------------------------------------------------------------
diff --git a/examples/protocols/mqtt/basic-pubsub/readme.html b/examples/protocols/mqtt/basic-pubsub/readme.html
deleted file mode 100644
index ca7dbff..0000000
--- a/examples/protocols/mqtt/basic-pubsub/readme.html
+++ /dev/null
@@ -1,136 +0,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.
--->
-
-<html>
- <head>
- <title>ActiveMQ Artemis MQTT 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>
- </head>
- <body onload="prettyPrint()">
- <h1>MQTT Example</h1>
-
- <p>This is a basic MQTT example that demonstrates how to setup and connect to an Apache Artemis broker and
- send and receive messages using the MQTT protocol.</p>
-
- <h2>Setting up the server</h2>
-
- <p>This example will use the default out of the box configuration of Artemis you don't need to change anything to run
- this example. Artemis ships with all protocols enabled on port 61616 and also MQTT on port 1883. To enable MQTT
- on a different port you can add the following XML snippet to the 'acceptors' section of your broker.xml
- configuration file (changing the port from 1883 to what ever you require).</p>
-
-
- <pre class="prettyprint">
- <!-- Escaped: <acceptor name="hornetq">tcp://0.0.0.0:1883?protocols=MQTT"></acceptor> -->
- <acceptor name="hornetq">tcp://0.0.0.0:1883?protocols=MQTT"></acceptor>
- </pre>
-
- For more information on configuring protocol transports see the "Configuring Transports" section of the user
- manual, specifically the section called "Single Port Support".
-
- <h2>MQTT Clients</h2>
-
- <p>There are a number of MQTT client implementations for various languages. The Paho project:
- http://www.eclipse.org/paho/ offers a number of clients for languages such as C, Python, JavaScript and .Net and
- is also a great resource for all things MQTT.
-
- This example is actually based on the Fuse MQTT java client and was chosen as it is Apache 2.0 licensed and
- available to download from maven central. The specific client used in the example is not of importance and is
- used simply to demonstrate the features of MQTT as provided by Apache Artemis.</p>
-
- <p>If you'd like to use the client demonstrated in this example, simple add the following dependency to your
- pom.xml</p>
-
- <pre class="prettyprint">
- <dependency>
- <groupId>org.fusesource.mqtt-client</groupId>
- <artifactId>mqtt-client</artifactId>
- <version>1.10</version>
- </dependency>
- </pre>
-
- <h2>Example Step by Step</h2>
-
- <o1>
- <li>1. Connect to Artemis</li>
-
- <p>We start by creating a connection to the Apache Artemis broker. In this example we specify to use TCP
- protocol on localhost. By default Apache Artemis will start all protocols on port 61616, so we connect
- to that port.</p>
-
- <pre class="prettyprint">
- MQTT mqtt = new MQTT();
- mqtt.setHost("tcp://localhost:61616");
- BlockingConnection connection = mqtt.blockingConnection();
- connection.connect();
- </pre>
-
- <li>2. Create subscriptions</li>
-
- <p>Subscriptions in MQTT are realised by subscribing to a particular Topic. Each Topic has an address
- and a quality of service level (QoS level). Subscriptions also support wildcards. In the code below we
- subscribe to a Topic with address "mqtt/example/publish", a wildcard address "test/#" which will
- match anything starting with "test/" and also a wildcard "foo/+/bar", where + matches a single level of the hierarchy (foo/something/bar)</p>
-
- <pre class="prettyprint">
- Topic[] topics = { new Topic("mqtt/example/publish", QoS.AT_LEAST_ONCE), new Topic("test/#", QoS.EXACTLY_ONCE), new Topic("foo/+/bar", QoS.AT_LEAST_ONCE) };
- connection.subscribe(topics);
- </pre>
-
- <li>3. Sending messages</li>
-
- <p>There is no type system in MQTT, messages simply consist of a number of bytes. Below we send three messages with
- UTF8 encoded strings (as a byte array). Notice the second message is sent to "test/test" which should match
- the first wildcard subscription we defined previously. The third message is sent to "foo/1/bar", which matches the second wildcard subscription.</p>
-
- <pre class="prettyprint">
- String payload1 = "This is message 1";
- String payload2 = "This is message 2";
- String payload3 = "This is message 3";
-
- connection.publish("mqtt/example/publish", payload1.getBytes(), QoS.AT_LEAST_ONCE, false);
- connection.publish("mqtt/test", payload2.getBytes(), QoS.AT_MOST_ONCE, false);
- connection.publish("foo/1/bar", payload3.getBytes(), QoS.AT_MOST_ONCE, false);
- </pre>
-
- <li>4. Receiving messages</li>
-
- <p>Since we have subscribed to a number of topics and sent messages to them, the client should now receive
- 2 messages. We are not using callbacks here on message receive so we specifically call receive to get
- the messages. Once we receive the message we convert the payload consisting of bytes back to a UTF8
- encoded string and print the result.</p>
-
- <pre class="prettyprint">
- Message message1 = connection.receive(5, TimeUnit.SECONDS);
- Message message2 = connection.receive(5, TimeUnit.SECONDS);
- Message message3 = connection.receive(5, TimeUnit.SECONDS);
-
- System.out.println(new String(message1.getPayload()));
- System.out.println(new String(message2.getPayload()));
- System.out.println(new String(message3.getPayload()));
- </pre>
- </o1>
-
- <h2>Result</h2>
- This example has shown you how to set up the basics of MQTT including how to connect to the Artemis broker and
- how to send and receive messages including subscriptions using wildcard addresses.
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/mqtt/basic-pubsub/readme.md
----------------------------------------------------------------------
diff --git a/examples/protocols/mqtt/basic-pubsub/readme.md b/examples/protocols/mqtt/basic-pubsub/readme.md
new file mode 100644
index 0000000..b7ea993
--- /dev/null
+++ b/examples/protocols/mqtt/basic-pubsub/readme.md
@@ -0,0 +1,69 @@
+# MQTT Example
+
+This is a basic MQTT example that demonstrates how to setup and connect to an Apache Artemis broker and send and receive messages using the MQTT protocol.
+
+## Setting up the Broker
+
+This example will use the default out of the box configuration of Artemis you don't need to change anything to run this example. Artemis ships with all protocols enabled on port 61616 and also MQTT on port 1883. To enable MQTT on a different port you can add the following XML snippet to the `acceptors` section of your broker.xml configuration file (changing the port from 1883 to what ever you require).
+
+ <acceptor name="mqtt">tcp://0.0.0.0:1883?protocols=MQTT"></acceptor>
+
+For more information on configuring protocol transports see the "Configuring Transports" section of the user manual, specifically the section called "Single Port Support".
+
+## MQTT Clients
+
+There are a number of MQTT client implementations for various languages. The Paho project: http://www.eclipse.org/paho/ offers a number of clients for languages such as C, Python, JavaScript and .Net and is also a great resource for all things MQTT. This example is actually based on the Fuse MQTT java client and was chosen as it is Apache 2.0 licensed and available to download from maven central. The specific client used in the example is not of importance and is used simply to demonstrate the features of MQTT as provided by Apache Artemis.
+
+If you'd like to use the client demonstrated in this example, simple add the following dependency to your pom.xml
+
+ <dependency>
+ <groupId>org.fusesource.mqtt-client</groupId>
+ <artifactId>mqtt-client</artifactId>
+ <version>1.10</version>
+ </dependency>
+
+## Example Step by Step
+
+* Connect to Artemis
+
+We start by creating a connection to the Apache Artemis broker. In this example we specify to use TCP protocol on localhost. By default Apache Artemis will start all protocols on port 61616, so we connect to that port.
+
+ MQTT mqtt = new MQTT();
+ mqtt.setHost("tcp://localhost:61616");
+ BlockingConnection connection = mqtt.blockingConnection();
+ connection.connect();
+
+* Create subscriptions
+
+Subscriptions in MQTT are realised by subscribing to a particular Topic. Each Topic has an address and a quality of service level (QoS level). Subscriptions also support wildcards. In the code below we subscribe to a Topic with address "mqtt/example/publish", a wildcard address "test/#" which will match anything starting with "test/" and also a wildcard "foo/+/bar", where + matches a single level of the hierarchy (foo/something/bar)
+
+ Topic[] topics = { new Topic("mqtt/example/publish", QoS.AT_LEAST_ONCE), new Topic("test/#", QoS.EXACTLY_ONCE), new Topic("foo/+/bar", QoS.AT_LEAST_ONCE) };
+ connection.subscribe(topics);
+
+* Sending messages
+
+There is no type system in MQTT, messages simply consist of a number of bytes. Below we send three messages with UTF8 encoded strings (as a byte array). Notice the second message is sent to "test/test" which should match the first wildcard subscription we defined previously. The third message is sent to "foo/1/bar", which matches the second wildcard subscription.
+
+ String payload1 = "This is message 1";
+ String payload2 = "This is message 2";
+ String payload3 = "This is message 3";
+
+ connection.publish("mqtt/example/publish", payload1.getBytes(), QoS.AT_LEAST_ONCE, false);
+ connection.publish("mqtt/test", payload2.getBytes(), QoS.AT_MOST_ONCE, false);
+ connection.publish("foo/1/bar", payload3.getBytes(), QoS.AT_MOST_ONCE, false);
+
+* Receiving messages
+
+Since we have subscribed to a number of topics and sent messages to them, the client should now receive 2 messages. We are not using callbacks here on message receive so we specifically call receive to get the messages. Once we receive the message we convert the payload consisting of bytes back to a UTF8 encoded string and print the result.
+
+ Message message1 = connection.receive(5, TimeUnit.SECONDS);
+ Message message2 = connection.receive(5, TimeUnit.SECONDS);
+ Message message3 = connection.receive(5, TimeUnit.SECONDS);
+
+ System.out.println(new String(message1.getPayload()));
+ System.out.println(new String(message2.getPayload()));
+ System.out.println(new String(message3.getPayload()));
+
+## Result
+
+This example has shown you how to set up the basics of MQTT including how to connect to the Artemis broker and how to send and receive messages including subscriptions using wildcard addresses.
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/mqtt/clustered-queue-mqtt/pom.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/mqtt/clustered-queue-mqtt/pom.xml b/examples/protocols/mqtt/clustered-queue-mqtt/pom.xml
index 6deacc0..374d703 100644
--- a/examples/protocols/mqtt/clustered-queue-mqtt/pom.xml
+++ b/examples/protocols/mqtt/clustered-queue-mqtt/pom.xml
@@ -155,7 +155,23 @@ under the License.
</dependency>
</dependencies>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
</plugins>
</build>
-
-</project>
+ <profiles>
+ <profile>
+ <id>release</id>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/mqtt/clustered-queue-mqtt/readme.html
----------------------------------------------------------------------
diff --git a/examples/protocols/mqtt/clustered-queue-mqtt/readme.html b/examples/protocols/mqtt/clustered-queue-mqtt/readme.html
deleted file mode 100644
index a39fc4c..0000000
--- a/examples/protocols/mqtt/clustered-queue-mqtt/readme.html
+++ /dev/null
@@ -1,55 +0,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.
--->
-
-<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>
- </head>
- <body onload="prettyPrint()">
- <h1>JMS Load Balanced Clustered Queue Example</h1>
-
- <pre>To run the example, simply type <b>mvn verify</b> from this directory, <br>or <b>mvn -PnoServer verify</b> if you want to start and create the server manually.</pre>
-
- <p>This example demonstrates a JMS queue deployed on two different nodes. The two nodes are configured to form a cluster.</p>
- <p>We then create a consumer on the queue on each node, and we create a producer on only one of the nodes.</p>
- <p>We then send some messages via the producer, and we verify that <b>both</b> consumers receive the sent messages
- in a round-robin fashion.</p>
- <p>In other words, ActiveMQ Artemis <b>load balances</b> the sent messages across all consumers on the cluster</p>
- <p>This example uses JNDI to lookup the JMS Queue and ConnectionFactory objects. If you prefer not to use
- JNDI, these could be instantiated directly.</p>
- <p>Here's the relevant snippet from the server configuration, which tells the server to form a cluster between the two nodes
- and to load balance the messages between the nodes.</p>
- <pre class="prettyprint">
- <code><cluster-connection name="my-cluster">
- <connector-ref>netty-connector</connector-ref>
- <retry-interval>500</retry-interval>
- <use-duplicate-detection>true</use-duplicate-detection>
- <message-load-balancing>STRICT</message-load-balancing>
- <max-hops>1</max-hops>
- <discovery-group-ref discovery-group-name="my-discovery-group"/>
- </cluster-connection>
- </code>
- </pre>
- <p>For more information on ActiveMQ Artemis load balancing, and clustering in general, please see the clustering
- section of the user manual.</p>
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/mqtt/clustered-queue-mqtt/readme.md
----------------------------------------------------------------------
diff --git a/examples/protocols/mqtt/clustered-queue-mqtt/readme.md b/examples/protocols/mqtt/clustered-queue-mqtt/readme.md
new file mode 100644
index 0000000..eb714f9
--- /dev/null
+++ b/examples/protocols/mqtt/clustered-queue-mqtt/readme.md
@@ -0,0 +1,11 @@
+# MQTT Clustered Subscription Example
+
+To run the example, simply type **mvn verify** from this directory, or **mvn -PnoServer verify** if you want to start and create the broker manually.
+
+This example demonstrates a queue deployed on two different nodes. The two nodes are configured to form a cluster.
+
+We then create an MQTT subscriber on the queue on each node, and we create a producer on only one of the nodes.
+
+We then send some messages via the producer, and we verify that **both** subscribers receive the sent messages.
+
+For more information on ActiveMQ Artemis clustering please see the clustering section of the user manual.
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/mqtt/clustered-queue-mqtt/src/main/java/org/apache/activemq/artemis/jms/example/ClusteredQueueMQTTExample.java
----------------------------------------------------------------------
diff --git a/examples/protocols/mqtt/clustered-queue-mqtt/src/main/java/org/apache/activemq/artemis/jms/example/ClusteredQueueMQTTExample.java b/examples/protocols/mqtt/clustered-queue-mqtt/src/main/java/org/apache/activemq/artemis/jms/example/ClusteredQueueMQTTExample.java
index 0f60ac3..51845ac 100644
--- a/examples/protocols/mqtt/clustered-queue-mqtt/src/main/java/org/apache/activemq/artemis/jms/example/ClusteredQueueMQTTExample.java
+++ b/examples/protocols/mqtt/clustered-queue-mqtt/src/main/java/org/apache/activemq/artemis/jms/example/ClusteredQueueMQTTExample.java
@@ -24,8 +24,7 @@ import org.fusesource.mqtt.client.QoS;
import org.fusesource.mqtt.client.Topic;
/**
- * A simple example that demonstrates server side load-balancing of messages between the queue instances on different
- * nodes of the cluster.
+ * A simple example that demonstrates an MQTT subscription on different nodes of the cluster.
*/
public class ClusteredQueueMQTTExample {
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/mqtt/clustered-queue-mqtt/src/main/resources/activemq/server0/broker.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/mqtt/clustered-queue-mqtt/src/main/resources/activemq/server0/broker.xml b/examples/protocols/mqtt/clustered-queue-mqtt/src/main/resources/activemq/server0/broker.xml
index bc43659..c643627 100644
--- a/examples/protocols/mqtt/clustered-queue-mqtt/src/main/resources/activemq/server0/broker.xml
+++ b/examples/protocols/mqtt/clustered-queue-mqtt/src/main/resources/activemq/server0/broker.xml
@@ -17,7 +17,7 @@ KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
-->
-<configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-server.xsd">
+<configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
<core xmlns="urn:activemq:core">
<security-enabled>false</security-enabled>
@@ -60,7 +60,6 @@ under the License.
<cluster-connections>
<cluster-connection name="my-cluster">
- <!-- <address>test/+/some/#</address> -->
<connector-ref>netty-connector</connector-ref>
<retry-interval>5</retry-interval>
<use-duplicate-detection>true</use-duplicate-detection>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/mqtt/clustered-queue-mqtt/src/main/resources/activemq/server1/broker.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/mqtt/clustered-queue-mqtt/src/main/resources/activemq/server1/broker.xml b/examples/protocols/mqtt/clustered-queue-mqtt/src/main/resources/activemq/server1/broker.xml
index 6b386da..9ffcc73 100644
--- a/examples/protocols/mqtt/clustered-queue-mqtt/src/main/resources/activemq/server1/broker.xml
+++ b/examples/protocols/mqtt/clustered-queue-mqtt/src/main/resources/activemq/server1/broker.xml
@@ -17,7 +17,7 @@ KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
-->
-<configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-server.xsd">
+<configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
<core xmlns="urn:activemq:core">
<security-enabled>false</security-enabled>
@@ -60,7 +60,6 @@ under the License.
<cluster-connections>
<cluster-connection name="my-cluster">
- <!-- <address>test/+/some/#</address> -->
<connector-ref>netty-connector</connector-ref>
<retry-interval>5</retry-interval>
<use-duplicate-detection>true</use-duplicate-detection>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/openwire/chat/pom.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/openwire/chat/pom.xml b/examples/protocols/openwire/chat/pom.xml
index 382ebd0..34b0b5a 100644
--- a/examples/protocols/openwire/chat/pom.xml
+++ b/examples/protocols/openwire/chat/pom.xml
@@ -56,6 +56,16 @@ under the License.
<artifactId>slf4j-nop</artifactId>
</dependency>
</dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+
<profiles>
<profile>
<id>server</id>
@@ -194,6 +204,17 @@ under the License.
</plugins>
</build>
</profile>
+ <profile>
+ <id>release</id>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
</profiles>
</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/openwire/chat/readme.html
----------------------------------------------------------------------
diff --git a/examples/protocols/openwire/chat/readme.html b/examples/protocols/openwire/chat/readme.html
deleted file mode 100644
index 9cd72a4..0000000
--- a/examples/protocols/openwire/chat/readme.html
+++ /dev/null
@@ -1,53 +0,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.
--->
-
-<html>
- <head>
- <title>ActiveMQ Artemis Openwire Chat 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>
- </head>
- <body onload="prettyPrint()">
- <h1>Openwire Chat Example</h1>
-
- <p>This example will require multiple windows to be executed</p>
-
- <pre>Window 1: mvn -Pserver verify</pre>
- <pre>Window 2: mvn -Pchat1 verify</pre>
- <pre>Window 3: mvn -Pchat2 verify</pre>
- <pre>Window 4: mvn -Pchat3 verify</pre>
-
-
- <p>You should be able to interact with the chat application:</p>
-
- <pre>
-Chat application:
-=================
-The application user Chatter2 connects to the broker at tcp://localhost:61616.
-The application will publish messages to the jms.samples.chat topic.
-The application also subscribes to that topic to consume any messages published there.
-
-Type some text, and then press Enter to publish it as a TextMesssage from Chatter2.
-
-Hello guys
-Chatter2: Hello guys
-</pre>
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/openwire/chat/readme.md
----------------------------------------------------------------------
diff --git a/examples/protocols/openwire/chat/readme.md b/examples/protocols/openwire/chat/readme.md
new file mode 100644
index 0000000..42bf00e
--- /dev/null
+++ b/examples/protocols/openwire/chat/readme.md
@@ -0,0 +1,33 @@
+# Openwire Chat Example
+
+This example will require multiple windows to be executed
+
+Window 1:
+
+ mvn -Pserver verify
+
+Window 2:
+
+ mvn -Pchat1 verify
+
+Window 3:
+
+ mvn -Pchat2 verify
+
+Window 4:
+
+ mvn -Pchat3 verify
+
+You should be able to interact with the chat application:
+
+## Chat application:
+The application user Chatter2 connects to the broker at `tcp://localhost:61616`.
+
+The application will publish messages to the `chat` address.
+
+The application also subscribes to that topic to consume any messages published there.
+
+Type some text, and then press Enter to publish it as a TextMesssage from Chatter2.
+
+ Hello guys
+ Chatter2: Hello guys
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/openwire/message-listener/pom.xml
----------------------------------------------------------------------
diff --git a/examples/protocols/openwire/message-listener/pom.xml b/examples/protocols/openwire/message-listener/pom.xml
index 7e695f8..db947f4 100644
--- a/examples/protocols/openwire/message-listener/pom.xml
+++ b/examples/protocols/openwire/message-listener/pom.xml
@@ -108,7 +108,23 @@ under the License.
</dependency>
</dependencies>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
</plugins>
</build>
-
-</project>
+ <profiles>
+ <profile>
+ <id>release</id>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>com.vladsch.flexmark</groupId>
+ <artifactId>markdown-page-generator-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/openwire/message-listener/readme.html
----------------------------------------------------------------------
diff --git a/examples/protocols/openwire/message-listener/readme.html b/examples/protocols/openwire/message-listener/readme.html
deleted file mode 100644
index e46e834..0000000
--- a/examples/protocols/openwire/message-listener/readme.html
+++ /dev/null
@@ -1,35 +0,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.
--->
-
-<html>
- <head>
- <title>ActiveMQ Artemis JMS 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>
- </head>
- <body onload="prettyPrint()">
- <h1>JMS Queue Message Listener for openwire</h1>
-
- <pre>To run the example, simply type <b>mvn verify</b> from this directory, <br>or <b>mvn -PnoServer verify</b> if you want to start and create the server manually.</pre>
-
- <p>This example shows how to use a MessageListener with the openwire client</p>
-
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b77cdaf7/examples/protocols/openwire/message-listener/readme.md
----------------------------------------------------------------------
diff --git a/examples/protocols/openwire/message-listener/readme.md b/examples/protocols/openwire/message-listener/readme.md
new file mode 100644
index 0000000..04c43d3
--- /dev/null
+++ b/examples/protocols/openwire/message-listener/readme.md
@@ -0,0 +1,5 @@
+# JMS Queue Message Listener for OpenWire
+
+To run the example, simply type **mvn verify** from this directory, or **mvn -PnoServer verify** if you want to start and create the broker manually.
+
+This example shows how to use a MessageListener with the OpenWire client
\ No newline at end of file