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 2015/08/07 21:31:27 UTC
[08/18] activemq-artemis git commit: ARTEMIS-180 removing -Pexample
and some other improvements around the examples
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/non-transaction-failover/readme.html
----------------------------------------------------------------------
diff --git a/examples/jms/non-transaction-failover/readme.html b/examples/jms/non-transaction-failover/readme.html
index 0e83d37..3667284 100644
--- a/examples/jms/non-transaction-failover/readme.html
+++ b/examples/jms/non-transaction-failover/readme.html
@@ -26,11 +26,14 @@ under the License.
</head>
<body onload="prettyPrint()">
<h1>JMS Failover Without Transactions Example</h1>
-
+
+ <pre>To run the example, simply type <b>mvn verify</b> from this directory.</pre>
+
+
<p>This example demonstrates two servers coupled as a live-backup pair for high availability (HA), and a client
connection failing over from live to backup when the live server is crashed.</p>
<p>Failover behavior differs whether the JMS session is transacted or not.</p>
- <p>When a <em>non-transacted</em> JMS session is used, once and only once delivery is not guaranteed
+ <p>When a <em>non-transacted</em> JMS session is used, once and only once delivery is not guaranteed
and it is possible some messages will be lost or delivered twice, depending when the failover to the backup server occurs.</p>
<p>It is up to the client to deal with such cases. To ensure once and only once delivery, the client must
use transacted JMS sessions (as shown in the example for <a href="../transaction-failover/readme.html">failover with transactions</a>).</p>
@@ -38,7 +41,6 @@ under the License.
section of 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>
<p>In this example, the live server is server 1, and the backup server is server 0</p>
<p>The connection will initially be created to server1, server 1 will crash, and the client will carry on
seamlessly on server 0, the backup server.</p>
@@ -58,12 +60,12 @@ under the License.
<pre class="prettyprint">
connection = connectionFactory.createConnection();
</pre>
-
+
<li>Create a JMS <em>non-transacted</em> Session with client acknowledgement</li>
<pre class="prettyprint">
Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
</pre>
-
+
<li>Start the connection to ensure delivery occurs</li>
<pre class="prettyprint">
connection.start();
@@ -84,7 +86,7 @@ under the License.
System.out.println("Sent message: " + message.getText());
}
</pre>
-
+
<li>Receive and acknowledge half of the sent messages</li>
<pre class="prettyprint">
TextMessage message0 = null;
@@ -95,7 +97,7 @@ under the License.
}
message0.acknowledge();
</pre>
-
+
<li>Receive the second half of the sent messages but <em>do not acknowledge them yet</em></li>
<pre class="prettyprint">
for (int i = numMessages / 2; i < numMessages; i++)
@@ -104,7 +106,7 @@ under the License.
System.out.println("Got message: " + message0.getText());
}
</pre>
-
+
<li>Crash server #1, the live server, and wait a little while to make sure it has really crashed.</li>
<pre class="prettyprint">
killServer(1);
@@ -122,7 +124,7 @@ under the License.
System.err.println("Got exception while acknowledging message: " + e.getMessage());
}
</pre>
-
+
<li>Consume again the second half of the messages againg. Note that they are not considered as redelivered</li>
<pre class="prettyprint">
for (int i = numMessages / 2; i < numMessages; i++)
@@ -132,7 +134,7 @@ under the License.
}
message0.acknowledge();
</pre>
-
+
<li>And finally, <strong>always</strong> remember to close your 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">
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/openwire/pom.xml
----------------------------------------------------------------------
diff --git a/examples/jms/openwire/pom.xml b/examples/jms/openwire/pom.xml
deleted file mode 100644
index 3888f12..0000000
--- a/examples/jms/openwire/pom.xml
+++ /dev/null
@@ -1,110 +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.jms</groupId>
- <artifactId>jms-examples</artifactId>
- <version>1.0.1-SNAPSHOT</version>
- </parent>
-
- <artifactId>artemis-jms-openwire-example</artifactId>
- <packaging>jar</packaging>
- <name>ActiveMQ Artemis JMS Openwire Example</name>
-
- <properties>
- <activemq.basedir>${project.basedir}/../../..</activemq.basedir>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.geronimo.specs</groupId>
- <artifactId>geronimo-jms_2.0_spec</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>activemq-client</artifactId>
- </dependency>
- </dependencies>
-
- <profiles>
- <profile>
- <id>example</id>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- </execution>
- <execution>
- <id>start</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <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.OpenWireExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.jms</groupId>
- <artifactId>artemis-jms-openwire-example</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
- </profile>
- </profiles>
-</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/openwire/readme.html
----------------------------------------------------------------------
diff --git a/examples/jms/openwire/readme.html b/examples/jms/openwire/readme.html
deleted file mode 100644
index df1e272..0000000
--- a/examples/jms/openwire/readme.html
+++ /dev/null
@@ -1,98 +0,0 @@
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<html>
- <head>
- <title>ActiveMQ Artemis OpenWire 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 OpenWire Example</h1>
-
- <p>This example shows you how to configure ActiveMQ Artemis server to communicate with an ActiveMQ Artemis JMS client using ActiveMQ's native openwire protocol.</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 create an ActiveMQ Artemis connection factory.</code></li>
- <pre class="prettyprint">
- <code>ConnectionFactory factory = new ActiveMQConnectionFactory(urlString);</code>
- </pre>
-
- <li>Create the target queue</li>
- <pre class="prettyprint">
- <code>Queue queue = new ActiveMQQueue("exampleQueue");</code>
- </pre>
-
- <li>We create a JMS connection and start it</li>
- <pre class="prettyprint">
- <code>connection = cf.createConnection();</code>
- <code>connection.start()</code>
- </pre>
-
- <li>We create a JMS session. The session is created as non transacted and will auto acknowledge messages.</li>
- <pre class="prettyprint">
- <code>Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);</code>
- </pre>
-
- <li>We create a JMS message producer on the session. This will be used to send the messages.</li>
- <pre class="prettyprint">
- <code>MessageProducer messageProducer = session.createProducer(topic);</code>
- </pre>
-
- <li>We create a JMS text message that we are going to send.</li>
- <pre class="prettyprint">
- <code>TextMessage message = session.createTextMessage("This is a text message");</code>
- </pre>
-
- <li>We send message to the queue</li>
- <pre class="prettyprint">
- <code>messageProducer.send(message);</code>
- </pre>
-
- <li>We create a JMS Message Consumer to receive the message.</li>
- <pre class="prettyprint">
- <code>MessageConsumer messageConsumer = session.createConsumer(queue);</code>
- </pre>
-
- <li>The message arrives at the consumer. In this case we use a timeout of 5000 milliseconds but we could use a blocking 'receive()'</li>
- <pre class="prettyprint">
- <code>TextMessage messageReceived = (TextMessage) messageConsumer.receive(5000);</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 (connection != null)
- {
- connection.close();
- }
- }</code>
- </pre>
-
-
-
- </ol>
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/openwire/src/main/java/org/apache/activemq/artemis/jms/example/OpenWireExample.java
----------------------------------------------------------------------
diff --git a/examples/jms/openwire/src/main/java/org/apache/activemq/artemis/jms/example/OpenWireExample.java b/examples/jms/openwire/src/main/java/org/apache/activemq/artemis/jms/example/OpenWireExample.java
deleted file mode 100644
index 202e1b0..0000000
--- a/examples/jms/openwire/src/main/java/org/apache/activemq/artemis/jms/example/OpenWireExample.java
+++ /dev/null
@@ -1,91 +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.MessageConsumer;
-import javax.jms.MessageProducer;
-import javax.jms.Queue;
-import javax.jms.Session;
-import javax.jms.TextMessage;
-
-import org.apache.activemq.ActiveMQConnectionFactory;
-import org.apache.activemq.command.ActiveMQQueue;
-
-import java.lang.Exception;
-
-/**
- * A simple JMS Queue example that creates a producer and consumer on a queue
- * and sends then receives a message.
- */
-public class OpenWireExample
-{
- public static final String OWHOST = "localhost";
- public static final int OWPORT = 61616;
-
- public static void main(final String[] args) throws Exception
- {
- Connection connection = null;
-
- try
- {
- String urlString = "tcp://" + OWHOST + ":" + OWPORT;
-
- // Step 1. Create an ActiveMQ Artemis Connection Factory
- ConnectionFactory factory = new ActiveMQConnectionFactory(urlString);
-
- // Step 2. Create the target queue
- Queue queue = new ActiveMQQueue("exampleQueue");
-
- // Step 3. Create a JMS Connection
- connection = factory.createConnection();
-
- // Step 4. Start the Connection
- connection.start();
-
- // 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
- TextMessage message = session.createTextMessage("This is a text message");
-
- // Step 8. Send the Message
- producer.send(message);
-
- System.out.println("Sent message: " + message.getText());
-
- // Step 9. Create a JMS Message Consumer
- MessageConsumer messageConsumer = session.createConsumer(queue);
-
- // Step 10. Receive the message
- TextMessage messageReceived = (TextMessage) messageConsumer.receive(5000);
-
- System.out.println("Received message: " + messageReceived.getText());
- }
- finally
- {
- if (connection != null)
- {
- connection.close();
- }
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/openwire/src/main/resources/activemq/server0/artemis-roles.properties
----------------------------------------------------------------------
diff --git a/examples/jms/openwire/src/main/resources/activemq/server0/artemis-roles.properties b/examples/jms/openwire/src/main/resources/activemq/server0/artemis-roles.properties
deleted file mode 100644
index 4e2d44c..0000000
--- a/examples/jms/openwire/src/main/resources/activemq/server0/artemis-roles.properties
+++ /dev/null
@@ -1,17 +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.
-## ---------------------------------------------------------------------------
-guest=guest
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/openwire/src/main/resources/activemq/server0/artemis-users.properties
----------------------------------------------------------------------
diff --git a/examples/jms/openwire/src/main/resources/activemq/server0/artemis-users.properties b/examples/jms/openwire/src/main/resources/activemq/server0/artemis-users.properties
deleted file mode 100644
index 4e2d44c..0000000
--- a/examples/jms/openwire/src/main/resources/activemq/server0/artemis-users.properties
+++ /dev/null
@@ -1,17 +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.
-## ---------------------------------------------------------------------------
-guest=guest
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/openwire/src/main/resources/activemq/server0/broker.xml
----------------------------------------------------------------------
diff --git a/examples/jms/openwire/src/main/resources/activemq/server0/broker.xml b/examples/jms/openwire/src/main/resources/activemq/server0/broker.xml
deleted file mode 100644
index c281c60..0000000
--- a/examples/jms/openwire/src/main/resources/activemq/server0/broker.xml
+++ /dev/null
@@ -1,71 +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.dir}/server0/data/messaging/bindings</bindings-directory>
-
- <journal-directory>${data.dir}/server0/data/messaging/journal</journal-directory>
-
- <large-messages-directory>${data.dir}/server0/data/messaging/largemessages</large-messages-directory>
-
- <paging-directory>${data.dir}/server0/data/messaging/paging</paging-directory>
-
- <connectors>
- <connector name="netty-connector">tcp://localhost:61616</connector>
- </connectors>
-
- <!-- Acceptors -->
- <acceptors>
- <!-- the same acceptor can deal with more than one protocol. We are adding CORE here as some of
- the example super classes will check for if the server is alive after starting it -->
- <acceptor name="openwire-acceptor">tcp://localhost:61616?protocols=OPENWIRE,CORE</acceptor>
- </acceptors>
-
- <!-- Other config -->
-
- <security-settings>
- <security-setting match="jms.topic.ActiveMQ Artemis.Advisory.#">
- <permission type="createNonDurableQueue" roles="guest"/>
- <permission type="consume" roles="guest"/>
- <permission type="send" roles="guest"/>
- </security-setting>
- <!--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/dd820318/examples/jms/paging/pom.xml
----------------------------------------------------------------------
diff --git a/examples/jms/paging/pom.xml b/examples/jms/paging/pom.xml
index 954aad9..22c0c60 100644
--- a/examples/jms/paging/pom.xml
+++ b/examples/jms/paging/pom.xml
@@ -18,7 +18,8 @@ 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">
+<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>
@@ -27,7 +28,7 @@ under the License.
<version>1.0.1-SNAPSHOT</version>
</parent>
- <artifactId>artemis-jms-paging-example</artifactId>
+ <artifactId>paging</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ Artemis JMS Paging Example</name>
@@ -37,71 +38,81 @@ under the License.
<dependencies>
<dependency>
- <groupId>org.apache.geronimo.specs</groupId>
- <artifactId>geronimo-jms_2.0_spec</artifactId>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-jms-client</artifactId>
+ <version>${project.version}</version>
</dependency>
</dependencies>
<profiles>
<profile>
- <id>example</id>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- </execution>
- <execution>
- <id>start</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <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.PagingExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.jms</groupId>
- <artifactId>artemis-jms-paging-example</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
+ <!-- specify -PnoServer if you don't want to start the server -->
+ <id>noServer</id>
+ <properties>
+ <noServer>true</noServer>
+ </properties>
</profile>
</profiles>
+ <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.PagingExample</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.jms</groupId>
+ <artifactId>paging</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ </plugin>
+ </plugins>
+ </build>
</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/paging/readme.html
----------------------------------------------------------------------
diff --git a/examples/jms/paging/readme.html b/examples/jms/paging/readme.html
index 938d087..1f9afd3 100644
--- a/examples/jms/paging/readme.html
+++ b/examples/jms/paging/readme.html
@@ -27,17 +27,19 @@ under the License.
<body onload="prettyPrint()">
<h1>Paging 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 ActiveMQ Artemis would avoid running out of memory resources by paging messages.</p>
<p>A maxSize can be specified per Destination via the destinations settings configuration file (broker.xml).</p>
<p>When messages routed to an address exceed the specified maxSize the server will begin to write messages to the file
system, this is called paging. This will continue to occur until messages have been delivered to consumers and subsequently
acknowledged freeing up memory. Messages will then be read from the file system , i.e. depaged, and routed as normal. </p>
<p>Acknowledgement plays an important factor on paging as messages will stay on the file system until the memory is released
- so it is important to make sure that the client acknowledges its messages.</p>
+ so it is important to make sure that the client acknowledges its messages.</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>
@@ -75,32 +77,32 @@ under the License.
<pre class="prettyprint"><code>
MessageProducer pageMessageProducer = session.createProducer(pageQueue);
</pre></code>
-
+
<li>We don't need persistent messages in order to use paging. (This step is optional)</li>
<pre class="prettyprint"><code>
pageMessageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
</pre></code>
-
+
<li>Create a Binary Bytes Message with 10K arbitrary bytes</li>
<pre class="prettyprint"><code>
BytesMessage message = session.createBytesMessage();
message.writeBytes(new byte[10 * 1024]);
</pre></code>
-
+
<li>Send only 20 messages to the Queue. This will be already enough for pagingQueue. Look at ./paging/config/activemq-queues.xml for the config.</li>
<pre class="prettyprint"><code>
for (int i = 0; i < 20; i++)
{
pageMessageProducer.send(message);
- }
+ }
</pre></code>
-
+
<li>Create a JMS Message Producer</li>
<pre class="prettyprint"><code>
MessageProducer messageProducer = session.createProducer(queue);
</pre></code>
-
+
<li>We don't need persistent messages in order to use paging. (This step is optional)</li>
<pre class="prettyprint"><code>
messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
@@ -115,26 +117,26 @@ under the License.
</pre></code>
<li>if you pause the example here, you will several files under ./build/data/paging</li>
-
+
<pre class="prettyprint"><code>
- // Thread.sleep(30000); // if you want to just our of curiosity, you can sleep here and inspect the created files just for
+ // Thread.sleep(30000); // if you want to just our of curiosity, you can sleep here and inspect the created files just for
</pre></code>
-
-
+
+
<li>Create a JMS Message Consumer</li>
<pre class="prettyprint"><code>
MessageConsumer messageConsumer = session.createConsumer(queue);
</pre></code>
-
+
<li>Start the JMS Connection. This step will activate the subscribers to receive messages.</li>
<pre class="prettyprint"><code>
connection.start();
</pre></code>
-
-
+
+
<li>Receive the messages. It's important to ACK for messages as ActiveMQ Artemis will not read messages from paging until messages are ACKed</li>
-
+
<pre class="prettyprint"><code>
for (int i = 0; i < 30000; i++)
{
@@ -143,12 +145,12 @@ under the License.
if (i % 1000 == 0)
{
System.out.println("Received " + i + " messages");
-
+
message.acknowledge();
}
}
</pre></code>
-
+
<li>Receive the messages from the Queue names pageQueue. Create the proper consumer for that.</li>
<pre class="prettyprint"><code>
messageConsumer.close();
@@ -157,7 +159,7 @@ under the License.
for (int i = 0; i < 20; i++)
{
message = (BytesMessage)messageConsumer.receive(1000);
-
+
System.out.println("Received message " + i + " from pageQueue");
message.acknowledge();
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/perf/pom.xml
----------------------------------------------------------------------
diff --git a/examples/jms/perf/pom.xml b/examples/jms/perf/pom.xml
index b348a70..a1eb6ef 100644
--- a/examples/jms/perf/pom.xml
+++ b/examples/jms/perf/pom.xml
@@ -27,7 +27,7 @@ under the License.
<version>1.0.1-SNAPSHOT</version>
</parent>
- <artifactId>artemis-jms-perf-example</artifactId>
+ <artifactId>perf</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ Artemis JMS PerfExample Example</name>
@@ -95,7 +95,7 @@ under the License.
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.jms</groupId>
- <artifactId>artemis-jms-perf-example</artifactId>
+ <artifactId>perf</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/pom.xml
----------------------------------------------------------------------
diff --git a/examples/jms/pom.xml b/examples/jms/pom.xml
index 4c8db04..3b59d1a 100644
--- a/examples/jms/pom.xml
+++ b/examples/jms/pom.xml
@@ -39,11 +39,10 @@ under the License.
<profiles>
<profile>
- <id>release</id>
+ <!-- You need to activate -Pexamples to run all the examples -->
+ <id>examples</id>
<modules>
- <module>aerogear</module>
<module>application-layer-failover</module>
- <module>artemis-ra-rar</module>
<module>bridge</module>
<module>browser</module>
<module>client-kickoff</module>
@@ -53,109 +52,14 @@ under the License.
<module>clustered-grouping</module>
<module>clustered-jgroups</module>
<module>clustered-queue</module>
- <module>clustered-standalone</module>
- <module>clustered-static-oneway</module>
- <module>clustered-static-discovery</module>
- <module>clustered-topic</module>
- <module>colocated-failover</module>
- <module>colocated-failover-scale-down</module>
- <module>consumer-rate-limit</module>
- <module>dead-letter</module>
- <module>delayed-redelivery</module>
- <module>divert</module>
- <module>durable-subscription</module>
- <module>embedded</module>
- <module>embedded-simple</module>
- <module>expiry</module>
- <module>http-transport</module>
- <module>interceptor</module>
- <module>instantiate-connection-factory</module>
- <module>ha-policy-autobackup</module>
- <module>jms-auto-closeable</module>
- <module>jms-bridge</module>
- <module>jms-completion-listener</module>
- <module>jms-context</module>
- <module>jms-shared-consumer</module>
- <module>jmx</module>
- <module>large-message</module>
- <module>last-value-queue</module>
- <module>management</module>
- <module>management-notifications</module>
- <module>message-counters</module>
- <module>message-group</module>
- <module>message-group2</module>
- <module>message-priority</module>
- <module>multiple-failover</module>
- <module>multiple-failover-failback</module>
- <module>no-consumer-buffering</module>
- <module>non-transaction-failover</module>
- <module>openwire</module>
- <module>paging</module>
- <module>perf</module>
- <module>pre-acknowledge</module>
- <module>producer-rate-limit</module>
- <module>proton-cpp</module>
- <module>proton-j</module>
- <module>proton-ruby</module>
- <module>queue</module>
- <module>queue-message-redistribution</module>
- <module>queue-requestor</module>
- <module>queue-selector</module>
- <module>reattach-node</module>
- <module>rest</module>
- <module>replicated-failback</module>
- <module>replicated-failback-static</module>
- <module>replicated-multiple-failover</module>
- <module>replicated-transaction-failover</module>
- <module>request-reply</module>
- <module>scale-down</module>
- <module>scheduled-message</module>
- <module>security</module>
- <module>send-acknowledgements</module>
- <module>spring-integration</module>
- <module>ssl-enabled</module>
- <module>static-selector</module>
- <module>static-selector-jms</module>
- <module>stomp</module>
- <module>stomp-websockets</module>
- <module>stomp1.1</module>
- <module>stomp1.2</module>
- <module>stop-server-failover</module>
- <module>symmetric-cluster</module>
- <module>temp-queue</module>
- <module>topic</module>
- <module>topic-hierarchies</module>
- <module>topic-selector-example1</module>
- <module>topic-selector-example2</module>
- <module>transactional</module>
- <module>transaction-failover</module>
- <module>xa-heuristic</module>
- <module>xa-receive</module>
- <module>xa-send</module>
- </modules>
- </profile>
- <profile>
- <id>example</id>
- <activation>
- <activeByDefault>true</activeByDefault>
- </activation>
- <modules>
- <module>application-layer-failover</module>
- <module>bridge</module>
- <module>browser</module>
- <module>client-kickoff</module>
- <module>client-side-load-balancing</module>
- <module>client-side-failoverlistener</module>
- <module>clustered-durable-subscription</module>
- <module>clustered-grouping</module>
- <module>clustered-jgroups</module>
- <module>clustered-queue</module>
- <module>clustered-standalone</module>
<module>clustered-static-oneway</module>
<module>clustered-static-discovery</module>
<module>clustered-topic</module>
+
+ <!-- ARTEMIS-197 FIX ME:
<module>colocated-failover</module>
- <module>colocated-failover-scale-down</module>
+ <module>colocated-failover-scale-down</module> -->
+
<module>consumer-rate-limit</module>
<module>dead-letter</module>
<module>delayed-redelivery</module>
@@ -186,7 +90,6 @@ under the License.
<module>multiple-failover-failback</module>
<module>no-consumer-buffering</module>
<module>non-transaction-failover</module>
- <module>openwire</module>
<module>paging</module>
<!--run this standalone-->
<!--<module>perf</module>-->
@@ -200,8 +103,11 @@ under the License.
<module>queue-requestor</module>
<module>queue-selector</module>
<module>reattach-node</module>
+
+ <!-- ARTEMIS-197 FIX ME:
<module>replicated-failback</module>
- <module>replicated-failback-static</module>
+ <module>replicated-failback-static</module> -->
+
<module>replicated-multiple-failover</module>
<module>replicated-transaction-failover</module>
<module>request-reply</module>
@@ -211,9 +117,13 @@ under the License.
<module>security</module>
<module>send-acknowledgements</module>
<module>spring-integration</module>
- <module>ssl-enabled</module>
+
+ <!-- ARTEMIS-197 FIX ME
+ this one could be the case of leaving it out for good
+ as it may require to be run manually
+ <module>ssl-enabled</module> -->
+
<module>static-selector</module>
- <module>static-selector-jms</module>
<module>stomp</module>
<!--this should be run standalone-->
<!--<module>stomp-websockets</module>-->
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/pre-acknowledge/pom.xml
----------------------------------------------------------------------
diff --git a/examples/jms/pre-acknowledge/pom.xml b/examples/jms/pre-acknowledge/pom.xml
index b181706..e3ee5ef 100644
--- a/examples/jms/pre-acknowledge/pom.xml
+++ b/examples/jms/pre-acknowledge/pom.xml
@@ -18,7 +18,8 @@ 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">
+<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>
@@ -27,7 +28,7 @@ under the License.
<version>1.0.1-SNAPSHOT</version>
</parent>
- <artifactId>artemis-jms-pre-acknowledge-example</artifactId>
+ <artifactId>pre-acknowledge</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ Artemis JMS Pre Acknowledge Example</name>
@@ -41,72 +42,77 @@ under the License.
<artifactId>artemis-jms-client</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.geronimo.specs</groupId>
- <artifactId>geronimo-jms_2.0_spec</artifactId>
- </dependency>
</dependencies>
<profiles>
<profile>
- <id>example</id>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- </execution>
- <execution>
- <id>start</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <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.PreacknowledgeExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.jms</groupId>
- <artifactId>artemis-jms-pre-acknowledge-example</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
+ <!-- specify -PnoServer if you don't want to start the server -->
+ <id>noServer</id>
+ <properties>
+ <noServer>true</noServer>
+ </properties>
</profile>
</profiles>
+ <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.PreacknowledgeExample</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.jms</groupId>
+ <artifactId>pre-acknowledge</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ </plugin>
+ </plugins>
+ </build>
</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/pre-acknowledge/readme.html
----------------------------------------------------------------------
diff --git a/examples/jms/pre-acknowledge/readme.html b/examples/jms/pre-acknowledge/readme.html
index 893423c..cadea23 100644
--- a/examples/jms/pre-acknowledge/readme.html
+++ b/examples/jms/pre-acknowledge/readme.html
@@ -27,6 +27,9 @@ under the License.
<body onload="prettyPrint()">
<h1>JMS Pre-Acknowledge 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>Standard JMS supports three acknowledgement modes: AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, and
DUPS_OK_ACKNOWLEDGE. For a full description on these modes please consult the JMS specification, or any
JMS tutorial.</p>
@@ -44,9 +47,8 @@ under the License.
update message will arrive soon, overriding the previous price.</p>
<p>In order to use pre-acknowledge functionality with ActiveMQ Artemis the session has to be created with
a special, ActiveMQ Artemis specific acknowledgement mode, given by the value of
- <code>ActiveMQJMSConstants.PRE_ACKNOWLEDGE</code>.
+ <code>ActiveMQJMSConstants.PRE_ACKNOWLEDGE</code>.
<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>Create an initial context to perform the JNDI lookup.</li>
@@ -61,7 +63,7 @@ under the License.
<code>
Queue queue = (Queue)initialContext.lookup("/queue/exampleQueue");
- ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory");
+ ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory");
</code>
</pre>
@@ -73,8 +75,8 @@ under the License.
Session session = connection.createSession(false, ActiveMQSession.PRE_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(queue);
-
- MessageConsumer messageConsumer = session.createConsumer(queue);
+
+ MessageConsumer messageConsumer = session.createConsumer(queue);
</code>
</pre>
@@ -85,7 +87,7 @@ under the License.
producer.send(message1);
- System.out.println("Sent message: " + message1.getText());
+ System.out.println("Sent message: " + message1.getText());
</code>
</pre>
@@ -94,8 +96,8 @@ under the License.
<pre class="prettyprint">
<code>
int count = getMessageCount(connection);
-
- System.out.println("Queue message count is " + count);
+
+ System.out.println("Queue message count is " + count);
</code>
</pre>
@@ -104,16 +106,16 @@ under the License.
<code>
connection.start();
- Thread.sleep(1000);
+ Thread.sleep(1000);
</code>
</pre>
<li>Print out the message count of the queue. It should now be zero, since the message has
- already been acknowledged even before the consumer has received it.</li>
+ already been acknowledged even before the consumer has received it.</li>
<pre class="prettyprint">
<code>
- count = getMessageCount(connection);
-
+ count = getMessageCount(connection);
+
System.out.println("Queue message count is now " + count);
</code>
</pre>
@@ -123,7 +125,7 @@ under the License.
<code>
TextMessage messageReceived = (TextMessage)messageConsumer.receive(5000);
- System.out.println("Received message: " + messageReceived.getText());
+ System.out.println("Received message: " + messageReceived.getText());
</code>
</pre>
@@ -137,16 +139,16 @@ under the License.
if (connection != null)
{
connection.close();
- }
+ }
</code>
</pre>
</ol>
-
+
<h2>More information</h2>
-
+
<ul>
<li>User Manual's <a href="../../../docs/user-manual/en/html_single/index.html#pre-acknowledge">Pre-acknowledgement Mode chapter</a></li>
</ul>
-
+
</body>
</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/pre-acknowledge/src/main/java/org/apache/activemq/artemis/jms/example/PreacknowledgeExample.java
----------------------------------------------------------------------
diff --git a/examples/jms/pre-acknowledge/src/main/java/org/apache/activemq/artemis/jms/example/PreacknowledgeExample.java b/examples/jms/pre-acknowledge/src/main/java/org/apache/activemq/artemis/jms/example/PreacknowledgeExample.java
index 446cec0..5191f85 100644
--- a/examples/jms/pre-acknowledge/src/main/java/org/apache/activemq/artemis/jms/example/PreacknowledgeExample.java
+++ b/examples/jms/pre-acknowledge/src/main/java/org/apache/activemq/artemis/jms/example/PreacknowledgeExample.java
@@ -27,11 +27,11 @@ import javax.jms.QueueRequestor;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
-import javax.naming.InitialContext;
import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.api.jms.ActiveMQJMSConstants;
import org.apache.activemq.artemis.api.jms.management.JMSManagementHelper;
+import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
/**
* This example demonstrates the use of ActiveMQ Artemis "pre-acknowledge" functionality where
@@ -44,17 +44,14 @@ public class PreacknowledgeExample
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. Perform the look-ups
- Queue queue = (Queue)initialContext.lookup("queue/exampleQueue");
+ // Step 2. instantiate the queue object
+ Queue queue = ActiveMQJMSClient.createQueue("exampleQueue");
- ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("ConnectionFactory");
+ // new connection factory
+ ConnectionFactory cf = new ActiveMQConnectionFactory();
// Step 3. Create a the JMS objects
connection = cf.createConnection();
@@ -102,10 +99,6 @@ public class PreacknowledgeExample
finally
{
// Step 9. Be sure to close our resources!
- if (initialContext != null)
- {
- initialContext.close();
- }
if (connection != null)
{
connection.close();
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/producer-rate-limit/pom.xml
----------------------------------------------------------------------
diff --git a/examples/jms/producer-rate-limit/pom.xml b/examples/jms/producer-rate-limit/pom.xml
index d407ea3..c514526 100644
--- a/examples/jms/producer-rate-limit/pom.xml
+++ b/examples/jms/producer-rate-limit/pom.xml
@@ -18,7 +18,8 @@ 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">
+<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>
@@ -27,7 +28,7 @@ under the License.
<version>1.0.1-SNAPSHOT</version>
</parent>
- <artifactId>artemis-jms-producer-rate-limit-example</artifactId>
+ <artifactId>producer-rate-limit</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ Artemis JMS Producer Rate Limit Example</name>
@@ -37,71 +38,81 @@ under the License.
<dependencies>
<dependency>
- <groupId>org.apache.geronimo.specs</groupId>
- <artifactId>geronimo-jms_2.0_spec</artifactId>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-jms-client</artifactId>
+ <version>${project.version}</version>
</dependency>
</dependencies>
<profiles>
<profile>
- <id>example</id>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- </execution>
- <execution>
- <id>start</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <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.ProducerRateLimitExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.jms</groupId>
- <artifactId>artemis-jms-producer-rate-limit-example</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
+ <!-- specify -PnoServer if you don't want to start the server -->
+ <id>noServer</id>
+ <properties>
+ <noServer>true</noServer>
+ </properties>
</profile>
</profiles>
+ <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.ProducerRateLimitExample</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.jms</groupId>
+ <artifactId>producer-rate-limit</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ </plugin>
+ </plugins>
+ </build>
</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/producer-rate-limit/readme.html
----------------------------------------------------------------------
diff --git a/examples/jms/producer-rate-limit/readme.html b/examples/jms/producer-rate-limit/readme.html
index a2615ea..fa8d086 100644
--- a/examples/jms/producer-rate-limit/readme.html
+++ b/examples/jms/producer-rate-limit/readme.html
@@ -27,10 +27,13 @@ under the License.
<body onload="prettyPrint()">
<h1>JMS Message Producer Rate Limiting</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>With ActiveMQ Artemis you can specify a maximum send rate at which a JMS MessageProducer will send messages.
This can be specified when creating or deploying the connection factory. See <code>activemq-jms.xml</code></p>
<p>If this value is specified then ActiveMQ Artemis will ensure that messages are never produced at a rate higher than
- specified. This is a form of producer <i>throttling</i>.</p>
+ specified. This is a form of producer <i>throttling</i>.</p>
<h2>Example step-by-step</h2>
<p>In this example we specify a <code>producer-max-rate</code> of <code>50</code> messages per second in the <code>activemq-jms.xml</code>
file when deploying the connection factory:</p>
@@ -39,21 +42,19 @@ under the License.
<connection-factory name="ConnectionFactory">
<connector-ref connector-name="netty-connector"/>
<entries>
- <entry name="ConnectionFactory"/>
+ <entry name="ConnectionFactory"/>
</entries>
-
+
<!-- We limit producers created on this connection factory to produce messages at a maximum rate
of 50 messages per sec -->
<producer-max-rate>50</producer-max-rate>
-
+
</connection-factory>
</code>
</pre>
<p>We then simply send as many messages as we can in 10 seconds and note how many messages are actually sent.</p>
<p>We note that the number of messages sent per second never exceeds the specified value of <code>50</code> messages per second.</p>
- <p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
-
<ol>
<li>Create an initial context to perform the JNDI lookup.</li>
<pre class="prettyprint">
@@ -107,13 +108,13 @@ under the License.
System.out.println("We sent " + i + " messages in " + (end - start) + " milliseconds");
- System.out.println("Actual send rate was " + rate + " messages per second");
+ System.out.println("Actual send rate was " + rate + " messages per second");
</code>
</pre>
-
+
<li>We note that the sending rate doesn't exceed 50 messages per second. Here's some example output from a real
run</li>
-
+
<pre class="prettyprint">
<code>
[java] Will now send as many messages as we can in 10 seconds...
@@ -121,7 +122,7 @@ under the License.
[java] Actual send rate was 49.64257347100874 messages per second
</code>
</pre>
-
+
<li>For good measure we consumer the messages we produced.</li>
<pre class="prettyprint">
@@ -145,8 +146,8 @@ under the License.
i++;
}
- System.out.println("Received " + i + " messages");
-
+ System.out.println("Received " + i + " messages");
+
</code>
</pre>
@@ -160,7 +161,7 @@ under the License.
{
initialContext.close();
}
-
+
if (connection != null)
{
connection.close();
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/producer-rate-limit/src/main/java/org/apache/activemq/artemis/jms/example/ProducerRateLimitExample.java
----------------------------------------------------------------------
diff --git a/examples/jms/producer-rate-limit/src/main/java/org/apache/activemq/artemis/jms/example/ProducerRateLimitExample.java b/examples/jms/producer-rate-limit/src/main/java/org/apache/activemq/artemis/jms/example/ProducerRateLimitExample.java
index c949122..cfae82e 100644
--- a/examples/jms/producer-rate-limit/src/main/java/org/apache/activemq/artemis/jms/example/ProducerRateLimitExample.java
+++ b/examples/jms/producer-rate-limit/src/main/java/org/apache/activemq/artemis/jms/example/ProducerRateLimitExample.java
@@ -23,7 +23,9 @@ import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
-import javax.naming.InitialContext;
+
+import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
+import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
/**
* This example demonstrates how a message producer can be limited to produce messages at a maximum rate
@@ -34,17 +36,13 @@ public class ProducerRateLimitExample
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");
+ Queue queue = ActiveMQJMSClient.createQueue("exampleQueue");
// Step 3. Perform a lookup on the Connection Factory
- ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("ConnectionFactory");
+ ConnectionFactory cf = new ActiveMQConnectionFactory("tcp://localhost:61616?producerMaxRate=50");
// Step 4. Create a JMS Connection
connection = cf.createConnection();
@@ -106,10 +104,6 @@ public class ProducerRateLimitExample
finally
{
// Step 9. Be sure to close our resources!
- if (initialContext != null)
- {
- initialContext.close();
- }
if (connection != null)
{
connection.close();
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/proton-cpp/pom.xml
----------------------------------------------------------------------
diff --git a/examples/jms/proton-cpp/pom.xml b/examples/jms/proton-cpp/pom.xml
index 240667d..32d2185 100644
--- a/examples/jms/proton-cpp/pom.xml
+++ b/examples/jms/proton-cpp/pom.xml
@@ -18,7 +18,8 @@ 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">
+<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>
@@ -27,7 +28,7 @@ under the License.
<version>1.0.1-SNAPSHOT</version>
</parent>
- <artifactId>artemis-jms-protoncpp</artifactId>
+ <artifactId>protoncpp</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ Artemis AMQP CPP Example</name>
@@ -49,64 +50,73 @@ under the License.
<profiles>
<profile>
- <id>example</id>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- </execution>
- <execution>
- <id>start</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <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.ProtonCPPExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.jms</groupId>
- <artifactId>artemis-jms-protoncpp</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
+ <!-- specify -PnoServer if you don't want to start the server -->
+ <id>noServer</id>
+ <properties>
+ <noServer>true</noServer>
+ </properties>
</profile>
</profiles>
+ <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.ProtonCPPExample</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.jms</groupId>
+ <artifactId>protoncpp</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ </plugin>
+ </plugins>
+ </build>
</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/proton-j/pom.xml
----------------------------------------------------------------------
diff --git a/examples/jms/proton-j/pom.xml b/examples/jms/proton-j/pom.xml
index 2cdf0c8..ebd92c4 100644
--- a/examples/jms/proton-j/pom.xml
+++ b/examples/jms/proton-j/pom.xml
@@ -18,7 +18,8 @@ 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">
+<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>
@@ -27,7 +28,7 @@ under the License.
<version>1.0.1-SNAPSHOT</version>
</parent>
- <artifactId>artemis-proton-j-example</artifactId>
+ <artifactId>artemis-proton-j</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ Artemis Proton-J Example</name>
@@ -45,64 +46,73 @@ under the License.
<profiles>
<profile>
- <id>example</id>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- </execution>
- <execution>
- <id>start</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <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.ProtonJExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.jms</groupId>
- <artifactId>artemis-proton-j-example</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
+ <!-- specify -PnoServer if you don't want to start the server -->
+ <id>noServer</id>
+ <properties>
+ <noServer>true</noServer>
+ </properties>
</profile>
</profiles>
+ <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.ProtonJExample</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.jms</groupId>
+ <artifactId>artemis-proton-j</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ </plugin>
+ </plugins>
+ </build>
</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/proton-j/readme.html
----------------------------------------------------------------------
diff --git a/examples/jms/proton-j/readme.html b/examples/jms/proton-j/readme.html
index 7a5c88a..fd77ffc 100644
--- a/examples/jms/proton-j/readme.html
+++ b/examples/jms/proton-j/readme.html
@@ -27,6 +27,9 @@ under the License.
<body onload="prettyPrint()">
<h1>Proton qpid java example</h1>
+<pre>To run the example, simply type <b>mvn verify</b> from this directory, <br>or <b>mvn -PnoServer verify</b> if you want to start and create the server manually.</pre>
+
+
<<p>ActiveMQ Artemis is a multi protocol broker. It will inspect the initial handshake of clients to determine what protocol to use.</p>
<p>All you need to do is to connect a client into activemq's configured port and you should be able connect.</p>
<p>To run this example simply run the command <literal>mvn verify -Pexample</literal>, execute the compile.sh script and start the executable called ./hello</p>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/proton-ruby/pom.xml
----------------------------------------------------------------------
diff --git a/examples/jms/proton-ruby/pom.xml b/examples/jms/proton-ruby/pom.xml
index 54f2269..6a90b8d 100644
--- a/examples/jms/proton-ruby/pom.xml
+++ b/examples/jms/proton-ruby/pom.xml
@@ -18,7 +18,8 @@ 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">
+<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>
@@ -27,7 +28,7 @@ under the License.
<version>1.0.1-SNAPSHOT</version>
</parent>
- <artifactId>artemis-jms-proton-ruby-example</artifactId>
+ <artifactId>proton-ruby</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ Artemis Proton Ruby Example</name>
@@ -35,37 +36,32 @@ under the License.
<activemq.basedir>${project.basedir}/../../..</activemq.basedir>
</properties>
- <profiles>
- <profile>
- <id>example</id>
- <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>
- <configuration>${basedir}/target/classes/activemq/server0</configuration>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.jms</groupId>
- <artifactId>artemis-jms-proton-ruby-example</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
- </profile>
- </profiles>
+ <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>
+ <configuration>${basedir}/target/classes/activemq/server0</configuration>
+ </configuration>
+ </execution>
+ </executions>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.activemq.examples.jms</groupId>
+ <artifactId>proton-ruby</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ </plugin>
+ </plugins>
+ </build>
</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/proton-ruby/readme.html
----------------------------------------------------------------------
diff --git a/examples/jms/proton-ruby/readme.html b/examples/jms/proton-ruby/readme.html
index 951a654..95c15b0 100644
--- a/examples/jms/proton-ruby/readme.html
+++ b/examples/jms/proton-ruby/readme.html
@@ -42,7 +42,7 @@ under the License.
</code>
</pre>
<h2>Example step-by-step</h2>
- <p>Firstly create the server by running the command <literal>mvn verify -Pexample</literal></p>
+ <p>Firstly create the server by running the command <literal>mvn verify</literal></p>
<p>Start the server manually under ./target/server1/bin by calling ./artemis run</p>
<p>Then in a separate window you can run the send ruby script by running the command <literal>ruby src/main/scripts/send.rb</literal></p>
<p>You can then receive the message via the receive ruby script by running <literal>ruby src/main/scripts/receive.rb</literal></p>