activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [25/48] activemq-artemis git commit: renaming broker-features -> features on examples
Date Thu, 13 Aug 2015 04:13:43 GMT
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/xa-receive/src/main/resources/jndi.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/xa-receive/src/main/resources/jndi.properties b/examples/broker-features/standard/xa-receive/src/main/resources/jndi.properties
deleted file mode 100644
index 77561f7..0000000
--- a/examples/broker-features/standard/xa-receive/src/main/resources/jndi.properties
+++ /dev/null
@@ -1,21 +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.
-
-java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
-connectionFactory.ConnectionFactory=tcp://localhost:61616
-connectionFactory.XAConnectionFactory=tcp://localhost:61616?type=XA_CF
-queue.queue/exampleQueue=exampleQueue

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/xa-send/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/xa-send/pom.xml b/examples/broker-features/standard/xa-send/pom.xml
deleted file mode 100644
index b4dfdf4..0000000
--- a/examples/broker-features/standard/xa-send/pom.xml
+++ /dev/null
@@ -1,109 +0,0 @@
-<?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.broker</groupId>
-      <artifactId>jms-examples</artifactId>
-      <version>1.0.1-SNAPSHOT</version>
-   </parent>
-
-   <artifactId>xa-send</artifactId>
-   <packaging>jar</packaging>
-   <name>ActiveMQ Artemis JMS XA Send Example</name>
-
-   <properties>
-      <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
-   </properties>
-
-   <dependencies>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-jms-client</artifactId>
-         <version>${project.version}</version>
-      </dependency>
-   </dependencies>
-
-   <build>
-      <plugins>
-         <plugin>
-            <groupId>org.apache.activemq</groupId>
-            <artifactId>artemis-maven-plugin</artifactId>
-            <executions>
-               <execution>
-                  <id>create</id>
-                  <goals>
-                     <goal>create</goal>
-                  </goals>
-                  <configuration>
-                     <ignore>${noServer}</ignore>
-                  </configuration>
-               </execution>
-               <execution>
-                  <id>start</id>
-                  <goals>
-                     <goal>cli</goal>
-                  </goals>
-                  <configuration>
-                     <ignore>${noServer}</ignore>
-                     <spawn>true</spawn>
-                     <testURI>tcp://localhost:61616</testURI>
-                     <args>
-                        <param>run</param>
-                     </args>
-                  </configuration>
-               </execution>
-               <execution>
-                  <id>runClient</id>
-                  <goals>
-                     <goal>runClient</goal>
-                  </goals>
-                  <configuration>
-                     <clientClass>org.apache.activemq.artemis.jms.example.XASendExample</clientClass>
-                  </configuration>
-               </execution>
-               <execution>
-                  <id>stop</id>
-                  <goals>
-                     <goal>cli</goal>
-                  </goals>
-                  <configuration>
-                     <ignore>${noServer}</ignore>
-                     <args>
-                        <param>stop</param>
-                     </args>
-                  </configuration>
-               </execution>
-            </executions>
-            <dependencies>
-               <dependency>
-                  <groupId>org.apache.activemq.examples.broker</groupId>
-                  <artifactId>xa-send</artifactId>
-                  <version>${project.version}</version>
-               </dependency>
-            </dependencies>
-         </plugin>
-      </plugins>
-   </build>
-
-</project>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/xa-send/readme.html
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/xa-send/readme.html b/examples/broker-features/standard/xa-send/readme.html
deleted file mode 100644
index fb3db4c..0000000
--- a/examples/broker-features/standard/xa-send/readme.html
+++ /dev/null
@@ -1,215 +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 XA Send 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 XA Send Example</h1>
-     <p>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.</p>
-
-     <p>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.</p>
-
-     <p>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.</p>
-
-     <h2>Example step-by-step</h2>
-     <p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
-
-     <ol>
-        <li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
-        <pre class="prettyprint">
-           <code>InitialContext initialContext = getContext(0);</code>
-        </pre>
-
-        <li>We look-up the JMS queue object from JNDI</li>
-        <pre class="prettyprint">
-           <code>Queue queue = (Queue) initialContext.lookup("/queue/exampleQueue");</code>
-        </pre>
-
-        <li>We perform a lookup on the XA Connection Factory</li>
-        <pre class="prettyprint">
-           <code>XAConnectionFactory cf = (XAConnectionFactory) initialContext.lookup("/XAConnectionFactory");</code>
-        </pre>
-
-        <li>We create a JMS XAConnection</li>
-        <pre class="prettyprint">
-           <code>connection = cf.createXAConnection();</code>
-        </pre>
-
-        <li>We Start the connection</li>
-        <pre class="prettyprint">
-           <code>connection.start();</code>
-        </pre>
-
-        <li>We create a JMS XASession</li>
-        <pre class="prettyprint">
-          <code>XASession xaSession = connection.createXASession();</code>
-       </pre>
-
-        <li>We create a normal session</li>
-        <pre class="prettyprint">
-          <code>Session normalSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);</code>
-       </pre>
-
-        <li>We create a normal Message Consumer</li>
-        <pre class="prettyprint">
-           <code>
-           MessageConsumer normalConsumer = normalSession.createConsumer(queue);
-           normalConsumer.setMessageListener(new SimpleMessageListener());
-           </code>
-       </pre>
-
-        <li>We get the JMS Session</li>
-        <pre class="prettyprint">
-          <code>Session session = xaSession.getSession();</code>
-       </pre>
-
-        <li>We create a message producer</li>
-        <pre class="prettyprint">
-          <code>MessageProducer producer = session.createProducer(queue);</code>
-       </pre>
-
-        <li>We create two Text Messages</li>
-        <pre class="prettyprint">
-          <code>
-          TextMessage helloMessage = session.createTextMessage("hello");
-          TextMessage worldMessage = session.createTextMessage("world");
-          </code>
-       </pre>
-
-        <li>We create a transaction</li>
-        <pre class="prettyprint">
-          <code>Xid xid1 = new XidImpl("xa-example1".getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes());</code>
-       </pre>
-
-        <li>We get the JMS XAResource</li>
-        <pre class="prettyprint">
-          <code>XAResource xaRes = xaSession.getXAResource();</code>
-       </pre>
-
-        <li>We begin the Transaction work</li>
-        <pre class="prettyprint">
-          <code>xaRes.start(xid1, XAResource.TMNOFLAGS);</code>
-       </pre>
-
-        <li>We do work, sending two messages.</li>
-        <pre class="prettyprint">
-          <code>
-          producer.send(helloMessage);
-          producer.send(worldMessage);
-          </code>
-       </pre>
-
-        <li>We check the result, it should receive none!</li>
-        <pre class="prettyprint">
-          <code>checkNoMessageReceived();</code>
-       </pre>
-
-        <li>We stop the work</li>
-        <pre class="prettyprint">
-          <code>xaRes.end(xid1, XAResource.TMSUCCESS);</code>
-       </pre>
-
-        <li>We prepare</li>
-        <pre class="prettyprint">
-          <code>xaRes.prepare(xid1);</code>
-       </pre>
-
-        <li>We roll back the transaction </li>
-        <pre class="prettyprint">
-          <code>xaRes.rollback(xid1);</code>
-       </pre>
-
-        <li>We check no messages should be received! </li>
-        <pre class="prettyprint">
-          <code>checkNoMessageReceived();</code>
-       </pre>
-
-        <li>We create another transaction</li>
-        <pre class="prettyprint">
-          <code>Xid xid2 = new XidImpl("xa-example2".getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes());</code>
-       </pre>
-
-        <li>We start the transaction</li>
-        <pre class="prettyprint">
-          <code>xaRes.start(xid2, XAResource.TMNOFLAGS);</code>
-       </pre>
-
-        <li>We re-send those messages</li>
-        <pre class="prettyprint">
-           <code>
-           producer.send(helloMessage);
-           producer.send(worldMessage);
-           </code>
-       </pre>
-
-        <li>We stop the work</li>
-        <pre class="prettyprint">
-          <code>xaRes.end(xid2, XAResource.TMSUCCESS);</code>
-       </pre>
-
-        <li>We prepare</li>
-        <pre class="prettyprint">
-          <code>xaRes.prepare(xid2);</code>
-       </pre>
-
-        <li>We check that no messages should be received at this moment</li>
-        <pre class="prettyprint">
-          <code>checkNoMessageReceived();</code>
-       </pre>
-
-        <li>We commit!</li>
-        <pre class="prettyprint">
-          <code>xaRes.commit(xid2, false);</code>
-       </pre>
-
-        <li>We check that all messages are received.</li>
-        <pre class="prettyprint">
-          <code>checkAllMessageReceived();</code>
-       </pre>
-
-        <li>And finally, <b>always</b> remember to close your JMS connections and resources after use, in a <code>finally</code> block. Closing a JMS connection will automatically close all of its sessions, consumers, producer and browser objects</li>
-
-        <pre class="prettyprint">
-           <code>finally
-           {
-              if (initialContext != null)
-              {
-                initialContext.close();
-              }
-              if (connection != null)
-              {
-                 connection.close();
-              }
-           }</code>
-        </pre>
-     </ol>
-  </body>
-</html>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/xa-send/src/main/java/org/apache/activemq/artemis/jms/example/DummyXid.java
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/xa-send/src/main/java/org/apache/activemq/artemis/jms/example/DummyXid.java b/examples/broker-features/standard/xa-send/src/main/java/org/apache/activemq/artemis/jms/example/DummyXid.java
deleted file mode 100644
index 4dbe2f8..0000000
--- a/examples/broker-features/standard/xa-send/src/main/java/org/apache/activemq/artemis/jms/example/DummyXid.java
+++ /dev/null
@@ -1,184 +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.
- */
-package org.apache.activemq.artemis.jms.example;
-
-import org.apache.activemq.artemis.utils.Base64;
-
-import javax.transaction.xa.Xid;
-
-public class DummyXid implements Xid {
-
-   private static final long serialVersionUID = 407053232840068514L;
-
-   private final byte[] branchQualifier;
-
-   private final int formatId;
-
-   private final byte[] globalTransactionId;
-
-   private int hash;
-
-   private boolean hashCalculated;
-
-   // Static --------------------------------------------------------
-
-   public static String toBase64String(final Xid xid) {
-      return Base64.encodeBytes(DummyXid.toByteArray(xid));
-   }
-
-   private static byte[] toByteArray(final Xid xid) {
-      byte[] branchQualifier = xid.getBranchQualifier();
-      byte[] globalTransactionId = xid.getGlobalTransactionId();
-      int formatId = xid.getFormatId();
-
-      byte[] hashBytes = new byte[branchQualifier.length + globalTransactionId.length + 4];
-      System.arraycopy(branchQualifier, 0, hashBytes, 0, branchQualifier.length);
-      System.arraycopy(globalTransactionId, 0, hashBytes, branchQualifier.length, globalTransactionId.length);
-      byte[] intBytes = new byte[4];
-      for (int i = 0; i < 4; i++) {
-         intBytes[i] = (byte) ((formatId >> i * 8) % 0xFF);
-      }
-      System.arraycopy(intBytes, 0, hashBytes, branchQualifier.length + globalTransactionId.length, 4);
-      return hashBytes;
-   }
-
-   // Constructors --------------------------------------------------
-
-   /**
-    * Standard constructor
-    *
-    * @param branchQualifier
-    * @param formatId
-    * @param globalTransactionId
-    */
-   public DummyXid(final byte[] branchQualifier, final int formatId, final byte[] globalTransactionId) {
-      this.branchQualifier = branchQualifier;
-      this.formatId = formatId;
-      this.globalTransactionId = globalTransactionId;
-   }
-
-   /**
-    * Copy constructor
-    *
-    * @param other
-    */
-   public DummyXid(final Xid other) {
-      branchQualifier = copyBytes(other.getBranchQualifier());
-      formatId = other.getFormatId();
-      globalTransactionId = copyBytes(other.getGlobalTransactionId());
-   }
-
-   // Xid implementation ------------------------------------------------------------------
-
-   public byte[] getBranchQualifier() {
-      return branchQualifier;
-   }
-
-   public int getFormatId() {
-      return formatId;
-   }
-
-   public byte[] getGlobalTransactionId() {
-      return globalTransactionId;
-   }
-
-   // Public -------------------------------------------------------------------------------
-
-   @Override
-   public int hashCode() {
-      if (!hashCalculated) {
-         calcHash();
-      }
-      return hash;
-   }
-
-   @Override
-   public boolean equals(final Object other) {
-      if (this == other) {
-         return true;
-      }
-      if (!(other instanceof Xid)) {
-         return false;
-      }
-      Xid xother = (Xid) other;
-      if (xother.getFormatId() != formatId) {
-         return false;
-      }
-      if (xother.getBranchQualifier().length != branchQualifier.length) {
-         return false;
-      }
-      if (xother.getGlobalTransactionId().length != globalTransactionId.length) {
-         return false;
-      }
-      for (int i = 0; i < branchQualifier.length; i++) {
-         byte[] otherBQ = xother.getBranchQualifier();
-         if (branchQualifier[i] != otherBQ[i]) {
-            return false;
-         }
-      }
-      for (int i = 0; i < globalTransactionId.length; i++) {
-         byte[] otherGtx = xother.getGlobalTransactionId();
-         if (globalTransactionId[i] != otherGtx[i]) {
-            return false;
-         }
-      }
-      return true;
-   }
-
-   @Override
-   public String toString() {
-      return "XidImpl (" + System.identityHashCode(this) +
-         " bq:" +
-         stringRep(branchQualifier) +
-         " formatID:" +
-         formatId +
-         " gtxid:" +
-         stringRep(globalTransactionId);
-   }
-
-   // Private -------------------------------------------------------------------------------
-
-   private String stringRep(final byte[] bytes) {
-      StringBuilder buff = new StringBuilder();
-      for (int i = 0; i < bytes.length; i++) {
-         byte b = bytes[i];
-
-         buff.append(b);
-
-         if (i != bytes.length - 1) {
-            buff.append('.');
-         }
-      }
-
-      return buff.toString();
-   }
-
-   private void calcHash() {
-      byte[] hashBytes = DummyXid.toByteArray(this);
-      String s = new String(hashBytes);
-      hash = s.hashCode();
-      hashCalculated = true;
-   }
-
-   private byte[] copyBytes(final byte[] other) {
-      byte[] bytes = new byte[other.length];
-
-      System.arraycopy(other, 0, bytes, 0, other.length);
-
-      return bytes;
-   }
-}

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/xa-send/src/main/java/org/apache/activemq/artemis/jms/example/XASendExample.java
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/xa-send/src/main/java/org/apache/activemq/artemis/jms/example/XASendExample.java b/examples/broker-features/standard/xa-send/src/main/java/org/apache/activemq/artemis/jms/example/XASendExample.java
deleted file mode 100644
index fd87f61..0000000
--- a/examples/broker-features/standard/xa-send/src/main/java/org/apache/activemq/artemis/jms/example/XASendExample.java
+++ /dev/null
@@ -1,191 +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.
- */
-package org.apache.activemq.artemis.jms.example;
-
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageConsumer;
-import javax.jms.MessageListener;
-import javax.jms.MessageProducer;
-import javax.jms.Queue;
-import javax.jms.Session;
-import javax.jms.TextMessage;
-import javax.jms.XAConnection;
-import javax.jms.XAConnectionFactory;
-import javax.jms.XASession;
-import javax.naming.InitialContext;
-import javax.transaction.xa.XAResource;
-import javax.transaction.xa.Xid;
-import java.nio.charset.StandardCharsets;
-import java.util.ArrayList;
-import java.util.concurrent.atomic.AtomicBoolean;
-
-import org.apache.activemq.artemis.utils.UUIDGenerator;
-
-/**
- * A simple JMS example showing the usage of XA support in JMS.
- */
-public class XASendExample {
-
-   public static void main(final String[] args) throws Exception {
-      AtomicBoolean result = new AtomicBoolean(true);
-      final ArrayList<String> receiveHolder = new ArrayList<String>();
-      XAConnection connection = null;
-      InitialContext initialContext = null;
-      try {
-         // Step 1. Create an initial context to perform the JNDI lookup.
-         initialContext = new InitialContext();
-
-         // Step 2. Lookup on the queue
-         Queue queue = (Queue) initialContext.lookup("queue/exampleQueue");
-
-         // Step 3. Perform a lookup on the XA Connection Factory
-         XAConnectionFactory cf = (XAConnectionFactory) initialContext.lookup("XAConnectionFactory");
-
-         // Step 4.Create a JMS XAConnection
-         connection = cf.createXAConnection();
-
-         // Step 5. Start the connection
-         connection.start();
-
-         // Step 6. Create a JMS XASession
-         XASession xaSession = connection.createXASession();
-
-         // Step 7. Create a normal session
-         Session normalSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
-         // Step 8. Create a normal Message Consumer
-         MessageConsumer normalConsumer = normalSession.createConsumer(queue);
-         normalConsumer.setMessageListener(new SimpleMessageListener(receiveHolder, result));
-
-         // Step 9. Get the JMS Session
-         Session session = xaSession.getSession();
-
-         // Step 10. Create a message producer
-         MessageProducer producer = session.createProducer(queue);
-
-         // Step 11. Create two Text Messages
-         TextMessage helloMessage = session.createTextMessage("hello");
-         TextMessage worldMessage = session.createTextMessage("world");
-
-         // Step 12. create a transaction
-         Xid xid1 = new DummyXid("xa-example1".getBytes(StandardCharsets.UTF_8), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes());
-
-         // Step 13. Get the JMS XAResource
-         XAResource xaRes = xaSession.getXAResource();
-
-         // Step 14. Begin the Transaction work
-         xaRes.start(xid1, XAResource.TMNOFLAGS);
-
-         // Step 15. do work, sending two messages.
-         producer.send(helloMessage);
-         producer.send(worldMessage);
-
-         Thread.sleep(2000);
-
-         // Step 16. Check the result, it should receive none!
-         checkNoMessageReceived(receiveHolder);
-
-         // Step 17. Stop the work
-         xaRes.end(xid1, XAResource.TMSUCCESS);
-
-         // Step 18. Prepare
-         xaRes.prepare(xid1);
-
-         // Step 19. Roll back the transaction
-         xaRes.rollback(xid1);
-
-         // Step 20. No messages should be received!
-         checkNoMessageReceived(receiveHolder);
-
-         // Step 21. Create another transaction
-         Xid xid2 = new DummyXid("xa-example2".getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes());
-
-         // Step 22. Start the transaction
-         xaRes.start(xid2, XAResource.TMNOFLAGS);
-
-         // Step 23. Re-send those messages
-         producer.send(helloMessage);
-         producer.send(worldMessage);
-
-         // Step 24. Stop the work
-         xaRes.end(xid2, XAResource.TMSUCCESS);
-
-         // Step 25. Prepare
-         xaRes.prepare(xid2);
-
-         // Step 26. No messages should be received at this moment
-         checkNoMessageReceived(receiveHolder);
-
-         // Step 27. Commit!
-         xaRes.commit(xid2, false);
-
-         Thread.sleep(2000);
-
-         // Step 28. Check the result, all message received
-         checkAllMessageReceived(receiveHolder);
-
-         if (!result.get())
-            throw new IllegalStateException();
-      }
-      finally {
-         // Step 29. Be sure to close our JMS resources!
-         if (initialContext != null) {
-            initialContext.close();
-         }
-         if (connection != null) {
-            connection.close();
-         }
-      }
-   }
-
-   private static void checkAllMessageReceived(ArrayList<String> receiveHolder) {
-      if (receiveHolder.size() != 2) {
-         throw new IllegalStateException("Number of messages received not correct ! -- " + receiveHolder.size());
-      }
-      receiveHolder.clear();
-   }
-
-   private static void checkNoMessageReceived(ArrayList<String> receiveHolder) {
-      if (receiveHolder.size() > 0) {
-         throw new IllegalStateException("Message received, wrong!");
-      }
-      receiveHolder.clear();
-   }
-}
-
-class SimpleMessageListener implements MessageListener {
-
-   ArrayList<String> receiveHolder;
-   AtomicBoolean result;
-
-   public SimpleMessageListener(ArrayList<String> receiveHolder, AtomicBoolean result) {
-      this.receiveHolder = receiveHolder;
-      this.result = result;
-   }
-
-   public void onMessage(final Message message) {
-      try {
-         System.out.println("Message received: " + message);
-         receiveHolder.add(((TextMessage) message).getText());
-      }
-      catch (JMSException e) {
-         result.set(false);
-         e.printStackTrace();
-      }
-   }
-}

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/xa-send/src/main/resources/jndi.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/xa-send/src/main/resources/jndi.properties b/examples/broker-features/standard/xa-send/src/main/resources/jndi.properties
deleted file mode 100644
index 77561f7..0000000
--- a/examples/broker-features/standard/xa-send/src/main/resources/jndi.properties
+++ /dev/null
@@ -1,21 +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.
-
-java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
-connectionFactory.ConnectionFactory=tcp://localhost:61616
-connectionFactory.XAConnectionFactory=tcp://localhost:61616?type=XA_CF
-queue.queue/exampleQueue=exampleQueue

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/sub-modules/aerogear/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/sub-modules/aerogear/pom.xml b/examples/broker-features/sub-modules/aerogear/pom.xml
deleted file mode 100644
index c522d78..0000000
--- a/examples/broker-features/sub-modules/aerogear/pom.xml
+++ /dev/null
@@ -1,125 +0,0 @@
-<?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.modules</groupId>
-      <artifactId>broker-modules</artifactId>
-      <version>1.0.1-SNAPSHOT</version>
-   </parent>
-
-   <properties>
-      <endpoint/>
-      <applicationid/>
-      <mastersecret/>
-      <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
-   </properties>
-
-   <artifactId>aerogear</artifactId>
-   <packaging>jar</packaging>
-   <name>ActiveMQ Artemis JMS AeroGear Example</name>
-
-   <dependencies>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-cli</artifactId>
-         <version>${project.version}</version>
-      </dependency>
-   </dependencies>
-
-   <build>
-      <plugins>
-         <plugin>
-            <groupId>org.apache.activemq</groupId>
-            <artifactId>artemis-maven-plugin</artifactId>
-            <executions>
-               <execution>
-                  <id>create</id>
-                  <goals>
-                     <goal>create</goal>
-                  </goals>
-                  <configuration>
-                     <ignore>${noServer}</ignore>
-                     <!-- this list was extracted from mvn dependency:tree on integration/aerogear -->
-                     <libList>
-                        <param>org.apache.activemq:artemis-aerogear-integration:${project.version}</param>
-                        <param>org.jboss.aerogear:unifiedpush-java-client:1.0.0</param>
-                        <param>net.iharder:base64:2.3.8</param>
-                        <param>com.fasterxml.jackson.core:jackson-annotations:2.3.0</param>
-                        <param>com.fasterxml.jackson.core:jackson-core:2.3.0</param>
-                        <param>org.jboss.resteasy:resteasy-jackson-provider:2.3.2.Final</param>
-                        <param>org.codehaus.jackson:jackson-core-asl:1.8.5</param>
-                        <param>org.codehaus.jackson:jackson-mapper-asl:1.8.5</param>
-                        <param>org.codehaus.jackson:jackson-jaxrs:1.8.5</param>
-                        <param>org.codehaus.jackson:jackson-xc:1.8.5</param>
-                     </libList>
-                  </configuration>
-               </execution>
-               <execution>
-                  <id>start</id>
-                  <goals>
-                     <goal>cli</goal>
-                  </goals>
-                  <configuration>
-                     <ignore>${noServer}</ignore>
-                     <spawn>true</spawn>
-                     <testURI>tcp://localhost:61616</testURI>
-                     <args>
-                        <param>run</param>
-                     </args>
-                  </configuration>
-               </execution>
-               <execution>
-                  <id>runClient</id>
-                  <goals>
-                     <goal>runClient</goal>
-                  </goals>
-                  <configuration>
-                     <clientClass>org.apache.activemq.artemis.jms.example.AerogearExample</clientClass>
-                  </configuration>
-               </execution>
-               <execution>
-                  <id>stop</id>
-                  <goals>
-                     <goal>cli</goal>
-                  </goals>
-                  <configuration>
-                     <ignore>${noServer}</ignore>
-                     <args>
-                        <param>stop</param>
-                     </args>
-                  </configuration>
-               </execution>
-            </executions>
-            <dependencies>
-               <dependency>
-                  <groupId>org.apache.activemq.examples.modules</groupId>
-                  <artifactId>aerogear</artifactId>
-                  <version>${project.version}</version>
-               </dependency>
-            </dependencies>
-         </plugin>
-      </plugins>
-   </build>
-
-</project>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/sub-modules/aerogear/readme.html
----------------------------------------------------------------------
diff --git a/examples/broker-features/sub-modules/aerogear/readme.html b/examples/broker-features/sub-modules/aerogear/readme.html
deleted file mode 100644
index 3534a4c..0000000
--- a/examples/broker-features/sub-modules/aerogear/readme.html
+++ /dev/null
@@ -1,157 +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 AeroGear 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 AeroGear 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 shows how you can send a message to a mobile device by leveraging <a href="http://aerogear.org/push/">AeroGears push</a> technology which
-         provides support for different push notification technologies like Google Cloud Messaging, Apple's APNs or
-         Mozilla's SimplePush.</p>
-
-     <p>For this example you will need an AeroGear Application running somewhere, a good way to do this is to deploy the
-        Push Application on <href a="">openshift</href>, you can follow the AeroGear Push 0.X Quickstart.</p>
-
-     <p>Once you have created your AeroGear Push Application you can create a mobile application. Simply log into the application
-     on the web and create a new mobile application by clicking the 'create' button. Once created you will see an application id
-     and a master secret, you will need the later to run the example.</p>
-
-     <p>lastly you will need to create a variant. For this example we will be using Android so you will need to create a google project,
-     this <a href="http://aerogear.org/docs/guides/aerogear-push-android/google-setup/">article</a> explains how to do this.
-     Once created click on your app then click 'add' to add a variant. choose 'google cloud messaging', enter your google
-         API key and the project number from your google project and click create</p>
-
-     <p>Now before we run the example we need a mobile application to receive it. Writing a mobile app is beyond the scope
-     of this example but for testing purposes we have supplied an Android app you can use, simply install on your android phone.
-     It can be found <a href="http://downloads.jboss.org.apache.activemq/ActiveMQAeroGear.apk">here</a>. For a more in depth mobile
-         app example visit the AeroGear site.</p>
-
-     <p>Once you have installed the mobile app you will need to configure the following:</p>
-     <p>AeroGear Unified Push URL : This is the URL where your aerogear server is running, something like http://myapp-mydomain.rhcloud.com
-        AeroGear Variant ID : This is the ID of the variant you created in AeroGear
-        AeroGear Variant Secret : This is the secret for your variant
-        GCM Sender ID : this is the Google project Number you created on Google
-        Variant : you can use this to target messages if needed.
-     </p>
-
-     <p>Once you set all these correctly you should get a message saying your mobile app is registered, if you log into
-         your AeroGear app you should see it registered with the variant.</p>
-
-
-     <p>Now to run the example simply run the following command
-         'mvn -Dendpoint=my aerogear url -Dapplicationid=my application id -Dmastersecret=my master secret -Djsse.enableSNIExtension=false clean verify'.
-     If you arent using java 7 you can omit the 'jsse.enableSNIExtension=false'</p>
-
-   <p>You should see something like this in your ActiveMQServer</p>
-     <ol>
-        <pre class="prettyprint">
-           <code>
-   Dec 04, 2013 3:25:39 PM org.jboss.aerogear.unifiedpush.SenderClient submitPayload
-   INFO: HTTP Response code from UnifiedPush Server: 302
-   Dec 04, 2013 3:25:39 PM org.jboss.aerogear.unifiedpush.SenderClient submitPayload
-   INFO: Performing redirect to 'https://myapp-mydomain.rhcloud.com/rest/sender/'
-   Dec 04, 2013 3:25:40 PM org.jboss.aerogear.unifiedpush.SenderClient submitPayload
-   INFO: HTTP Response code from UnifiedPush Server: 200
-           </code>
-        </pre>
-     </ol>
-   <p>And on your mobile app you should see a message from ActiveMQ</p>
-
-  <p>Now lets look a bit more closely at the configuration in broker.xml</p>
-     <ol>
-        <pre class="prettyprint">
-           <code>
-   &lt;queues>
-       &lt;queue name="jms.queue.exampleQueue">
-           &lt;address>jms.queue.exampleQueue&lt;/address>
-       &lt;/queue>
-   &lt;/queues>
-
-   &lt;connector-services>
-       &lt;connector-service name="aerogear-connector">
-           &lt;factory-class>org.apache.activemq.integration.aerogear.AeroGearConnectorServiceFactory&lt;/factory-class>
-           &lt;param key="endpoint" value="${endpoint}"/>
-           &lt;param key="queue" value="jms.queue.exampleQueue"/>
-           &lt;param key="application-id" value="${applicationid}"/>
-           &lt;param key="master-secret" value="${mastersecret}"/>
-       &lt;/connector-service>
-   &lt;/connector-services>
-           </code>
-        </pre>
-     </ol>
-  <p>Firstly you will see that we have to create a core queue so it is available when the connector is started, the following are mandatory parameters:</p>
-  <ol>
-      <li>endpoint - The endpoint or URL of you AeroGear application</li>
-      <li>queue - The name of the queue to consume from</li>
-      <li>application-id - The application id of your mobile application in AeroGear</li>
-      <li>master-secret - the secret of your mobile application in AeroGear</li>
-  </ol>
-  <p>as well as those there are also the following optional parameters</p>
-  <ol>
-      <li>ttl - The time to live for the message once AeroGear receives it</li>
-      <li>badge - The badge the mobile app should use for the notification</li>
-      <li>sound - The sound the mobile app should use for the notification</li>
-      <li>filter - A message filter(selector) to use on the connector</li>
-      <li>retry-interval - If an error occurs on send, how long before we try again</li>
-      <li>retry-attempts - How many times we should try to reconnect after an error</li>
-      <li>variants - A comma separated list of variants that should get the message</li>
-      <li>aliases - A list of aliases that should get the message</li>
-      <li>device-types - A list of device types that should get the message</li>
-  </ol>
-  <p>More in depth explanations of these can be found in the AeroGear docs.</p>
-  <p>Now lets look at a snippet of code we used to send the message for our JMS client</p>
-  <pre class="prettyprint">
-      <code>
-  Queue queue = (Queue)initialContext.lookup("queue/exampleQueue");
-
-  // Step 3. Perform a lookup on the Connection Factory
-  ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory");
-
-  // Step 4.Create a JMS Connection
-  connection = cf.createConnection();
-
-  // Step 5. Create a JMS Session
-  Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
-  // Step 6. Create a JMS Message Producer
-  MessageProducer producer = session.createProducer(queue);
-
-  // Step 7. Create a Text Message
-  Message message = session.createMessage();
-
-  message.setStringProperty("AEROGEAR_ALERT", "Hello this is a notification from ActiveMQ");
-
-  producer.send(message);
-      </code>
-  </pre>
-  <p> The most important thing here is string propert we have set on the message, i.e. 'AEROGEAR_ALERT'. This is the
-      actual alert that is sent via AeroGear</p>
-  <p>As well as the alert itself you can override any of the above optional parameters in the same fashionby using the
-      following propert names: AEROGEAR_SOUND,AEROGEAR_BADGE,AEROGEAR_TTL,AEROGEAR_VARIANTS,AEROGEAR_ALIASES and AEROGEAR_DEVICE_TYPES</p>
-  </body>
-</html>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/sub-modules/aerogear/src/main/java/org/apache/activemq/artemis/jms/example/AerogearExample.java
----------------------------------------------------------------------
diff --git a/examples/broker-features/sub-modules/aerogear/src/main/java/org/apache/activemq/artemis/jms/example/AerogearExample.java b/examples/broker-features/sub-modules/aerogear/src/main/java/org/apache/activemq/artemis/jms/example/AerogearExample.java
deleted file mode 100644
index b412d87..0000000
--- a/examples/broker-features/sub-modules/aerogear/src/main/java/org/apache/activemq/artemis/jms/example/AerogearExample.java
+++ /dev/null
@@ -1,77 +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.
- */
-package org.apache.activemq.artemis.jms.example;
-
-import javax.jms.Connection;
-import javax.jms.ConnectionFactory;
-import javax.jms.Message;
-import javax.jms.MessageProducer;
-import javax.jms.Queue;
-import javax.jms.Session;
-import javax.naming.InitialContext;
-
-/**
- * A simple JMS Queue example that creates a producer and consumer on a queue and sends then receives a message.
- */
-public class AerogearExample {
-
-   public static void main(final String[] args) throws Exception {
-      Connection connection = null;
-      InitialContext initialContext = null;
-      try {
-         // Step 1. Create an initial context to perform the JNDI lookup.
-         initialContext = new InitialContext();
-
-         // Step 2. Perfom a lookup on the queue
-         Queue queue = (Queue) initialContext.lookup("queue/exampleQueue");
-
-         // Step 3. Perform a lookup on the Connection Factory
-         ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("ConnectionFactory");
-
-         // Step 4.Create a JMS Connection
-         connection = cf.createConnection();
-
-         // Step 5. Create a JMS Session
-         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
-         // Step 6. Create a JMS Message Producer
-         MessageProducer producer = session.createProducer(queue);
-
-         // Step 7. Create a Text Message
-         Message message = session.createMessage();
-
-         message.setStringProperty("AEROGEAR_ALERT", "Hello this is a notification from ActiveMQ");
-
-         producer.send(message);
-
-         System.out.println("Sent message");
-
-         System.out.println("now check your mobile app and press enter");
-
-         System.in.read();
-      }
-      finally {
-         // Step 12. Be sure to close our JMS resources!
-         if (initialContext != null) {
-            initialContext.close();
-         }
-         if (connection != null) {
-            connection.close();
-         }
-      }
-   }
-}

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/sub-modules/aerogear/src/main/resources/activemq/server0/broker.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/sub-modules/aerogear/src/main/resources/activemq/server0/broker.xml b/examples/broker-features/sub-modules/aerogear/src/main/resources/activemq/server0/broker.xml
deleted file mode 100644
index 1095761..0000000
--- a/examples/broker-features/sub-modules/aerogear/src/main/resources/activemq/server0/broker.xml
+++ /dev/null
@@ -1,77 +0,0 @@
-<?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.
--->
-
-<configuration xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-               xmlns="urn:activemq"
-               xsi:schemaLocation="urn:activemq /schema/artemis-server.xsd">
-
-   <jms xmlns="urn:activemq:jms">
-      <!--the queue used by the example-->
-      <queue name="exampleQueue"/>
-   </jms>
-
-   <core xmlns="urn:activemq:core">
-
-      <bindings-directory>./data/bindings</bindings-directory>
-
-      <journal-directory>./data/journal</journal-directory>
-
-      <large-messages-directory>./data/largemessages</large-messages-directory>
-
-      <paging-directory>./data/paging</paging-directory>
-
-      <!-- Acceptors -->
-      <acceptors>
-         <acceptor name="netty-acceptor">tcp://localhost:61616</acceptor>
-      </acceptors>
-
-      <!-- We need to create a core queue for the JMS queue explicitly because the connector will be deployed
-       before the JMS queue is deployed, so the first time, it otherwise won't find the queue -->
-      <queues>
-         <queue name="jms.queue.exampleQueue">
-            <address>jms.queue.exampleQueue</address>
-         </queue>
-      </queues>
-
-      <connector-services>
-         <connector-service name="aerogear-connector">
-            <factory-class>org.apache.activemq.artemis.integration.aerogear.AeroGearConnectorServiceFactory</factory-class>
-            <param key="endpoint" value="${endpoint}"/>
-            <param key="queue" value="jms.queue.exampleQueue"/>
-            <param key="application-id" value="${applicationid}"/>
-            <param key="master-secret" value="${mastersecret}"/>
-         </connector-service>
-      </connector-services>
-
-      <!-- Other config -->
-
-      <security-settings>
-         <!--security for example queue-->
-         <security-setting match="jms.queue.exampleQueue">
-            <permission type="createDurableQueue" roles="guest"/>
-            <permission type="deleteDurableQueue" roles="guest"/>
-            <permission type="createNonDurableQueue" roles="guest"/>
-            <permission type="deleteNonDurableQueue" roles="guest"/>
-            <permission type="consume" roles="guest"/>
-            <permission type="send" roles="guest"/>
-         </security-setting>
-      </security-settings>
-   </core>
-</configuration>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/sub-modules/aerogear/src/main/resources/jndi.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/sub-modules/aerogear/src/main/resources/jndi.properties b/examples/broker-features/sub-modules/aerogear/src/main/resources/jndi.properties
deleted file mode 100644
index 93537c4..0000000
--- a/examples/broker-features/sub-modules/aerogear/src/main/resources/jndi.properties
+++ /dev/null
@@ -1,20 +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.
-
-java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
-connectionFactory.ConnectionFactory=tcp://localhost:61616
-queue.queue/exampleQueue=exampleQueue

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/sub-modules/artemis-ra-rar/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/sub-modules/artemis-ra-rar/pom.xml b/examples/broker-features/sub-modules/artemis-ra-rar/pom.xml
deleted file mode 100644
index cae1386..0000000
--- a/examples/broker-features/sub-modules/artemis-ra-rar/pom.xml
+++ /dev/null
@@ -1,101 +0,0 @@
-<?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.modules</groupId>
-      <artifactId>broker-modules</artifactId>
-      <version>1.0.1-SNAPSHOT</version>
-   </parent>
-
-   <artifactId>artemis-rar</artifactId>
-   <packaging>rar</packaging>
-   <name>ActiveMQ Artemis JMS RA</name>
-
-   <properties>
-      <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
-   </properties>
-
-   <dependencies>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-jms-client</artifactId>
-         <version>${project.version}</version>
-         <exclusions>
-            <exclusion>
-               <groupId>org.apache.activemq</groupId>
-               <artifactId>artemis-core-client</artifactId>
-            </exclusion>
-            <exclusion>
-               <groupId>org.apache.activemq</groupId>
-               <artifactId>artemis-jms-client</artifactId>
-            </exclusion>
-            <exclusion>
-              <groupId>org.apache.geronimo.specs</groupId>
-              <artifactId>geronimo-jms_2.0_spec</artifactId>
-            </exclusion>
-            <exclusion>
-               <groupId>org.apache.geronimo.specs</groupId>
-               <artifactId>geronimo-ejb_3.0_spec</artifactId>
-            </exclusion>
-         </exclusions>
-      </dependency>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-ra</artifactId>
-         <version>${project.version}</version>
-      </dependency>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-jms-server</artifactId>
-         <version>${project.version}</version>
-      </dependency>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-core-client</artifactId>
-         <version>${project.version}</version>
-         <exclusions>
-            <exclusion>
-               <groupId>org.apache.activemq</groupId>
-               <artifactId>artemis-core-client</artifactId>
-            </exclusion>
-         </exclusions>
-      </dependency>
-      <dependency>
-         <groupId>io.netty</groupId>
-         <artifactId>netty-all</artifactId>
-      </dependency>
-   </dependencies>
-
-   <build>
-      <plugins>
-         <plugin>
-            <groupId>org.apache.maven.plugins</groupId>
-            <artifactId>maven-rar-plugin</artifactId>
-            <configuration>
-               <raXmlFile>src/main/resources/ra.xml</raXmlFile>
-            </configuration>
-         </plugin>
-      </plugins>
-   </build>
-
-</project>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/sub-modules/artemis-ra-rar/src/main/resources/ra.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/sub-modules/artemis-ra-rar/src/main/resources/ra.xml b/examples/broker-features/sub-modules/artemis-ra-rar/src/main/resources/ra.xml
deleted file mode 100644
index db571a3..0000000
--- a/examples/broker-features/sub-modules/artemis-ra-rar/src/main/resources/ra.xml
+++ /dev/null
@@ -1,308 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!-- $Id: ra.xml 76819 2008-08-08 11:04:20Z jesper.pedersen $ -->
-
-<connector xmlns="http://java.sun.com/xml/ns/j2ee"
-           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-           xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
-           http://java.sun.com/xml/ns/j2ee/connector_1_5.xsd"
-           version="1.5">
-
-   <description>ActiveMQ Artemis 2.0 Resource Adapter</description>
-   <display-name>ActiveMQ Artemis 2.0 Resource Adapter</display-name>
-
-   <vendor-name>Apache Software Foundation</vendor-name>
-   <eis-type>JMS 1.1 Server</eis-type>
-   <resourceadapter-version>1.0</resourceadapter-version>
-
-   <license>
-      <description>
-         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.
-      </description>
-      <license-required>true</license-required>
-   </license>
-
-   <resourceadapter>
-      <resourceadapter-class>org.apache.activemq.artemis.ra.ActiveMQResourceAdapter</resourceadapter-class>
-      <config-property>
-         <description>
-            The transport type. Multiple connectors can be configured by using a comma separated list,
-            i.e. org.apache.activemq.artemis.core.remoting.impl.invm.InVMConnectorFactory,org.apache.activemq.artemis.core.remoting.impl.invm.InVMConnectorFactory.
-         </description>
-         <config-property-name>ConnectorClassName</config-property-name>
-         <config-property-type>java.lang.String</config-property-type>
-         <config-property-value>org.apache.activemq.artemis.core.remoting.impl.invm.InVMConnectorFactory</config-property-value>
-      </config-property>
-      <config-property>
-         <description>The transport configuration. These values must be in the form of key=val;key=val;,
-            if multiple connectors are used then each set must be separated by a comma i.e. host=host1;port=61616,host=host2;port=61617.
-            Each set of params maps to the connector classname specified.
-         </description>
-         <config-property-name>ConnectionParameters</config-property-name>
-         <config-property-type>java.lang.String</config-property-type>
-         <config-property-value>server-id=0</config-property-value>
-      </config-property>
-      <!--
-      <config-property>
-        <description>Does we support HA</description>
-        <config-property-name>HA</config-property-name>
-        <config-property-type>java.lang.Boolean</config-property-type>
-        <config-property-value>false</config-property-value>
-      </config-property>
-      <config-property>
-        <description>The method to use for locating the transactionmanager</description>
-        <config-property-name>TransactionManagerLocatorMethod</config-property-name>
-        <config-property-type>java.lang.String</config-property-type>
-        <config-property-value>getTm</config-property-value>
-      </config-property>
-      <config-property>
-        <description>Use A local Transaction instead of XA?</description>
-        <config-property-name>UseLocalTx</config-property-name>
-        <config-property-type>java.lang.Boolean</config-property-type>
-        <config-property-value>false</config-property-value>
-      </config-property>
-      <config-property>
-        <description>The user name used to login to the JMS server</description>
-        <config-property-name>UserName</config-property-name>
-        <config-property-type>java.lang.String</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The password used to login to the JMS server</description>
-        <config-property-name>Password</config-property-name>
-        <config-property-type>java.lang.String</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The jndi params to use to look up the jms resources if local jndi is not to be used</description>
-        <config-property-name>JndiParams</config-property-name>
-        <config-property-type>java.lang.String</config-property-type>
-        <config-property-value>java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory;java.naming.provider.url=jnp://localhost:1199;java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces</config-property-value>
-      </config-property>
-      <config-property>
-        <description>The jGroups File name</description>
-        <config-property-name>JgroupsFile</config-property-name>
-        <config-property-type>java.lang.String</config-property-type>
-        <config-property-value>jgroups.xml</config-property-value>
-      </config-property>
-      <config-property>
-        <description>The name of the channel used on this configuration</description>
-        <config-property-name>JgroupsChannelName</config-property-name>
-        <config-property-type>java.lang.Integer</config-property-type>
-        <config-property-value>my-channel</config-property-value>
-      </config-property>
-      <config-property>
-        <description>The discovery group address</description>
-        <config-property-name>DiscoveryAddress</config-property-name>
-        <config-property-type>java.lang.String</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The discovery group port</description>
-        <config-property-name>DiscoveryPort</config-property-name>
-        <config-property-type>java.lang.Integer</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The discovery refresh timeout</description>
-        <config-property-name>DiscoveryRefreshTimeout</config-property-name>
-        <config-property-type>java.lang.Long</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The discovery initial wait timeout</description>
-        <config-property-name>DiscoveryInitialWaitTimeout</config-property-name>
-        <config-property-type>java.lang.Long</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The load balancing policy class name</description>
-        <config-property-name>LoadBalancingPolicyClassName</config-property-name>
-        <config-property-type>java.lang.String</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The client failure check period</description>
-        <config-property-name>ClientFailureCheckPeriod</config-property-name>
-        <config-property-type>java.lang.Long</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The connection TTL</description>
-        <config-property-name>ConnectionTTL</config-property-name>
-        <config-property-type>java.lang.Long</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The call timeout</description>
-        <config-property-name>CallTimeout</config-property-name>
-        <config-property-type>java.lang.Long</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The dups ok batch size</description>
-        <config-property-name>DupsOKBatchSize</config-property-name>
-        <config-property-type>java.lang.Integer</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The transaction batch size</description>
-        <config-property-name>TransactionBatchSize</config-property-name>
-        <config-property-type>java.lang.Integer</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The consumer window size</description>
-        <config-property-name>ConsumerWindowSize</config-property-name>
-        <config-property-type>java.lang.Integer</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The consumer max rate</description>
-        <config-property-name>ConsumerMaxRate</config-property-name>
-        <config-property-type>java.lang.Integer</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The confirmation window size</description>
-        <config-property-name>ConfirmationWindowSize</config-property-name>
-        <config-property-type>java.lang.Integer</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The producer max rate</description>
-        <config-property-name>ProducerMaxRate</config-property-name>
-        <config-property-type>java.lang.Integer</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The min large message size</description>
-        <config-property-name>MinLargeMessageSize</config-property-name>
-        <config-property-type>java.lang.Integer</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The block on acknowledge</description>
-        <config-property-name>BlockOnAcknowledge</config-property-name>
-        <config-property-type>java.lang.Boolean</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The block on non durable send</description>
-        <config-property-name>BlockOnNonDurableSend</config-property-name>
-        <config-property-type>java.lang.Boolean</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The block on durable send</description>
-        <config-property-name>BlockOnDurableSend</config-property-name>
-        <config-property-type>java.lang.Boolean</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The auto group</description>
-        <config-property-name>AutoGroup</config-property-name>
-        <config-property-type>java.lang.Boolean</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The max connections</description>
-        <config-property-type>java.lang.Integer</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The pre acknowledge</description>
-        <config-property-name>PreAcknowledge</config-property-name>
-        <config-property-type>java.lang.Boolean</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The retry interval</description>
-        <config-property-name>RetryInterval</config-property-name>
-        <config-property-type>java.lang.Long</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The retry interval multiplier</description>
-        <config-property-name>RetryIntervalMultiplier</config-property-name>
-        <config-property-type>java.lang.Double</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The client id</description>
-        <config-property-name>ClientID</config-property-name>
-        <config-property-type>java.lang.String</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>Whether the password is cleartext or encrypted, default false</description>
-        <config-property-name>UseMaskedPassword</config-property-name>
-        <config-property-type>java.lang.Boolean</config-property-type>
-        <config-property-value></config-property-value>
-      </config-property>
-      <config-property>
-        <description>The class definition (full qualified name and its properties) used to encrypt the password</description>
-        <config-property-name>PasswordCodec</config-property-name>
-        <config-property-type>java.lang.String</config-property-type>
-        <config-property-value>org.apache.activemq.artemis.utils.DefaultSensitiveStringCodec;key=clusterpassword;algorithm=something</config-property-value>
-      </config-property>-->
-
-      <outbound-resourceadapter>
-         <connection-definition>
-            <managedconnectionfactory-class>org.apache.activemq.artemis.ra.ActiveMQRAManagedConnectionFactory</managedconnectionfactory-class>
-
-            <config-property>
-               <description>The default session type</description>
-               <config-property-name>SessionDefaultType</config-property-name>
-               <config-property-type>java.lang.String</config-property-type>
-               <config-property-value>javax.jms.Queue</config-property-value>
-            </config-property>
-            <config-property>
-               <description>Try to obtain a lock within specified number of seconds; less than or equal to 0 disable this functionality</description>
-               <config-property-name>UseTryLock</config-property-name>
-               <config-property-type>java.lang.Integer</config-property-type>
-               <config-property-value>0</config-property-value>
-            </config-property>
-
-            <connectionfactory-interface>org.apache.activemq.artemis.ra.ActiveMQRAConnectionFactory</connectionfactory-interface>
-            <connectionfactory-impl-class>org.apache.activemq.artemis.ra.ActiveMQRAConnectionFactoryImpl</connectionfactory-impl-class>
-            <connection-interface>javax.jms.Session</connection-interface>
-            <connection-impl-class>org.apache.activemq.artemis.ra.ActiveMQRASession</connection-impl-class>
-         </connection-definition>
-         <transaction-support>XATransaction</transaction-support>
-         <authentication-mechanism>
-            <authentication-mechanism-type>BasicPassword</authentication-mechanism-type>
-            <credential-interface>javax.resource.spi.security.PasswordCredential</credential-interface>
-         </authentication-mechanism>
-         <reauthentication-support>false</reauthentication-support>
-      </outbound-resourceadapter>
-
-      <inbound-resourceadapter>
-         <messageadapter>
-            <messagelistener>
-               <messagelistener-type>javax.jms.MessageListener</messagelistener-type>
-               <activationspec>
-                  <activationspec-class>org.apache.activemq.artemis.ra.inflow.ActiveMQActivationSpec</activationspec-class>
-                  <required-config-property>
-                      <config-property-name>destination</config-property-name>
-                  </required-config-property>
-               </activationspec>
-            </messagelistener>
-         </messageadapter>
-      </inbound-resourceadapter>
-
-   </resourceadapter>
-</connector>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/sub-modules/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/sub-modules/pom.xml b/examples/broker-features/sub-modules/pom.xml
deleted file mode 100644
index aeeae3c..0000000
--- a/examples/broker-features/sub-modules/pom.xml
+++ /dev/null
@@ -1,58 +0,0 @@
-<?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.modules</groupId>
-   <artifactId>broker-modules</artifactId>
-   <packaging>pom</packaging>
-   <name>ActiveMQ Artemis Modules 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>
-      <!-- The modules examples need to be executed manually,
-           for that reason we won't provide an examples profile here to execute all of them at once -->
-      <profile>
-         <id>release</id>
-         <modules>
-            <module>aerogear</module>
-            <module>artemis-ra-rar</module>
-            <module>vertx</module>
-         </modules>
-      </profile>
-   </profiles>
-</project>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/sub-modules/vertx/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/sub-modules/vertx/pom.xml b/examples/broker-features/sub-modules/vertx/pom.xml
deleted file mode 100644
index e38a299..0000000
--- a/examples/broker-features/sub-modules/vertx/pom.xml
+++ /dev/null
@@ -1,145 +0,0 @@
-<?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.modules</groupId>
-      <artifactId>broker-modules</artifactId>
-      <version>1.0.1-SNAPSHOT</version>
-   </parent>
-
-   <artifactId>artemis-vertx-example</artifactId>
-   <packaging>jar</packaging>
-   <name>ActiveMQ Artemis Vert.x Example</name>
-
-   <properties>
-      <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
-      <vertx.version>2.1.2</vertx.version>
-   </properties>
-
-   <dependencies>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-server</artifactId>
-         <version>${project.version}</version>
-      </dependency>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-core-client</artifactId>
-         <version>${project.version}</version>
-      </dependency>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-commons</artifactId>
-         <version>${project.version}</version>
-      </dependency>
-      <dependency>
-         <groupId>io.netty</groupId>
-         <artifactId>netty-all</artifactId>
-         <version>${netty.version}</version>
-      </dependency>
-      <dependency>
-         <groupId>org.apache.geronimo.specs</groupId>
-         <artifactId>geronimo-jms_2.0_spec</artifactId>
-      </dependency>
-      <dependency>
-         <groupId>io.vertx</groupId>
-         <artifactId>vertx-core</artifactId>
-         <version>${vertx.version}</version>
-         <scope>provided</scope>
-      </dependency>
-      <dependency>
-         <groupId>io.vertx</groupId>
-         <artifactId>vertx-platform</artifactId>
-         <version>${vertx.version}</version>
-         <scope>provided</scope>
-      </dependency>
-      <dependency>
-         <groupId>io.vertx</groupId>
-         <artifactId>vertx-hazelcast</artifactId>
-         <version>${vertx.version}</version>
-         <scope>provided</scope>
-      </dependency>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-vertx-integration</artifactId>
-         <version>${project.version}</version>
-      </dependency>
-
-   </dependencies>
-   <build>
-      <plugins>
-         <plugin>
-            <groupId>org.apache.activemq</groupId>
-            <artifactId>artemis-maven-plugin</artifactId>
-            <executions>
-               <execution>
-                  <id>create0</id>
-                  <goals>
-                     <goal>create</goal>
-                  </goals>
-                  <configuration>
-                     <libList>
-                        <arg>org.apache.activemq.examples.modules:artemis-vertx-example:${project.version}</arg>
-                     </libList>
-                     <instance>${basedir}/target/server0</instance>
-                     <configuration>${basedir}/target/classes/activemq/server0</configuration>
-                  </configuration>
-               </execution>
-               <execution>
-                  <id>start0</id>
-                  <goals>
-                     <goal>cli</goal>
-                  </goals>
-                  <configuration>
-                     <ignore>${noServer}</ignore>
-                     <spawn>true</spawn>
-                     <location>${basedir}/target/server0</location>
-                     <testURI>tcp://localhost:61616</testURI>
-                     <args>
-                        <param>run</param>
-                     </args>
-                     <name>server0</name>
-                  </configuration>
-               </execution>
-               <execution>
-                  <id>runClient</id>
-                  <goals>
-                     <goal>runClient</goal>
-                  </goals>
-                  <configuration>
-                     <clientClass>org.apache.activemq.artemis.core.example.VertxConnectorExample</clientClass>
-                  </configuration>
-               </execution>
-            </executions>
-            <dependencies>
-               <dependency>
-                  <groupId>org.apache.activemq.examples.modules</groupId>
-                  <artifactId>artemis-vertx-example</artifactId>
-                  <version>${project.version}</version>
-               </dependency>
-            </dependencies>
-         </plugin>
-      </plugins>
-   </build>
-</project>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/sub-modules/vertx/readme.html
----------------------------------------------------------------------
diff --git a/examples/broker-features/sub-modules/vertx/readme.html b/examples/broker-features/sub-modules/vertx/readme.html
deleted file mode 100644
index e8f053a..0000000
--- a/examples/broker-features/sub-modules/vertx/readme.html
+++ /dev/null
@@ -1,103 +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 Vert.x Connector Service 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>Vert.x Connector Service Example</h1>
-
-     <p>This example shows you how to configure ActiveMQ Artemis to use the Vert.x Connector Service.</p>
-
-     <p>ActiveMQ Artemis supports 2 types of Vert.x connector, incoming and outgoing.
-     Incoming connector consumes from Vert.x event bus and forwards to a configurable address.
-     Outgoing connector consumes from a configurable address and forwards to a configurable Vert.x event bus.
-     </p>
-
-     <p>In this example, an incoming connector and an outgoing connector are configured. A simple java Verticle
-     is deployed. The verticle registers a message handler on the outgoing connector's address ("outgoing.vertx.address").
-     A String message is sent to Vert.x event bus on the incoming connector's address("incoming.vertx.address").
-     The message then will be forwarded to a ActiveMQ Artemis queue by the incoming connector. The outgoing connector listens to
-     the ActiveMQ Artemis queue and forwards the message from ActiveMQ Artemis to Vert.x event bus on the outgoing connector's address.
-     The verticle finally receives the message from it's event bus.</p>
-
-     <p>For more information on Vert.x concept please visit the <a href="http://vertx.io/">Vertx site</a></p>
-
-     <h2>Example step-by-step</h2>
-     <p><i>To run the server, simply type <code>mvn verify</code>
-         from this directory.</p>
-
-     <ol>
-        <li>First we need to create a Vert.x PlatformManager</li>
-        <pre class="prettyprint">
-           <code>platformManager = PlatformLocator.factory.createPlatformManager(PORT, HOST);</code>
-        </pre>
-
-        <li>We deploy a Verticle using the platformManager</li>
-        <pre class="prettyprint">
-           <code>String verticle = "org.apache.activemq.artemis.core.example.ExampleVerticle";
-           platformManager.deployVerticle(verticle, null, new URL[0], 1, null,
-                  new Handler<AsyncResult<String>>(){
-
-                     @Override
-                     public void handle(AsyncResult<String> result)
-                     {
-                        if (!result.succeeded())
-                        {
-                           throw new RuntimeException("failed to deploy verticle", result.cause());
-                        }
-                        latch0.countDown();
-                     }
-
-           });</code>
-        </pre>
-
-        <li>We register a message handler with the event bus in the Verticle to listen on the outgoing connector's address.</li>
-        <pre class="prettyprint">
-           <code>EventBus eventBus = vertx.eventBus();
-           eventBus.registerHandler(VertxConnectorExample.OUTGOING,
-                      new Handler<Message<?>>() {
-                         @Override
-                         public void handle(Message<?> startMsg)
-                         {
-                            Object body = startMsg.body();
-                            System.out.println("Verticle receives a message: " + body);
-                            VertxConnectorExample.result.set(VertxConnectorExample.MSG.equals(body));
-                            latch0.countDown();
-                         }
-                      });
-           </code>
-        </pre>
-
-        <li>We send a message to incoming connector's address via event bus</li>
-        <pre class="prettyprint">
-           <code>
-              EventBus bus = platformManager.vertx().eventBus();
-              bus.send(INCOMING, MSG);
-           </code>
-        </pre>
-
-        <li>The message will eventually arrives at the Verticle's message handler.</li>
-     </ol>
-  </body>
-</html>


Mime
View raw message