You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/12/19 03:09:23 UTC
[2/4] activemq-artemis git commit: ARTEMIS-1546 Adding tests to
validate compatibility
ARTEMIS-1546 Adding tests to validate compatibility
https://issues.apache.org/jira/browse/ARTEMIS-1546
- the dependency scan is changed to allow adding an extra repository
- adding groovy so we won't require compilation dependencies (just runtime)
without needing reflection (thanks Groovy :) )
- Adding hornetq to the mesh of version tests
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/9ef90f8d
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/9ef90f8d
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/9ef90f8d
Branch: refs/heads/master
Commit: 9ef90f8defdce6845b6d01cb03613111972ecabd
Parents: ac17071
Author: Clebert Suconic <cl...@apache.org>
Authored: Wed Dec 13 21:53:19 2017 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Mon Dec 18 22:04:37 2017 -0500
----------------------------------------------------------------------
.../maven/ArtemisDependencyScanPlugin.java | 22 +
.../standard/send-acknowledgements-fail/pom.xml | 94 ++++
.../send-acknowledgements-fail/readme.html | 140 ++++++
.../example/SendAcknowledgementsExample.java | 151 ++++++
.../src/main/resources/jndi.properties | 20 +
pom.xml | 6 +
tests/compatibility-tests/pom.xml | 475 +++++++++++++++++++
.../artemis/tests/compatibility/GroovyRun.java | 118 +++++
.../main/resources/clients/artemisClient.groovy | 31 ++
.../main/resources/clients/hornetqClient.groovy | 33 ++
.../main/resources/meshTest/sendMessages.groovy | 205 ++++++++
.../sendAckTest/sendAckMessages.groovy | 97 ++++
.../src/main/resources/serial/serial.groovy | 54 +++
.../main/resources/servers/artemisServer.groovy | 61 +++
.../main/resources/servers/hornetqServer.groovy | 54 +++
.../artemis/tests/compatibility/MeshTest.java | 79 +++
.../tests/compatibility/SendAckTest.java | 78 +++
.../tests/compatibility/SerializationTest.java | 76 +++
.../tests/compatibility/VersionedBaseTest.java | 179 +++++++
.../tests/compatibility/package-info.java | 23 +
tests/pom.xml | 1 +
.../artemis/tests/util/SpawnedVMSupport.java | 63 ++-
22 files changed, 2057 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisDependencyScanPlugin.java
----------------------------------------------------------------------
diff --git a/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisDependencyScanPlugin.java b/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisDependencyScanPlugin.java
index e59bc36..4f1d1d8 100644
--- a/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisDependencyScanPlugin.java
+++ b/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisDependencyScanPlugin.java
@@ -19,6 +19,8 @@ package org.apache.activemq.artemis.maven;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.StandardCopyOption;
+import java.util.ArrayList;
+import java.util.List;
import java.util.Map;
import java.util.Set;
@@ -29,6 +31,7 @@ import org.apache.maven.plugins.annotations.LifecyclePhase;
import org.apache.maven.plugins.annotations.Mojo;
import org.apache.maven.plugins.annotations.Parameter;
import org.apache.maven.project.MavenProject;
+import org.eclipse.aether.repository.RemoteRepository;
@Mojo(name = "dependency-scan", defaultPhase = LifecyclePhase.VERIFY)
public class ArtemisDependencyScanPlugin extends ArtemisAbstractPlugin {
@@ -48,6 +51,9 @@ public class ArtemisDependencyScanPlugin extends ArtemisAbstractPlugin {
private String[] libList;
@Parameter
+ private String[] extraRepositories;
+
+ @Parameter
private String variableName;
@Parameter
@@ -64,6 +70,16 @@ public class ArtemisDependencyScanPlugin extends ArtemisAbstractPlugin {
@Override
protected void doExecute() throws MojoExecutionException, MojoFailureException {
+
+ int repositories = 0;
+ List<RemoteRepository> listRepo = new ArrayList<>();
+ if (extraRepositories != null) {
+ for (String strRepo: extraRepositories) {
+ RemoteRepository repo = new RemoteRepository.Builder("repo" + (repositories++), "default", strRepo).build();
+ listRepo.add(repo);
+ remoteRepos.add(repo);
+ }
+ }
getLog().info("Local " + localRepository);
MavenProject project = (MavenProject) getPluginContext().get("project");
@@ -102,7 +118,13 @@ public class ArtemisDependencyScanPlugin extends ArtemisAbstractPlugin {
} catch (Throwable e) {
getLog().error(e);
throw new MojoFailureException(e.getMessage());
+ } finally {
+ for (RemoteRepository repository : listRepo) {
+ remoteRepos.remove(repository);
+ }
}
+
+
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/examples/features/standard/send-acknowledgements-fail/pom.xml
----------------------------------------------------------------------
diff --git a/examples/features/standard/send-acknowledgements-fail/pom.xml b/examples/features/standard/send-acknowledgements-fail/pom.xml
new file mode 100644
index 0000000..369f94e
--- /dev/null
+++ b/examples/features/standard/send-acknowledgements-fail/pom.xml
@@ -0,0 +1,94 @@
+<?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>2.5.0-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>send-acknowledgements-fail</artifactId>
+ <packaging>jar</packaging>
+ <name>ActiveMQ Artemis JMS Send Acknowledgements Example</name>
+
+ <properties>
+ <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-jms-client-all</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <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>
+ <instance>${basedir}/target/server0</instance>
+ <args>
+ <arg>--global-max-size</arg>
+ <arg>10M</arg>
+ </args>
+ </configuration>
+ </execution>
+ <execution>
+ <id>runClient</id>
+ <goals>
+ <goal>runClient</goal>
+ </goals>
+ <configuration>
+ <clientClass>org.apache.activemq.artemis.jms.example.SendAcknowledgementsExample</clientClass>
+ <args>
+ <param>${basedir}/target/server0</param>
+ </args>
+ </configuration>
+ </execution>
+ </executions>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.activemq.examples.broker</groupId>
+ <artifactId>send-acknowledgements-fail</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ </plugin>
+ </plugins>
+ </build>
+
+</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/examples/features/standard/send-acknowledgements-fail/readme.html
----------------------------------------------------------------------
diff --git a/examples/features/standard/send-acknowledgements-fail/readme.html b/examples/features/standard/send-acknowledgements-fail/readme.html
new file mode 100644
index 0000000..fcc37fc
--- /dev/null
+++ b/examples/features/standard/send-acknowledgements-fail/readme.html
@@ -0,0 +1,140 @@
+<!--
+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 Asynchronous Send Acknowledgements 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>Asynchronous Send Acknowledgements 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>Asynchronous Send Acknowledgements are an advanced feature of ActiveMQ Artemis which allow you to
+ receive acknowledgements that messages were successfully received at the server in a separate thread to the sending thread<p/>
+ <p>In this example we create a normal JMS session, then set a SendAcknowledgementHandler on the JMS
+ session's underlying core session. We send many messages to the server without blocking and asynchronously
+ receive send acknowledgements via the SendAcknowledgementHandler.
+
+ <p>For more information on Asynchronous Send Acknowledgements please see the user manual</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();</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 look-up the JMS connection factory object from JNDI</li>
+ <pre class="prettyprint">
+ <code>ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory");</code>
+ </pre>
+
+ <li>We create a JMS connection</li>
+ <pre class="prettyprint">
+ <code>connection = cf.createConnection();</code>
+ </pre>
+
+ <li>Define a SendAcknowledgementHandler which will receive asynchronous acknowledgements</li>
+ <pre class="prettyprint">
+ <code>
+ class MySendAcknowledgementsHandler implements SendAcknowledgementHandler
+ {
+ int count = 0;
+
+ public void sendAcknowledged(final Message message)
+ {
+ System.out.println("Received send acknowledgement for message " + count++);
+ }
+ }
+ </code>
+ </pre>
+
+ <li>Create a JMS session</li>
+ <pre class="prettyprint">
+ <code>Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);</code>
+ </pre>
+
+ <li>Set the handler on the underlying core session</li>
+ <pre class="prettyprint">
+ <code>
+ ClientSession coreSession = ((ActiveMQSession)session).getCoreSession();
+
+ coreSession.setSendAcknowledgementHandler(new MySendAcknowledgementsHandler());
+
+ </code>
+ </pre>
+
+ <li>Create a JMS Message Producer</li>
+ <pre class="prettyprint">
+ <code>
+ MessageProducer producer = session.createProducer(queue);
+
+ producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
+ </code>
+ </pre>
+
+ <li>Send 5000 messages, the handler will get called asynchronously some time later after the messages are sent.</li>
+ <pre class="prettyprint">
+ <code>
+ final int numMessages = 5000;
+
+ for (int i = 0; i < numMessages; i++)
+ {
+ javax.jms.Message jmsMessage = session.createMessage();
+
+ producer.send(jmsMessage);
+
+ System.out.println("Sent message " + i);
+ }
+ </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/9ef90f8d/examples/features/standard/send-acknowledgements-fail/src/main/java/org/apache/activemq/artemis/jms/example/SendAcknowledgementsExample.java
----------------------------------------------------------------------
diff --git a/examples/features/standard/send-acknowledgements-fail/src/main/java/org/apache/activemq/artemis/jms/example/SendAcknowledgementsExample.java b/examples/features/standard/send-acknowledgements-fail/src/main/java/org/apache/activemq/artemis/jms/example/SendAcknowledgementsExample.java
new file mode 100644
index 0000000..86c4333
--- /dev/null
+++ b/examples/features/standard/send-acknowledgements-fail/src/main/java/org/apache/activemq/artemis/jms/example/SendAcknowledgementsExample.java
@@ -0,0 +1,151 @@
+/*
+ * 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 java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
+import org.apache.activemq.artemis.api.core.Message;
+import org.apache.activemq.artemis.api.core.RoutingType;
+import org.apache.activemq.artemis.api.core.SimpleString;
+import org.apache.activemq.artemis.api.core.client.ActiveMQClient;
+import org.apache.activemq.artemis.api.core.client.ClientConsumer;
+import org.apache.activemq.artemis.api.core.client.ClientMessage;
+import org.apache.activemq.artemis.api.core.client.ClientProducer;
+import org.apache.activemq.artemis.api.core.client.ClientSession;
+import org.apache.activemq.artemis.api.core.client.ClientSessionFactory;
+import org.apache.activemq.artemis.api.core.client.SendAcknowledgementHandler;
+import org.apache.activemq.artemis.api.core.client.ServerLocator;
+import org.apache.activemq.artemis.util.ServerUtil;
+
+/**
+ * Asynchronous Send Acknowledgements are an advanced feature of ActiveMQ Artemis which allow you to
+ * receive acknowledgements that messages were successfully received at the server in a separate stream
+ * to the stream of messages being sent to the server.
+ * For more information please see the readme.html file
+ */
+public class SendAcknowledgementsExample {
+
+ private static Process server0;
+ private static final int numMessages = 30_000;
+ private static final SimpleString queueName = SimpleString.toSimpleString("testQueue");
+
+ public static void main(final String[] args) throws Exception {
+
+ for (int i = 0; i < 500; i++) {
+ System.out.println("$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$ Running test " + i);
+ server0 = ServerUtil.startServer(args[0], SendAcknowledgementsExample.class.getSimpleName() + "0", 0, 10000);
+ sendMessages();
+
+ server0 = ServerUtil.startServer(args[0], SendAcknowledgementsExample.class.getSimpleName() + "0", 0, 10000);
+ consumeMessages();
+ }
+ }
+
+ private static void sendMessages() throws Exception {
+ try {
+
+ ServerLocator locator = ActiveMQClient.createServerLocator("tcp://localhost:61616").setBlockOnDurableSend(false).setConfirmationWindowSize(1024 * 1024);
+
+ ClientSessionFactory factory = locator.createSessionFactory();
+
+ ClientSession session = factory.createSession(null, null, false, true, true, false, ActiveMQClient.DEFAULT_ACK_BATCH_SIZE);
+
+ try {
+ // Tried with and without the createAddress
+ session.createAddress(queueName, RoutingType.MULTICAST, false);
+ session.createQueue(queueName.toString(), RoutingType.MULTICAST, queueName.toString(), true);
+ } catch (Exception e) {
+ }
+
+ ClientProducer producer = session.createProducer(queueName);
+
+ CountDownLatch latch = new CountDownLatch(numMessages);
+
+ for (int i = 0; i < numMessages; i++) {
+
+ if (i % 10000 == 0) {
+ System.out.println("Send " + i);
+ }
+ ClientMessage message = session.createMessage(true);
+ message.getBodyBuffer().writeBytes("hello world".getBytes());
+
+ // tried with producer.send(queueName, message, ...);; // didn't make a difference
+
+ producer.send(message, new SendAcknowledgementHandler() {
+ @Override
+ public void sendAcknowledged(Message message) {
+ latch.countDown();
+ if (latch.getCount() % 10_000 == 0) {
+ System.out.println(latch.getCount() + " to go");
+ }
+ }
+ });
+ }
+ latch.await(10, TimeUnit.MINUTES);
+ } finally {
+ server0.destroy();
+ server0.waitFor();
+ }
+ }
+
+ private static void consumeMessages() throws Exception {
+ try {
+
+ ServerLocator locator = ActiveMQClient.createServerLocator("tcp://localhost:61616").setBlockOnDurableSend(false).setConfirmationWindowSize(-1);
+
+ ClientSessionFactory factory = locator.createSessionFactory();
+
+ ClientSession session = factory.createSession(null, null, false, false, false, false, ActiveMQClient.DEFAULT_ACK_BATCH_SIZE);
+
+ ClientConsumer consumer = session.createConsumer(queueName);
+
+ session.start();
+
+ for (int i = 0; i < numMessages; i++) {
+
+ if (i % 10000 == 0) {
+ System.out.println("Received " + i);
+ }
+
+ ClientMessage message = consumer.receive(5000);
+ message.acknowledge();
+
+ if (message == null) {
+ System.err.println("Expected message at " + i);
+ System.exit(-1);
+ }
+ }
+
+ session.commit();
+
+ ClientMessage message = consumer.receiveImmediate();
+ if (message != null) {
+ System.err.println("Received too many messages");
+ System.exit(-1);
+ }
+
+ session.close();
+ locator.close();
+
+ } finally {
+ server0.destroy();
+ server0.waitFor();
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/examples/features/standard/send-acknowledgements-fail/src/main/resources/jndi.properties
----------------------------------------------------------------------
diff --git a/examples/features/standard/send-acknowledgements-fail/src/main/resources/jndi.properties b/examples/features/standard/send-acknowledgements-fail/src/main/resources/jndi.properties
new file mode 100644
index 0000000..8421f25
--- /dev/null
+++ b/examples/features/standard/send-acknowledgements-fail/src/main/resources/jndi.properties
@@ -0,0 +1,20 @@
+# 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?confirmationWindowSize=1048576
+queue.queue/exampleQueue=exampleQueue
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 885b970..1baad38 100644
--- a/pom.xml
+++ b/pom.xml
@@ -111,6 +111,9 @@
<version.org.jacoco>0.7.9</version.org.jacoco>
<version.org.jacoco.plugin>0.7.9</version.org.jacoco.plugin>
+ <!-- used on tests -->
+ <groovy.version>2.4.3</groovy.version>
+
<owasp.version>1.4.3</owasp.version>
<spring.version>5.0.1.RELEASE</spring.version>
@@ -126,6 +129,7 @@
<skipJmsTests>true</skipJmsTests>
<skipExtraTests>true</skipExtraTests>
<skipIntegrationTests>true</skipIntegrationTests>
+ <skipCompatibilityTests>true</skipCompatibilityTests>
<skipSmokeTests>true</skipSmokeTests>
<skipJoramTests>true</skipJoramTests>
<skipTimingTests>true</skipTimingTests>
@@ -959,6 +963,7 @@
<skipJmsTests>false</skipJmsTests>
<skipJoramTests>false</skipJoramTests>
<skipIntegrationTests>false</skipIntegrationTests>
+ <skipCompatibilityTests>false</skipCompatibilityTests>
<skipSmokeTests>false</skipSmokeTests>
<skipTimingTests>true</skipTimingTests>
<skipConcurrentTests>false</skipConcurrentTests>
@@ -1005,6 +1010,7 @@
<skipExtraTests>true</skipExtraTests>
<skipStyleCheck>false</skipStyleCheck>
<skipLicenseCheck>false</skipLicenseCheck>
+ <skipCompatibilityTests>false</skipCompatibilityTests>
</properties>
</profile>
<profile>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/pom.xml
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/pom.xml b/tests/compatibility-tests/pom.xml
new file mode 100644
index 0000000..443b0ed
--- /dev/null
+++ b/tests/compatibility-tests/pom.xml
@@ -0,0 +1,475 @@
+<!--
+ 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.tests</groupId>
+ <artifactId>artemis-tests-pom</artifactId>
+ <version>2.5.0-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>compatibility-tests</artifactId>
+ <packaging>jar</packaging>
+ <name>ActiveMQ Artemis Compatibility Tests</name>
+
+ <properties>
+ <activemq.basedir>${project.basedir}/../..</activemq.basedir>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-server</artifactId>
+ <version>${project.version}</version>
+ <scope>test</scope>
+ <type>test-jar</type>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-commons</artifactId>
+ <version>${project.version}</version>
+ <scope>test</scope>
+ <type>test-jar</type>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq.tests</groupId>
+ <artifactId>unit-tests</artifactId>
+ <version>${project.version}</version>
+ <scope>test</scope>
+ <type>test-jar</type>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-core-client</artifactId>
+ <version>${project.version}</version>
+ <scope>test</scope>
+ <type>test-jar</type>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-jms-client</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-ra</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-cli</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-commons</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-spring-integration</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-journal</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-jdbc-store</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-amqp-protocol</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-stomp-protocol</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-openwire-protocol</artifactId>
+ <version>${project.version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>org.apache.geronimo.specs</groupId>
+ <artifactId>geronimo-jms_1.1_spec</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-hornetq-protocol</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-server</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-native</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-service-extensions</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq.tests</groupId>
+ <artifactId>artemis-test-support</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-features</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq.rest</groupId>
+ <artifactId>artemis-rest</artifactId>
+ <version>2.5.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.codehaus.groovy</groupId>
+ <artifactId>groovy-all</artifactId>
+ <version>${groovy.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-junit</artifactId>
+ <version>${project.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>activemq-client</artifactId>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>org.apache.geronimo.specs</groupId>
+ <artifactId>geronimo-jms_1.1_spec</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-mqtt-protocol</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.fusesource.mqtt-client</groupId>
+ <artifactId>mqtt-client</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.geronimo.specs</groupId>
+ <artifactId>geronimo-json_1.0_spec</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.geronimo.specs</groupId>
+ <artifactId>geronimo-j2ee-connector_1.5_spec</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.geronimo.specs</groupId>
+ <artifactId>geronimo-jta_1.1_spec</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.geronimo.specs</groupId>
+ <artifactId>geronimo-jms_2.0_spec</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.johnzon</groupId>
+ <artifactId>johnzon-core</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-buffer</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-codec-http</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-codec-mqtt</artifactId>
+ <version>${netty.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-handler</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-transport</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.jboss.logging</groupId>
+ <artifactId>jboss-logging-processor</artifactId>
+ <scope>provided</scope>
+ <optional>true</optional>
+ </dependency>
+ <dependency>
+ <groupId>org.jboss.logging</groupId>
+ <artifactId>jboss-logging-annotations</artifactId>
+ <scope>provided</scope>
+ <optional>true</optional>
+ </dependency>
+ <dependency>
+ <groupId>org.jboss.logging</groupId>
+ <artifactId>jboss-logging</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.jboss.logmanager</groupId>
+ <artifactId>jboss-logmanager</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.qpid</groupId>
+ <artifactId>qpid-jms-client</artifactId>
+ <version>${qpid.jms.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.qpid</groupId>
+ <artifactId>proton-j</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ <version>1.7.5</version>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <testResources>
+ <testResource>
+ <directory>src/test/resources</directory>
+ <filtering>true</filtering>
+ </testResource>
+ </testResources>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-jar-plugin</artifactId>
+ <executions>
+ <execution>
+ <phase>test</phase>
+ <goals>
+ <goal>test-jar</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-maven-plugin</artifactId>
+ <executions>
+ <!-- The executions of dependency-scan will calculate dependencies for each specific version used here on this testsuite. -->
+ <execution>
+ <id>snapshot-check</id>
+ <phase>compile</phase>
+ <goals>
+ <goal>dependency-scan</goal>
+ </goals>
+ <configuration>
+ <libListWithDeps>
+ <arg>org.apache.activemq:artemis-jms-server:${project.version}</arg>
+ <arg>org.apache.activemq:artemis-jms-client:${project.version}</arg>
+ <arg>org.apache.activemq:artemis-hornetq-protocol:${project.version}</arg>
+ <arg>org.apache.activemq:artemis-amqp-protocol:${project.version}</arg>
+ <arg>org.apache.activemq:artemis-hornetq-protocol:${project.version}</arg>
+ <arg>org.codehaus.groovy:groovy-all:${groovy.version}</arg>
+ </libListWithDeps>
+ <libList>
+ <arg>org.apache.activemq.tests:compatibility-tests:${project.version}</arg>
+ </libList>
+ <variableName>ARTEMIS-SNAPSHOT</variableName>
+ </configuration>
+ </execution>
+ <execution>
+ <phase>compile</phase>
+ <goals>
+ <goal>dependency-scan</goal>
+ </goals>
+ <id>240-check</id>
+ <configuration>
+ <libListWithDeps>
+ <arg>org.apache.activemq:artemis-jms-server:2.4.0</arg>
+ <arg>org.apache.activemq:artemis-jms-client:2.4.0</arg>
+ <arg>org.apache.activemq:artemis-hornetq-protocol:2.4.0</arg>
+ <arg>org.apache.activemq:artemis-amqp-protocol:2.4.0</arg>
+ <arg>org.apache.activemq:artemis-hornetq-protocol:2.4.0</arg>
+ <arg>org.codehaus.groovy:groovy-all:${groovy.version}</arg>
+ </libListWithDeps>
+ <libList>
+ <arg>org.apache.activemq.tests:compatibility-tests:${project.version}</arg>
+ </libList>
+ <variableName>ARTEMIS-240</variableName>
+ </configuration>
+ </execution>
+ <execution>
+ <id>140-check</id>
+ <phase>compile</phase>
+ <goals>
+ <goal>dependency-scan</goal>
+ </goals>
+ <configuration>
+ <libListWithDeps>
+ <arg>org.apache.activemq:artemis-jms-server:1.4.0</arg>
+ <arg>org.apache.activemq:artemis-jms-client:1.4.0</arg>
+ <arg>org.apache.activemq:artemis-hornetq-protocol:1.4.0</arg>
+ <arg>org.apache.activemq:artemis-amqp-protocol:1.4.0</arg>
+ <arg>org.apache.activemq:artemis-hornetq-protocol:1.4.0</arg>
+ <arg>org.codehaus.groovy:groovy-all:${groovy.version}</arg>
+ </libListWithDeps>
+ <libList>
+ <arg>org.apache.activemq.tests:compatibility-tests:${project.version}</arg>
+ </libList>
+ <variableName>ARTEMIS-140</variableName>
+ </configuration>
+ </execution>
+ <execution>
+ <id>hornetq-235</id>
+ <phase>compile</phase>
+ <goals>
+ <goal>dependency-scan</goal>
+ </goals>
+ <configuration>
+ <extraRepositories>
+ <!-- some of the dependencies are not on maven central,
+ and the artemis maven plugin has the capability of using this extra repo -->
+ <arg>https://repository.jboss.org/nexus/content/groups/public</arg>
+ </extraRepositories>
+ <libListWithDeps>
+ <arg>org.hornetq:hornetq-jms-server:2.4.7.Final</arg>
+ <arg>org.codehaus.groovy:groovy-all:${groovy.version}</arg>
+ </libListWithDeps>
+ <libList>
+ <arg>org.apache.activemq.tests:compatibility-tests:${project.version}</arg>
+ </libList>
+ <variableName>HORNETQ-235</variableName>
+ </configuration>
+ </execution>
+ <execution>
+ <id>hornetq-247</id>
+ <phase>compile</phase>
+ <goals>
+ <goal>dependency-scan</goal>
+ </goals>
+ <configuration>
+ <extraRepositories>
+ <!-- some of the dependencies are not on maven central,
+ and the artemis maven plugin has the capability of using this extra repo -->
+ <arg>https://repository.jboss.org/nexus/content/groups/public</arg>
+ </extraRepositories>
+ <libListWithDeps>
+ <arg>org.hornetq:hornetq-jms-server:2.4.7.Final</arg>
+ <arg>org.codehaus.groovy:groovy-all:${groovy.version}</arg>
+ </libListWithDeps>
+ <libList>
+ <arg>org.apache.activemq.tests:compatibility-tests:${project.version}</arg>
+ </libList>
+ <variableName>HORNETQ-247</variableName>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <configuration>
+ <systemProperties>
+ <property>
+ <name>ARTEMIS-SNAPSHOT</name>
+ <value>${ARTEMIS-SNAPSHOT}</value>
+ </property>
+ <property>
+ <name>ARTEMIS-240</name>
+ <value>${ARTEMIS-240}</value>
+ </property>
+ <property>
+ <name>ARTEMIS-140</name>
+ <value>${ARTEMIS-140}</value>
+ </property>
+ <property>
+ <name>HORNETQ-235</name>
+ <value>${HORNETQ-235}</value>
+ </property>
+ <property>
+ <name>HORNETQ-247</name>
+ <value>${HORNETQ-247}</value>
+ </property>
+ </systemProperties>
+ <skipTests>${skipCompatibilityTests}</skipTests>
+ <argLine>-Djgroups.bind_addr=::1 ${activemq-surefire-argline}</argLine>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.servicemix.tooling</groupId>
+ <artifactId>depends-maven-plugin</artifactId>
+ <version>1.2</version>
+ <executions>
+ <execution>
+ <id>generate-depends-file</id>
+ <goals>
+ <goal>generate-depends-file</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+
+ <distributionManagement>
+ <repository>
+ <id>jboss-releases-repository</id>
+ <name>JBoss Releases Repository</name>
+ <url>https://repository.jboss.org/nexus/service/local/staging/deploy/maven2/</url>
+ </repository>
+ <snapshotRepository>
+ <id>jboss-snapshots-repository</id>
+ <name>JBoss Snapshots Repository</name>
+ <url>https://repository.jboss.org/nexus/content/repositories/snapshots/</url>
+ </snapshotRepository>
+ </distributionManagement>
+
+
+</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/main/java/org/apache/activemq/artemis/tests/compatibility/GroovyRun.java
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/main/java/org/apache/activemq/artemis/tests/compatibility/GroovyRun.java b/tests/compatibility-tests/src/main/java/org/apache/activemq/artemis/tests/compatibility/GroovyRun.java
new file mode 100644
index 0000000..08e6c34
--- /dev/null
+++ b/tests/compatibility-tests/src/main/java/org/apache/activemq/artemis/tests/compatibility/GroovyRun.java
@@ -0,0 +1,118 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.tests.compatibility;
+
+import java.io.IOException;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.net.URL;
+
+import groovy.lang.Binding;
+import groovy.lang.GroovyShell;
+
+public class GroovyRun {
+
+ public static final String SNAPSHOT = "ARTEMIS-SNAPSHOT";
+ public static final String ONE_FOUR = "ARTEMIS-140";
+ public static final String TWO_FOUR = "ARTEMIS-240";
+ public static final String HORNETQ_235 = "HORNETQ-235";
+ public static final String HORNETQ_247 = "HORNETQ-247";
+
+ public static final String WORD_START = "**SERVER STARTED**";
+
+ public static Binding binding = new Binding();
+ public static GroovyShell shell = new GroovyShell(binding);
+
+ // Called with reflection
+ public static void doMain(String script, String... arg) throws Throwable {
+ int i = 0;
+ for (String a : arg) {
+ System.out.println("[" + (i++) + "]=" + a);
+ }
+ System.out.println();
+
+ evaluate(script, "arg", arg);
+
+ System.out.println(WORD_START);
+ }
+
+ /**
+ * This can be called from the scripts as well.
+ * The scripts will use this method instead of its own groovy method.
+ * As a classloader operation needs to be done here.
+ */
+ public static void evaluate(String script,
+ String argVariableName,
+ String[] arg) throws URISyntaxException, IOException {
+ URL scriptURL = GroovyRun.class.getClassLoader().getResource(script);
+ if (scriptURL == null) {
+ throw new RuntimeException("cannot find " + script);
+ }
+ URI scriptURI = scriptURL.toURI();
+
+ binding.setVariable(argVariableName, arg);
+
+ shell.evaluate(scriptURI);
+ }
+
+ // Called with reflection
+ public static void execute(String script) throws Throwable {
+ shell.evaluate(script);
+ }
+
+ public static void assertNotNull(Object value) {
+ if (value == null) {
+ throw new RuntimeException("Null value");
+ }
+ }
+
+ public static void assertNull(Object value) {
+ if (value != null) {
+ throw new RuntimeException("Expected Null value");
+ }
+ }
+
+ public static void assertTrue(boolean value) {
+ if (!value) {
+ throw new RuntimeException("Expected true");
+ }
+ }
+
+ public static void assertEquals(Object value1, Object value2) {
+ if (!value1.equals(value2)) {
+ throw new RuntimeException(value1 + "!=" + value2);
+ }
+ }
+
+ public static void assertEquals(int value1, int value2) {
+ if (value1 != value2) {
+ throw new RuntimeException(value1 + "!=" + value2);
+ }
+ }
+
+ public static void assertEquals(byte[] value1, byte[] value2) {
+
+ assertEquals(value1.length, value2.length);
+
+ for (int i = 0; i < value1.length; i++) {
+ assertEquals(value1[i], value2[i]);
+ }
+ }
+
+
+ public static byte getSamplebyte(final long position) {
+ return (byte) ('a' + position % ('z' - 'a' + 1));
+ }
+}
+
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/main/resources/clients/artemisClient.groovy
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/main/resources/clients/artemisClient.groovy b/tests/compatibility-tests/src/main/resources/clients/artemisClient.groovy
new file mode 100644
index 0000000..e729ebb
--- /dev/null
+++ b/tests/compatibility-tests/src/main/resources/clients/artemisClient.groovy
@@ -0,0 +1,31 @@
+package clients
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.
+ */
+
+// Create a client connection factory
+
+import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory
+import org.apache.activemq.artemis.tests.compatibility.GroovyRun;
+
+println("serverType " + serverArg[0]);
+
+if (serverArg[0].startsWith("HORNETQ")) {
+ cf = new ActiveMQConnectionFactory("tcp://localhost:61616?protocolManagerFactoryStr=org.apache.activemq.artemis.core.protocol.hornetq.client.HornetQClientProtocolManagerFactory&confirmationWindowSize=1048576&blockOnDurableSend=false");
+} else {
+ cf = new ActiveMQConnectionFactory("tcp://localhost:61616?confirmationWindowSize=1048576&blockOnDurableSend=false");
+}
+
+
+GroovyRun.assertTrue(!cf.getServerLocator().isBlockOnDurableSend());
+GroovyRun.assertEquals(1048576, cf.getServerLocator().getConfirmationWindowSize());
+
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/main/resources/clients/hornetqClient.groovy
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/main/resources/clients/hornetqClient.groovy b/tests/compatibility-tests/src/main/resources/clients/hornetqClient.groovy
new file mode 100644
index 0000000..63bf4e6
--- /dev/null
+++ b/tests/compatibility-tests/src/main/resources/clients/hornetqClient.groovy
@@ -0,0 +1,33 @@
+package clients
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.
+ */
+
+// This script is called by sendMessages.groovy
+
+import javax.jms.ConnectionFactory;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.hornetq.api.core.TransportConfiguration;
+import org.hornetq.api.jms.HornetQJMSConstants;
+import org.hornetq.core.message.impl.MessageImpl;
+import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory;
+import org.hornetq.core.remoting.impl.netty.TransportConstants;
+import org.hornetq.jms.client.HornetQJMSConnectionFactory;
+
+
+properties = new HashMap();
+properties.put(TransportConstants.HOST_PROP_NAME, "localhost");
+properties.put(TransportConstants.PORT_PROP_NAME, "61616");
+configuration = new TransportConfiguration(NettyConnectorFactory.class.getName(), properties);
+cf = new HornetQJMSConnectionFactory(false, configuration);
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/main/resources/meshTest/sendMessages.groovy
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/main/resources/meshTest/sendMessages.groovy b/tests/compatibility-tests/src/main/resources/meshTest/sendMessages.groovy
new file mode 100644
index 0000000..fdfddee
--- /dev/null
+++ b/tests/compatibility-tests/src/main/resources/meshTest/sendMessages.groovy
@@ -0,0 +1,205 @@
+package meshTest
+
+import org.apache.activemq.artemis.api.core.SimpleString
+import org.apache.activemq.artemis.tests.compatibility.GroovyRun
+
+import javax.jms.*
+
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.
+ */
+
+// starts an artemis server
+String serverType = arg[0];
+String clientType = arg[1];
+String operation = arg[2];
+
+
+String queueName = "queue";
+
+int LARGE_MESSAGE_SIZE = 10 * 1024;
+
+String propertyLargeMessage = "JMS_AMQ_InputStream";
+HDR_DUPLICATE_DETECTION_ID = "_AMQ_DUPL_ID";
+
+if (clientType.startsWith("HORNETQ")) {
+ HDR_DUPLICATE_DETECTION_ID = "_HQ_DUPL_ID";
+ propertyLargeMessage = "JMS_HQ_InputStream"
+}
+
+BYTES_BODY = new byte[3];
+BYTES_BODY[0] = (byte) 0x77;
+BYTES_BODY[1] = (byte) 0x77;
+BYTES_BODY[2] = (byte) 0x77;
+
+String textBody = "a rapadura e doce mas nao e mole nao";
+
+
+println("serverType " + serverType);
+
+if (clientType.startsWith("ARTEMIS")) {
+ // Can't depend directly on artemis, otherwise it wouldn't compile in hornetq
+ GroovyRun.evaluate("clients/artemisClient.groovy", "serverArg", serverType);
+} else {
+ // Can't depend directly on hornetq, otherwise it wouldn't compile in artemis
+ GroovyRun.evaluate("clients/hornetqClient.groovy", "serverArg");
+}
+
+
+Connection connection = cf.createConnection();
+Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
+Queue queue = session.createQueue(queueName);
+
+if (operation.equals("sendAckMessages")) {
+ MessageProducer producer = session.createProducer(queue);
+ producer.setDeliveryMode(DeliveryMode.PERSISTENT);
+
+ System.out.println("Sending messages");
+
+ TextMessage message = session.createTextMessage(textBody);
+ message.setStringProperty(HDR_DUPLICATE_DETECTION_ID, "some-duplicate");
+ message.setStringProperty("prop", "test");
+ producer.send(message);
+
+ BytesMessage bytesMessage = session.createBytesMessage();
+ bytesMessage.writeBytes(BYTES_BODY);
+ producer.send(bytesMessage);
+
+
+ for (int i = 0; i < 10; i++) {
+ BytesMessage m = session.createBytesMessage();
+ m.setIntProperty("count", i);
+
+ m.setObjectProperty(propertyLargeMessage, createFakeLargeStream(LARGE_MESSAGE_SIZE));
+
+ producer.send(m);
+ }
+
+ producer.send(session.createObjectMessage("rapadura"));
+
+ MapMessage mapMessage = session.createMapMessage();
+ mapMessage.setString("prop", "rapadura")
+ producer.send(mapMessage);
+
+ StreamMessage streamMessage = session.createStreamMessage();
+ streamMessage.writeString("rapadura");
+ streamMessage.writeString("doce");
+ streamMessage.writeInt(33);
+ producer.send(streamMessage);
+
+ Message plain = session.createMessage();
+ plain.setStringProperty("plain", "doce");
+ producer.send(plain);
+
+ session.commit();
+
+ connection.close();
+ System.out.println("Message sent");
+} else if (operation.equals("receiveMessages")) {
+ MessageConsumer consumer = session.createConsumer(queue);
+ connection.start();
+
+ System.out.println("Receiving messages");
+
+ TextMessage message = (TextMessage) consumer.receive(5000);
+ GroovyRun.assertNotNull(message);
+ GroovyRun.assertEquals(textBody, message.getText());
+ GroovyRun.assertEquals("test", message.getStringProperty("prop"));
+ GroovyRun.assertEquals("some-duplicate", message.getStringProperty(HDR_DUPLICATE_DETECTION_ID));
+
+ BytesMessage bm = (BytesMessage) consumer.receive(5000);
+ GroovyRun.assertNotNull(bm);
+
+ GroovyRun.assertEquals(3L, bm.getBodyLength());
+
+ byte[] body = new byte[3];
+ bm.readBytes(body);
+
+ GroovyRun.assertEquals(BYTES_BODY, body);
+
+ for (int m = 0; m < 10; m++) {
+ BytesMessage rm = (BytesMessage) consumer.receive(10000);
+ GroovyRun.assertNotNull(rm);
+ GroovyRun.assertEquals(m, rm.getIntProperty("count"));
+
+ byte[] data = new byte[1024];
+
+ System.out.println("Message = " + rm);
+
+ for (int i = 0; i < LARGE_MESSAGE_SIZE; i += 1024) {
+ int numberOfBytes = rm.readBytes(data);
+ GroovyRun.assertEquals(1024, numberOfBytes);
+ for (int j = 0; j < 1024; j++) {
+ GroovyRun.assertEquals(GroovyRun.getSamplebyte(i + j), data[j]);
+ }
+ }
+ }
+
+
+ ObjectMessage obj = consumer.receive(5000);
+ GroovyRun.assertNotNull(obj);
+ GroovyRun.assertEquals("rapadura", obj.getObject().toString());
+
+ MapMessage mapMessage = consumer.receive(5000);
+ GroovyRun.assertNotNull(mapMessage);
+ GroovyRun.assertEquals("rapadura", mapMessage.getString("prop"));
+
+ StreamMessage streamMessage = consumer.receive(5000);
+ GroovyRun.assertNotNull(streamMessage);
+ GroovyRun.assertEquals("rapadura", streamMessage.readString());
+ GroovyRun.assertEquals("doce", streamMessage.readString());
+ GroovyRun.assertTrue(streamMessage.readInt() == 33);
+
+ Message plain = consumer.receive(5000);
+ GroovyRun.assertNotNull(plain);
+ GroovyRun.assertEquals("doce", plain.getStringProperty("plain"));
+
+ session.commit();
+ connection.close();
+ System.out.println("Message received");
+} else {
+ throw new RuntimeException("Invalid operation " + operation);
+}
+
+
+// Creates a Fake LargeStream without using a real file
+InputStream createFakeLargeStream(final long size) throws Exception {
+ return new InputStream() {
+ private long count;
+
+ private boolean closed = false;
+
+ @Override
+ void close() throws IOException {
+ super.close();
+ closed = true;
+ }
+
+ @Override
+ int read() throws IOException {
+ if (closed) {
+ throw new IOException("Stream was closed");
+ }
+ if (count++ < size) {
+ return GroovyRun.getSamplebyte(count - 1);
+ }
+ else {
+ return -1;
+ }
+ }
+
+ };
+
+}
+
+
+
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/main/resources/sendAckTest/sendAckMessages.groovy
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/main/resources/sendAckTest/sendAckMessages.groovy b/tests/compatibility-tests/src/main/resources/sendAckTest/sendAckMessages.groovy
new file mode 100644
index 0000000..2b994bf
--- /dev/null
+++ b/tests/compatibility-tests/src/main/resources/sendAckTest/sendAckMessages.groovy
@@ -0,0 +1,97 @@
+package meshTest
+
+import org.apache.activemq.artemis.api.core.SimpleString
+import org.apache.activemq.artemis.tests.compatibility.GroovyRun
+
+import javax.jms.*
+import java.util.concurrent.CountDownLatch
+import java.util.concurrent.TimeUnit
+
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.
+ */
+
+// starts an artemis server
+String serverType = arg[0];
+String clientType = arg[1];
+String operation = arg[2];
+
+
+String queueName = "queue";
+
+
+String textBody = "a rapadura e doce mas nao e mole nao";
+
+println("serverType " + serverType);
+
+if (clientType.startsWith("ARTEMIS")) {
+ // Can't depend directly on artemis, otherwise it wouldn't compile in hornetq
+ GroovyRun.evaluate("clients/artemisClient.groovy", "serverArg", serverType);
+} else {
+ // Can't depend directly on hornetq, otherwise it wouldn't compile in artemis
+ GroovyRun.evaluate("clients/hornetqClient.groovy", "serverArg");
+}
+
+
+Connection connection = cf.createConnection();
+Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+Queue queue = session.createQueue(queueName);
+
+if (operation.equals("sendAckMessages")) {
+
+ CountDownLatch latch = new CountDownLatch(10);
+
+ CompletionListener completionListener = new CompletionListener() {
+ @Override
+ void onCompletion(Message message) {
+ latch.countDown();
+ }
+
+ @Override
+ void onException(Message message, Exception exception) {
+
+ }
+ }
+
+ MessageProducer producer = session.createProducer(queue);
+ producer.setDeliveryMode(DeliveryMode.PERSISTENT);
+ for (int i = 0; i < 10; i++) {
+ producer.send(session.createTextMessage(textBody + i), completionListener);
+ }
+
+ GroovyRun.assertTrue(latch.await(10, TimeUnit.SECONDS));
+
+ System.out.println("Sending messages");
+ connection.close();
+ System.out.println("Message sent");
+} else if (operation.equals("receiveMessages")) {
+ MessageConsumer consumer = session.createConsumer(queue);
+ connection.start();
+
+ System.out.println("Receiving messages");
+
+ for (int i = 0; i < 10; i++) {
+ TextMessage message = consumer.receive(1000);
+ GroovyRun.assertNotNull(message);
+ GroovyRun.assertEquals(textBody + i, message.getText());
+ }
+
+ GroovyRun.assertNull(consumer.receiveNoWait());
+ connection.close();
+ System.out.println("Message received");
+} else {
+ throw new RuntimeException("Invalid operation " + operation);
+}
+
+
+
+
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/main/resources/serial/serial.groovy
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/main/resources/serial/serial.groovy b/tests/compatibility-tests/src/main/resources/serial/serial.groovy
new file mode 100644
index 0000000..1fc9dbd
--- /dev/null
+++ b/tests/compatibility-tests/src/main/resources/serial/serial.groovy
@@ -0,0 +1,54 @@
+package clients
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.
+ */
+
+// Create a client connection factory
+
+import org.apache.activemq.artemis.tests.compatibility.GroovyRun;
+import javax.jms.*;
+import org.apache.activemq.artemis.jms.client.*
+
+file = arg[0]
+method = arg[1]
+System.out.println("File::" + file);
+
+
+if (method.equals("write")) {
+ cf = new ActiveMQConnectionFactory("tcp://localhost:61616?confirmationWindowSize=1048576&blockOnDurableSend=false");
+ queue = new ActiveMQQueue("queue");
+ topic = new ActiveMQTopic("topic")
+
+ ObjectOutputStream objectOutputStream = new ObjectOutputStream(new FileOutputStream(file));
+ objectOutputStream.writeObject(cf);
+ objectOutputStream.writeObject(queue)
+ objectOutputStream.writeObject(topic)
+ objectOutputStream.close();
+} else {
+ ObjectInputStream inputStream = new ObjectInputStream(new FileInputStream(file))
+
+ cf = inputStream.readObject();
+ queue = inputStream.readObject()
+ topic = inputStream.readObject()
+ inputStream.close();
+}
+
+GroovyRun.assertTrue(!cf.getServerLocator().isBlockOnDurableSend());
+GroovyRun.assertEquals(1048576, cf.getServerLocator().getConfirmationWindowSize());
+
+Connection connection = cf.createConnection();
+Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+MessageConsumer consumer = session.createConsumer(queue);
+MessageProducer topicProducer = session.createProducer(topic)
+connection.close();
+
+
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/main/resources/servers/artemisServer.groovy
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/main/resources/servers/artemisServer.groovy b/tests/compatibility-tests/src/main/resources/servers/artemisServer.groovy
new file mode 100644
index 0000000..3ec6d31
--- /dev/null
+++ b/tests/compatibility-tests/src/main/resources/servers/artemisServer.groovy
@@ -0,0 +1,61 @@
+package servers
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.
+ */
+
+// starts an artemis server
+
+import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl;
+import org.apache.activemq.artemis.core.server.JournalType;
+import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
+import org.apache.activemq.artemis.jms.server.config.impl.JMSConfigurationImpl;
+import org.apache.activemq.artemis.jms.server.embedded.EmbeddedJMS
+import org.apache.activemq.artemis.tests.compatibility.GroovyRun;
+
+
+String folder = arg[0];
+String id = arg[1];
+String type = arg[2];
+String producer = arg[3];
+String consumer = arg[4];
+
+println("type = " + type);
+
+configuration = new ConfigurationImpl();
+configuration.setJournalType(JournalType.NIO);
+System.out.println("folder:: " + folder);
+configuration.setBrokerInstance(new File(folder + "/" + id));
+configuration.addAcceptorConfiguration("artemis", "tcp://0.0.0.0:61616");
+configuration.setSecurityEnabled(false);
+configuration.setPersistenceEnabled(false);
+try {
+ if (!type.equals("ARTEMIS-140")) {
+ configuration.addAddressesSetting("#", new AddressSettings().setAutoCreateAddresses(true));
+ }
+} catch (Throwable e) {
+ // need to ignore this for 1.4
+ e.printStackTrace();
+}
+
+jmsConfiguration = new JMSConfigurationImpl();
+
+server = new EmbeddedJMS();
+server.setConfiguration(configuration);
+server.setJmsConfiguration(jmsConfiguration);
+server.start();
+
+// uncomment this line to validate https://issues.apache.org/jira/browse/ARTEMIS-1561
+// this api exists on both 1.4 and 2.x... so, this one was preferred for this
+if (producer.toString().startsWith("HORNETQ")) {
+ // hornetq servers won't auto-create
+ server.getJMSServerManager().createQueue(true, "queue", null, true);
+}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/main/resources/servers/hornetqServer.groovy
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/main/resources/servers/hornetqServer.groovy b/tests/compatibility-tests/src/main/resources/servers/hornetqServer.groovy
new file mode 100644
index 0000000..be92768
--- /dev/null
+++ b/tests/compatibility-tests/src/main/resources/servers/hornetqServer.groovy
@@ -0,0 +1,54 @@
+package servers
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.
+ */
+
+// starts a hornetq server
+
+import org.hornetq.api.core.TransportConfiguration
+import org.hornetq.core.config.impl.ConfigurationImpl
+import org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory
+import org.hornetq.core.remoting.impl.netty.TransportConstants
+import org.hornetq.jms.server.config.impl.JMSConfigurationImpl
+import org.hornetq.jms.server.config.impl.JMSQueueConfigurationImpl
+import org.hornetq.jms.server.embedded.EmbeddedJMS
+
+String folder = arg[0];
+String id = arg[1];
+String type = arg[2];
+String producer = arg[3];
+String consumer = arg[4];
+
+configuration = new ConfigurationImpl();
+configuration.setSecurityEnabled(false);
+configuration.setJournalDirectory(folder + "/" + id + "/journal");
+configuration.setBindingsDirectory(folder + "/" + id + "/binding");
+configuration.setPagingDirectory(folder + "/" + id + "/paging");
+configuration.setLargeMessagesDirectory(folder + "/" + id + "/largemessage");
+configuration.setJournalType(org.hornetq.core.server.JournalType.NIO);
+configuration.setPersistenceEnabled(false);
+
+HashMap map = new HashMap();
+map.put(TransportConstants.HOST_PROP_NAME, "localhost");
+map.put(TransportConstants.PORT_PROP_NAME, "61616");
+TransportConfiguration tpc = new TransportConfiguration(NettyAcceptorFactory.class.getName(), map);
+configuration.getAcceptorConfigurations().add(tpc);
+
+jmsConfiguration = new JMSConfigurationImpl();
+
+JMSQueueConfigurationImpl queueConfiguration = new JMSQueueConfigurationImpl("queue", null, true);
+jmsConfiguration.getQueueConfigurations().add(queueConfiguration);
+server = new EmbeddedJMS();
+server.setConfiguration(configuration);
+server.setJmsConfiguration(jmsConfiguration);
+server.start();
+
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/MeshTest.java
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/MeshTest.java b/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/MeshTest.java
new file mode 100644
index 0000000..ed7851c
--- /dev/null
+++ b/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/MeshTest.java
@@ -0,0 +1,79 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.tests.compatibility;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+
+import static org.apache.activemq.artemis.tests.compatibility.GroovyRun.HORNETQ_235;
+import static org.apache.activemq.artemis.tests.compatibility.GroovyRun.HORNETQ_247;
+import static org.apache.activemq.artemis.tests.compatibility.GroovyRun.ONE_FOUR;
+import static org.apache.activemq.artemis.tests.compatibility.GroovyRun.SNAPSHOT;
+import static org.apache.activemq.artemis.tests.compatibility.GroovyRun.TWO_FOUR;
+
+/**
+ * To run this test on the IDE and debug it, run the compatibility-tests through a command line once:
+ *
+ * cd /compatibility-tests
+ * mvn install -Ptests | tee output.log
+ *
+ * on the output.log you will see the output generated by {@link #getClasspathProperty(String)}
+ *
+ * On your IDE, edit the Run Configuration to your test and add those -D as parameters to your test.
+ * On Idea you would do the following:
+ *
+ * Run->Edit Configuration->Add ArtemisMeshTest and add your properties.
+ */
+@RunWith(Parameterized.class)
+public class MeshTest extends VersionedBaseTest {
+
+ // this will ensure that all tests in this class are run twice,
+ // once with "true" passed to the class' constructor and once with "false"
+ @Parameterized.Parameters(name = "server={0}, producer={1}, consumer={2}")
+ public static Collection getParameters() {
+ // we don't need every single version ever released..
+ // if we keep testing current one against 2.4 and 1.4.. we are sure the wire and API won't change over time
+ List<Object[]> combinations = new ArrayList<>();
+
+ /*
+ // during development sometimes is useful to comment out the combinations
+ // and add the ones you are interested.. example:
+ */
+ // combinations.add(new Object[]{SNAPSHOT, ONE_FOUR, ONE_FOUR});
+ // combinations.add(new Object[]{ONE_FOUR, ONE_FOUR, ONE_FOUR});
+
+ combinations.addAll(combinatory(new Object[]{SNAPSHOT}, new Object[]{ONE_FOUR, TWO_FOUR, SNAPSHOT, HORNETQ_235}, new Object[]{ONE_FOUR, TWO_FOUR, SNAPSHOT, HORNETQ_235}));
+ combinations.addAll(combinatory(new Object[]{ONE_FOUR}, new Object[]{ONE_FOUR, SNAPSHOT}, new Object[]{ONE_FOUR, SNAPSHOT}));
+ combinations.addAll(combinatory(new Object[]{HORNETQ_235}, new Object[]{ONE_FOUR, SNAPSHOT, HORNETQ_235}, new Object[]{ONE_FOUR, SNAPSHOT, HORNETQ_235}));
+ combinations.addAll(combinatory(new Object[]{HORNETQ_247}, new Object[]{SNAPSHOT, HORNETQ_247}, new Object[]{SNAPSHOT, HORNETQ_247}));
+ return combinations;
+ }
+
+ public MeshTest(String server, String sender, String receiver) throws Exception {
+ super(server, sender, receiver);
+ }
+
+ @Test
+ public void testSendReceive() throws Throwable {
+ callMain(senderClassloader, GroovyRun.class.getName(), "meshTest/sendMessages.groovy", server, sender, "sendAckMessages");
+ callMain(receiverClassloader, GroovyRun.class.getName(), "meshTest/sendMessages.groovy", server, receiver, "receiveMessages");
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/SendAckTest.java
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/SendAckTest.java b/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/SendAckTest.java
new file mode 100644
index 0000000..2f21704
--- /dev/null
+++ b/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/SendAckTest.java
@@ -0,0 +1,78 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.tests.compatibility;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+
+import static org.apache.activemq.artemis.tests.compatibility.GroovyRun.ONE_FOUR;
+import static org.apache.activemq.artemis.tests.compatibility.GroovyRun.SNAPSHOT;
+import static org.apache.activemq.artemis.tests.compatibility.GroovyRun.TWO_FOUR;
+
+/**
+ * To run this test on the IDE and debug it, run the compatibility-tests through a command line once:
+ *
+ * cd /compatibility-tests
+ * mvn install -Ptests | tee output.log
+ *
+ * on the output.log you will see the output generated by {@link #getClasspathProperty(String)}
+ *
+ * On your IDE, edit the Run Configuration to your test and add those -D as parameters to your test.
+ * On Idea you would do the following:
+ *
+ * Run->Edit Configuration->Add ArtemisMeshTest and add your properties.
+ */
+@RunWith(Parameterized.class)
+public class SendAckTest extends VersionedBaseTest {
+
+ // this will ensure that all tests in this class are run twice,
+ // once with "true" passed to the class' constructor and once with "false"
+ @Parameterized.Parameters(name = "server={0}, producer={1}, consumer={2}")
+ public static Collection getParameters() {
+ // we don't need every single version ever released..
+ // if we keep testing current one against 2.4 and 1.4.. we are sure the wire and API won't change over time
+ List<Object[]> combinations = new ArrayList<>();
+
+ /*
+ // during development sometimes is useful to comment out the combinations
+ // and add the ones you are interested.. example:
+ */
+ // combinations.add(new Object[]{SNAPSHOT, ONE_FOUR, ONE_FOUR});
+ // combinations.add(new Object[]{ONE_FOUR, ONE_FOUR, ONE_FOUR});
+
+ combinations.addAll(combinatory(new Object[]{SNAPSHOT, ONE_FOUR}, new Object[]{ONE_FOUR, SNAPSHOT}, new Object[]{ONE_FOUR, SNAPSHOT}));
+
+ // not every combination on two four would make sense.. as there's a compatibility issue between 2.4 and 1.4 when crossing consumers and producers
+ combinations.add(new Object[]{TWO_FOUR, SNAPSHOT, SNAPSHOT});
+ combinations.add(new Object[]{SNAPSHOT, TWO_FOUR, TWO_FOUR});
+ return combinations;
+ }
+
+ public SendAckTest(String server, String sender, String receiver) throws Exception {
+ super(server, sender, receiver);
+ }
+
+ @Test
+ public void testSendReceive() throws Throwable {
+ callMain(senderClassloader, GroovyRun.class.getName(), "sendAckTest/sendAckMessages.groovy", server, sender, "sendAckMessages");
+ callMain(receiverClassloader, GroovyRun.class.getName(), "sendAckTest/sendAckMessages.groovy", server, receiver, "receiveMessages");
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ef90f8d/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/SerializationTest.java
----------------------------------------------------------------------
diff --git a/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/SerializationTest.java b/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/SerializationTest.java
new file mode 100644
index 0000000..c99e696
--- /dev/null
+++ b/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/SerializationTest.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat 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.tests.compatibility;
+
+import java.io.File;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+
+import static org.apache.activemq.artemis.tests.compatibility.GroovyRun.ONE_FOUR;
+import static org.apache.activemq.artemis.tests.compatibility.GroovyRun.SNAPSHOT;
+
+/**
+ * To run this test on the IDE and debug it, run the compatibility-tests through a command line once:
+ *
+ * cd /compatibility-tests
+ * mvn install -Ptests | tee output.log
+ *
+ * on the output.log you will see the output generated by {@link #getClasspathProperty(String)}
+ *
+ * On your IDE, edit the Run Configuration to your test and add those -D as parameters to your test.
+ * On Idea you would do the following:
+ *
+ * Run->Edit Configuration->Add ArtemisMeshTest and add your properties.
+ */
+@RunWith(Parameterized.class)
+public class SerializationTest extends VersionedBaseTest {
+
+ // this will ensure that all tests in this class are run twice,
+ // once with "true" passed to the class' constructor and once with "false"
+ @Parameterized.Parameters(name = "server={0}, producer={1}, consumer={2}")
+ public static Collection getParameters() {
+ // we don't need every single version ever released..
+ // if we keep testing current one against 2.4 and 1.4.. we are sure the wire and API won't change over time
+ List<Object[]> combinations = new ArrayList<>();
+
+ /*
+ // during development sometimes is useful to comment out the combinations
+ // and add the ones you are interested.. example:
+ */
+ // combinations.add(new Object[]{SNAPSHOT, ONE_FOUR, ONE_FOUR});
+ // combinations.add(new Object[]{ONE_FOUR, ONE_FOUR, ONE_FOUR});
+
+ combinations.addAll(combinatory(new Object[]{SNAPSHOT}, new Object[]{ONE_FOUR, SNAPSHOT}, new Object[]{ONE_FOUR, SNAPSHOT}));
+ return combinations;
+ }
+
+ public SerializationTest(String server, String sender, String receiver) throws Exception {
+ super(server, sender, receiver);
+ }
+
+ @Test
+ public void testSerializeFactory() throws Throwable {
+ File file = serverFolder.newFile("objects.ser");
+ file.mkdirs();
+ callMain(senderClassloader, GroovyRun.class.getName(), "serial/serial.groovy", file.getAbsolutePath(), "write");
+ callMain(receiverClassloader, GroovyRun.class.getName(), "serial/serial.groovy", file.getAbsolutePath(), "read");
+ }
+
+}
+