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/13 06:13:53 UTC
[35/48] activemq-artemis git commit: renaming broker-features ->
features on examples
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jms-context/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jms-context/pom.xml b/examples/broker-features/standard/jms-context/pom.xml
deleted file mode 100644
index 1f3e017..0000000
--- a/examples/broker-features/standard/jms-context/pom.xml
+++ /dev/null
@@ -1,109 +0,0 @@
-<?xml version='1.0'?>
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.activemq.examples.broker</groupId>
- <artifactId>jms-examples</artifactId>
- <version>1.0.1-SNAPSHOT</version>
- </parent>
-
- <artifactId>context</artifactId>
- <packaging>jar</packaging>
- <name>ActiveMQ Artemis JMS Context Example</name>
-
- <properties>
- <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-jms-client</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- </configuration>
- </execution>
- <execution>
- <id>start</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <spawn>true</spawn>
- <testURI>tcp://localhost:61616</testURI>
- <args>
- <param>run</param>
- </args>
- </configuration>
- </execution>
- <execution>
- <id>runClient</id>
- <goals>
- <goal>runClient</goal>
- </goals>
- <configuration>
- <clientClass>org.apache.activemq.artemis.jms.example.JMSContextExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.broker</groupId>
- <artifactId>context</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
-
-</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jms-context/readme.html
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jms-context/readme.html b/examples/broker-features/standard/jms-context/readme.html
deleted file mode 100644
index 34895a2..0000000
--- a/examples/broker-features/standard/jms-context/readme.html
+++ /dev/null
@@ -1,35 +0,0 @@
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<html>
- <head>
- <title>ActiveMQ Artemis JMS Context 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 Context 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 you how to send and receive a message to a JMS Queue using ActiveMQ Artemis by using a JMS Context</p>
- <p>A JMSContext is part of JMS 2.0 and combines the JMS Connection and Session Objects into a simple Interface</p>
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jms-context/src/main/java/org/apache/activemq/artemis/jms/example/JMSContextExample.java
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jms-context/src/main/java/org/apache/activemq/artemis/jms/example/JMSContextExample.java b/examples/broker-features/standard/jms-context/src/main/java/org/apache/activemq/artemis/jms/example/JMSContextExample.java
deleted file mode 100644
index d2a341c..0000000
--- a/examples/broker-features/standard/jms-context/src/main/java/org/apache/activemq/artemis/jms/example/JMSContextExample.java
+++ /dev/null
@@ -1,51 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activemq.artemis.jms.example;
-
-import javax.jms.DeliveryMode;
-import javax.jms.JMSContext;
-import javax.jms.Queue;
-
-import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
-import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
-
-/**
- * A simple JMS Queue example that creates a producer and consumer on a queue and sends then receives a message.
- */
-public class JMSContextExample {
-
- public static void main(final String[] args) throws Exception {
- // Instantiate the queue
- Queue queue = ActiveMQJMSClient.createQueue("exampleQueue");
-
- // Instantiate the ConnectionFactory (Using the default URI on this case)
- // Also instantiate the jmsContext
- // Using closeable interface
- try (ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory();
- JMSContext jmsContext = cf.createContext()) {
- // Create a message producer, note that we can chain all this into one statement
- jmsContext.createProducer().setDeliveryMode(DeliveryMode.PERSISTENT).send(queue, "this is a string");
-
- // Create a Consumer and receive the payload of the message direct.
- String payLoad = jmsContext.createConsumer(queue).receiveBody(String.class);
-
- System.out.println("payLoad = " + payLoad);
-
- }
-
- }
-}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jms-shared-consumer/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jms-shared-consumer/pom.xml b/examples/broker-features/standard/jms-shared-consumer/pom.xml
deleted file mode 100644
index e5fa1ce..0000000
--- a/examples/broker-features/standard/jms-shared-consumer/pom.xml
+++ /dev/null
@@ -1,111 +0,0 @@
-<?xml version='1.0'?>
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.activemq.examples.broker</groupId>
- <artifactId>jms-examples</artifactId>
- <version>1.0.1-SNAPSHOT</version>
- </parent>
-
- <artifactId>shared-consumer</artifactId>
- <packaging>jar</packaging>
- <name>ActiveMQ Artemis JMS Shared Consumer Example</name>
-
- <properties>
- <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-jms-client</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <instance>${basedir}/target/server0</instance>
- <configuration>${basedir}/target/classes/activemq/server0</configuration>
- </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.JMSSharedConsumerExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.broker</groupId>
- <artifactId>shared-consumer</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
-
-</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jms-shared-consumer/readme.html
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jms-shared-consumer/readme.html b/examples/broker-features/standard/jms-shared-consumer/readme.html
deleted file mode 100644
index b92b340..0000000
--- a/examples/broker-features/standard/jms-shared-consumer/readme.html
+++ /dev/null
@@ -1,119 +0,0 @@
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<html>
- <head>
- <title>ActiveMQ Artemis JMS Shared Consumer 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 Shared Consumer 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 you how can use shared consumers to share a subscription on a topic. In JMS 1.1 this was not allowed
- and so caused a scalability issue. In JMS 2 this restriction has been lifted so you can share the load across different
- threads and connections.</p>
-
- <h2>Example step-by-step</h2>
-
- <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 topic object from JNDI</li>
- <pre class="prettyprint">
- <code>Topic topic = (Topic) initialContext.lookup("/topic/exampleTopic");</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 context</li>
- <pre class="prettyprint">
- <code>jmsContext = cf.createContext();</code>
- </pre>
-
- <li>We create a JMS Producer.</li>
- <pre class="prettyprint">
- <code>JMSProducer producer = jmsContext.createProducer();</code>
- </pre>
-
- <li>We create a shared consumer using the subscription name <literal>sc1</literal></li>
- <pre class="prettyprint">
- <code>JMSConsumer jmsConsumer = jmsContext.createSharedConsumer(topic, "sc1");</code>
- </pre>
-
- <li>We then create a second JMS context for a second shared consumer</li>
- <pre class="prettyprint">
- <code>jmsContext2 = cf.createContext();</code>
- </pre>
-
- <li>we then create the second shared consumer using the same subscription name</li>
- <pre class="prettyprint">
- <code>JMSConsumer jmsConsumer2 = jmsContext2.createSharedConsumer(topic, "sc1");</code>
- </pre>
-
- <li>we then send 2 messages</li>
- <pre class="prettyprint">
- <code>
- producer.send(topic, "this is a String!");
-
- producer.send(topic, "this is a second String!") ;</code>
- </pre>
-
- <li>we then receive the 2 messages using both shared consumers</li>
- <pre class="prettyprint">
- <code>
- String body = jmsConsumer.receiveBody(String.class, 5000);
-
- body = jmsConsumer2.receiveBody(String.class, 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 (initialContext != null)
- {
- initialContext.close();
- }
- if (jmsContext != null)
- {
- jmsContext.close();
- }
- if (jmsContext2 != null)
- {
- jmsContext2.close();
- }
- }</code>
- </pre>
-
-
-
- </ol>
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jms-shared-consumer/src/main/java/org/apache/activemq/artemis/jms/example/JMSSharedConsumerExample.java
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jms-shared-consumer/src/main/java/org/apache/activemq/artemis/jms/example/JMSSharedConsumerExample.java b/examples/broker-features/standard/jms-shared-consumer/src/main/java/org/apache/activemq/artemis/jms/example/JMSSharedConsumerExample.java
deleted file mode 100644
index da43eb0..0000000
--- a/examples/broker-features/standard/jms-shared-consumer/src/main/java/org/apache/activemq/artemis/jms/example/JMSSharedConsumerExample.java
+++ /dev/null
@@ -1,87 +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.ConnectionFactory;
-import javax.jms.JMSConsumer;
-import javax.jms.JMSContext;
-import javax.jms.JMSProducer;
-import javax.jms.Topic;
-import javax.naming.InitialContext;
-
-/**
- * A JMS Example that uses shared consumers.
- */
-public class JMSSharedConsumerExample {
-
- public static void main(final String[] args) throws Exception {
- InitialContext initialContext = null;
- JMSContext jmsContext = null;
- JMSContext jmsContext2 = null;
- try {
- // Step 1. Create an initial context to perform the JNDI lookup.
- initialContext = new InitialContext();
-
- // Step 2. Perfom a lookup on the queue
- Topic topic = (Topic) initialContext.lookup("topic/exampleTopic");
-
- // Step 3. Perform a lookup on the Connection Factory
- ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("ConnectionFactory");
-
- // Step 4.Create a JMS Context
- jmsContext = cf.createContext();
-
- // Step 5. Create a message producer.
- JMSProducer producer = jmsContext.createProducer();
-
- // Step 6. Create a shared consumer
- JMSConsumer jmsConsumer = jmsContext.createSharedConsumer(topic, "sc1");
-
- // Step 7. Create a second JMS Context for a second shared consumer
- jmsContext2 = cf.createContext();
-
- // Step 8. Create the second shared consumer
- JMSConsumer jmsConsumer2 = jmsContext2.createSharedConsumer(topic, "sc1");
-
- // Step 9. send 2 messages
- producer.send(topic, "this is a String!");
-
- producer.send(topic, "this is a second String!");
-
- // Step 10. receive the messages shared by both consumers
- String body = jmsConsumer.receiveBody(String.class, 5000);
-
- System.out.println("body = " + body);
-
- body = jmsConsumer2.receiveBody(String.class, 5000);
-
- System.out.println("body = " + body);
- }
- finally {
- // Step 11. Be sure to close our JMS resources!
- if (initialContext != null) {
- initialContext.close();
- }
- if (jmsContext != null) {
- jmsContext.close();
- }
- if (jmsContext2 != null) {
- jmsContext2.close();
- }
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jms-shared-consumer/src/main/resources/activemq/server0/artemis-roles.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jms-shared-consumer/src/main/resources/activemq/server0/artemis-roles.properties b/examples/broker-features/standard/jms-shared-consumer/src/main/resources/activemq/server0/artemis-roles.properties
deleted file mode 100644
index 4e2d44c..0000000
--- a/examples/broker-features/standard/jms-shared-consumer/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/6b17d966/examples/broker-features/standard/jms-shared-consumer/src/main/resources/activemq/server0/artemis-users.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jms-shared-consumer/src/main/resources/activemq/server0/artemis-users.properties b/examples/broker-features/standard/jms-shared-consumer/src/main/resources/activemq/server0/artemis-users.properties
deleted file mode 100644
index 4e2d44c..0000000
--- a/examples/broker-features/standard/jms-shared-consumer/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/6b17d966/examples/broker-features/standard/jms-shared-consumer/src/main/resources/activemq/server0/broker.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jms-shared-consumer/src/main/resources/activemq/server0/broker.xml b/examples/broker-features/standard/jms-shared-consumer/src/main/resources/activemq/server0/broker.xml
deleted file mode 100644
index 2b2ba2e..0000000
--- a/examples/broker-features/standard/jms-shared-consumer/src/main/resources/activemq/server0/broker.xml
+++ /dev/null
@@ -1,61 +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 topic used by the example-->
- <topic name="exampleTopic"/>
- </jms>
-
- <core xmlns="urn:activemq:core">
-
- <bindings-directory>${data.dir:../data}/bindings</bindings-directory>
-
- <journal-directory>${data.dir:../data}/journal</journal-directory>
-
- <large-messages-directory>${data.dir:../data}/largemessages</large-messages-directory>
-
- <paging-directory>${data.dir:../data}/paging</paging-directory>
-
- <!-- Acceptors -->
-
- <acceptors>
- <acceptor name="netty-acceptor">tcp://localhost:61616</acceptor>
- </acceptors>
-
- <!-- Other config -->
-
- <security-settings>
- <!--security for example topic-->
- <security-setting match="jms.topic.exampleTopic">
- <permission type="createDurableQueue" roles="guest"/>
- <permission type="deleteDurableQueue" roles="guest"/>
- <permission type="createNonDurableQueue" roles="guest"/>
- <permission type="deleteNonDurableQueue" roles="guest"/>
- <permission type="consume" roles="guest"/>
- <permission type="send" roles="guest"/>
- </security-setting>
- </security-settings>
-
- </core>
-</configuration>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jms-shared-consumer/src/main/resources/jndi.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jms-shared-consumer/src/main/resources/jndi.properties b/examples/broker-features/standard/jms-shared-consumer/src/main/resources/jndi.properties
deleted file mode 100644
index 54bed6d..0000000
--- a/examples/broker-features/standard/jms-shared-consumer/src/main/resources/jndi.properties
+++ /dev/null
@@ -1,20 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-
-java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
-connectionFactory.ConnectionFactory=tcp://localhost:61616
-topic.topic/exampleTopic=exampleTopic
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jmx/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jmx/pom.xml b/examples/broker-features/standard/jmx/pom.xml
deleted file mode 100644
index 693b2fc..0000000
--- a/examples/broker-features/standard/jmx/pom.xml
+++ /dev/null
@@ -1,117 +0,0 @@
-<?xml version='1.0'?>
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.activemq.examples.broker</groupId>
- <artifactId>jms-examples</artifactId>
- <version>1.0.1-SNAPSHOT</version>
- </parent>
-
- <artifactId>jmx</artifactId>
- <packaging>jar</packaging>
- <name>ActiveMQ Artemis JMS "JMX" Example</name>
-
- <properties>
- <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-core-client</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-jms-client</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <!-- options used for JMX on the example -->
- <javaOptions>-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=3000 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false
- </javaOptions>
- </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.JMXExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.broker</groupId>
- <artifactId>jmx</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
-
-</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jmx/readme.html
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jmx/readme.html b/examples/broker-features/standard/jmx/readme.html
deleted file mode 100644
index 8dd4fe9..0000000
--- a/examples/broker-features/standard/jmx/readme.html
+++ /dev/null
@@ -1,181 +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 JMX Management 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>JMX Management 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 to manage ActiveMQ Artemis using <a href="http://java.sun.com/javase/technologies/core/mntr-mgmt/javamanagement/">JMX</a></p>
-
- <h2>Example configuration</h2>
-
- <p>ActiveMQ Artemis exposes its managed resources by default on the platform MBeanServer.</p>
- <p>To access this MBeanServer remotely, the Java Virtual machine must be started with system properties:
- <pre class="prettyprint">
- <code>-Dcom.sun.management.jmxremote
- -Dcom.sun.management.jmxremote.port=3000
- -Dcom.sun.management.jmxremote.ssl=false
- -Dcom.sun.management.jmxremote.authenticate=false</code>
- </pre>
- <p>These properties are explained in the Java 5 <a href="http://java.sun.com/j2se/1.5.0/docs/guide/management/agent.html#remote">Management guide</a>
- (please note that for this example, we will disable user authentication for simplicity sake).</p>
- <p>With these properties, ActiveMQ Artemis server will be manageable remotely using standard JMX URL on port <code>3000</code>.</p>
- </p>
-
- <h2>Example step-by-step</h2>
- <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 its properties from <a href="server0/client-jndi.properties">client-jndi.properties</a></li>
- <pre class="prettyprint">
- <code>InitialContext initialContext = getContext(0);</code>
- </pre>
-
- <li>We look up the JMS queue object from JNDI</li>
- <pre class="prettyprint">
- <code>Queue queue = (Queue) initialContext.lookup("/queue/exampleQueue");</code>
- </pre>
-
- <li>We 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>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>
-
- <p><em>Now that we have a message in the queue, we will manage the queue by retrieving the number of messages in the queue
- (i.e. 1) and by removing the message which has been sent in step 8.</em></p>
-
- <li>We retrieve the <code>ObjectName</code> corresponding to the queue using a helper class <code>ObjectNameBuilder</code></li>
- <pre class="prettyprint">
- <code>ObjectName on = ObjectNameBuilder.DEFAULT.getJMSQueueObjectName(queue.getQueueName());</code>
- </pre>
-
- <li>We create a JMX Connector to connect to the server's MBeanServer using the <a href="http://java.sun.com/j2se/1.5.0/docs/guide/management/agent.html#connecting">standard JMX service URL</a></li>
- <pre class="prettyprint">
- <code>JMXConnector connector = JMXConnectorFactory.connect(new JMXServiceURL(JMX_URL), new HashMap());</code>
- </pre>
-
- <li>We retrieve a <code>MBeanServerConnection</code> from the JMX connector</li>
- <pre class="prettyprint">
- <code>TextMessage messageReceived = (TextMessage) messageConsumer.receive(5000);</code>
- </pre>
-
- <li>We create a <code>JMSQueueControl</code> proxy to manage the queue on the server</li>
- <pre class="prettyprint">
- <code>JMSQueueControl queueControl = (JMSQueueControl)MBeanServerInvocationHandler.newProxyInstance(mbsc,
- on,
- JMSQueueControl.class,
- false);
- </code>
- </pre>
-
- <li>We use this mbean proxy to retrieve the number of messages in the queue using the <code>getMessageCount</code> method</li>
- <pre class="prettyprint">
- <code>System.out.println(queueControl.getName() + " contains " + queueControl.getMessageCount() + " messages");</code>
- </pre>
-
- <li>We will now remove the message sent at step 8 using the <code>removeMessage</code> method with the JMS Message ID of the message</li>
- <pre class="prettyprint">
- <code>System.out.println("message has been removed: " + queueControl.removeMessage(message.getJMSMessageID()));</code>
- </pre>
-
- <li>We use again the mbean proxy to retrieve the number of messages. This time, it will display <code>0</code> messages</li>
- <pre class="prettyprint">
- <code>System.out.println(queueControl.getName() + " contains " + queueControl.getMessageCount() + " messages");</code>
- </pre>
-
- <li>Now we have finish the management operations, we close the JMX connector</li>
- <pre class="prettyprint">
- <code>connector.close()</code>
- </pre>
-
- <p><em>We will now try to consume the message sent to the queue but it won't be there: it has been removed by the management operation</em></p>
-
- <li>We create a JMS message consumer on the queue</li>
- <pre class="prettyprint">
- <code>MessageConsumer messageConsumer = session.createConsumer(queue);</code>
- </pre>
-
- <li>We start the connection. In order for delivery to occur on any consumers or subscribers on a connection, the connection must be started</li>
- <pre class="prettyprint">
- <code>connection.start();</code>
- </pre>
-
- <li>We try to receive a message from the queue. Since there is none, the call will timeout after 5000ms and messageReceived will be null
- </li>
- <pre class="prettyprint">
- <code>TextMessage messageReceived = (TextMessage) messageConsumer.receive(5000);
- System.out.println("Received message: " + messageReceived);</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>
-
- <h2>More information</h2>
-
- <ul>
- <li>User Manual's <a href="../../../docs/user-manual/en/html_single/index.html#management.jmx">Using Management Via JMX chapter</a></li>
- <li><a href="http://java.sun.com/j2se/1.5.0/docs/guide/management/agent.html">Java 5 Management guide</a></li>
- </ul>
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jmx/src/main/java/org/apache/activemq/artemis/jms/example/JMXExample.java
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jmx/src/main/java/org/apache/activemq/artemis/jms/example/JMXExample.java b/examples/broker-features/standard/jmx/src/main/java/org/apache/activemq/artemis/jms/example/JMXExample.java
deleted file mode 100644
index 108897f..0000000
--- a/examples/broker-features/standard/jmx/src/main/java/org/apache/activemq/artemis/jms/example/JMXExample.java
+++ /dev/null
@@ -1,121 +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 java.util.HashMap;
-
-import javax.jms.MessageConsumer;
-import javax.jms.MessageProducer;
-import javax.jms.Queue;
-import javax.jms.QueueConnection;
-import javax.jms.QueueConnectionFactory;
-import javax.jms.QueueSession;
-import javax.jms.Session;
-import javax.jms.TextMessage;
-import javax.management.MBeanServerConnection;
-import javax.management.MBeanServerInvocationHandler;
-import javax.management.ObjectName;
-import javax.management.remote.JMXConnector;
-import javax.management.remote.JMXConnectorFactory;
-import javax.management.remote.JMXServiceURL;
-import javax.naming.InitialContext;
-
-import org.apache.activemq.artemis.api.core.management.ObjectNameBuilder;
-import org.apache.activemq.artemis.api.jms.management.JMSQueueControl;
-
-/**
- * An example that shows how to manage ActiveMQ Artemis using JMX.
- */
-public class JMXExample {
-
- private static final String JMX_URL = "service:jmx:rmi:///jndi/rmi://localhost:3000/jmxrmi";
-
- public static void main(final String[] args) throws Exception {
- QueueConnection connection = null;
- InitialContext initialContext = null;
- try {
- // Step 1. Create an initial context to perform the JNDI lookup.
- initialContext = new InitialContext();
-
- // Step 2. Perfom a lookup on the queue
- Queue queue = (Queue) initialContext.lookup("queue/exampleQueue");
-
- // Step 3. Perform a lookup on the Connection Factory
- QueueConnectionFactory cf = (QueueConnectionFactory) initialContext.lookup("ConnectionFactory");
-
- // Step 4.Create a JMS Connection
- connection = cf.createQueueConnection();
-
- // Step 5. Create a JMS Session
- QueueSession session = connection.createQueueSession(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");
- System.out.println("Sent message: " + message.getText());
-
- // Step 8. Send the Message
- producer.send(message);
-
- // Step 9. Retrieve the ObjectName of the queue. This is used to identify the server resources to manage
- ObjectName on = ObjectNameBuilder.DEFAULT.getJMSQueueObjectName(queue.getQueueName());
-
- // Step 10. Create JMX Connector to connect to the server's MBeanServer
- JMXConnector connector = JMXConnectorFactory.connect(new JMXServiceURL(JMXExample.JMX_URL), new HashMap());
-
- // Step 11. Retrieve the MBeanServerConnection
- MBeanServerConnection mbsc = connector.getMBeanServerConnection();
-
- // Step 12. Create a JMSQueueControl proxy to manage the queue on the server
- JMSQueueControl queueControl = MBeanServerInvocationHandler.newProxyInstance(mbsc, on, JMSQueueControl.class, false);
- // Step 13. Display the number of messages in the queue
- System.out.println(queueControl.getName() + " contains " + queueControl.getMessageCount() + " messages");
-
- // Step 14. Remove the message sent at step #8
- System.out.println("message has been removed: " + queueControl.removeMessage(message.getJMSMessageID()));
-
- // Step 15. Display the number of messages in the queue
- System.out.println(queueControl.getName() + " contains " + queueControl.getMessageCount() + " messages");
-
- // Step 16. We close the JMX connector
- connector.close();
-
- // Step 17. Create a JMS Message Consumer on the queue
- MessageConsumer messageConsumer = session.createConsumer(queue);
-
- // Step 18. Start the Connection
- connection.start();
-
- // Step 19. Trying to receive a message. Since the only message in the queue was removed by a management
- // operation, there is none to consume.
- // The call will timeout after 5000ms and messageReceived will be null
- TextMessage messageReceived = (TextMessage) messageConsumer.receive(5000);
- System.out.println("Received message: " + messageReceived);
- }
- finally {
- // Step 20. Be sure to close the resources!
- if (initialContext != null) {
- initialContext.close();
- }
- if (connection != null) {
- connection.close();
- }
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jmx/src/main/resources/activemq/server0/artemis-roles.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jmx/src/main/resources/activemq/server0/artemis-roles.properties b/examples/broker-features/standard/jmx/src/main/resources/activemq/server0/artemis-roles.properties
deleted file mode 100644
index 4e2d44c..0000000
--- a/examples/broker-features/standard/jmx/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/6b17d966/examples/broker-features/standard/jmx/src/main/resources/activemq/server0/artemis-users.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jmx/src/main/resources/activemq/server0/artemis-users.properties b/examples/broker-features/standard/jmx/src/main/resources/activemq/server0/artemis-users.properties
deleted file mode 100644
index 4e2d44c..0000000
--- a/examples/broker-features/standard/jmx/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/6b17d966/examples/broker-features/standard/jmx/src/main/resources/activemq/server0/broker.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jmx/src/main/resources/activemq/server0/broker.xml b/examples/broker-features/standard/jmx/src/main/resources/activemq/server0/broker.xml
deleted file mode 100644
index 7a30153..0000000
--- a/examples/broker-features/standard/jmx/src/main/resources/activemq/server0/broker.xml
+++ /dev/null
@@ -1,64 +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>
-
-
- <!-- true to expose ActiveMQ Artemis resources through JMX -->
- <jmx-management-enabled>true</jmx-management-enabled>
-
- <!-- Acceptors -->
- <acceptors>
- <acceptor name="netty">tcp://localhost:61616</acceptor>
- </acceptors>
-
- <!-- Other config -->
-
- <security-settings>
- <!--security for example queue-->
- <security-setting match="jms.queue.exampleQueue">
- <permission type="createDurableQueue" roles="guest"/>
- <permission type="deleteDurableQueue" roles="guest"/>
- <permission type="createNonDurableQueue" roles="guest"/>
- <permission type="deleteNonDurableQueue" roles="guest"/>
- <permission type="consume" roles="guest"/>
- <permission type="send" roles="guest"/>
- </security-setting>
- </security-settings>
-
- </core>
-</configuration>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/jmx/src/main/resources/jndi.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/jmx/src/main/resources/jndi.properties b/examples/broker-features/standard/jmx/src/main/resources/jndi.properties
deleted file mode 100644
index 93537c4..0000000
--- a/examples/broker-features/standard/jmx/src/main/resources/jndi.properties
+++ /dev/null
@@ -1,20 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-
-java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
-connectionFactory.ConnectionFactory=tcp://localhost:61616
-queue.queue/exampleQueue=exampleQueue
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/large-message/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/large-message/pom.xml b/examples/broker-features/standard/large-message/pom.xml
deleted file mode 100644
index 007ccd7..0000000
--- a/examples/broker-features/standard/large-message/pom.xml
+++ /dev/null
@@ -1,88 +0,0 @@
-<?xml version='1.0'?>
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.activemq.examples.broker</groupId>
- <artifactId>jms-examples</artifactId>
- <version>1.0.1-SNAPSHOT</version>
- </parent>
-
- <artifactId>large-message</artifactId>
- <packaging>jar</packaging>
- <name>ActiveMQ Artemis JMS Large Message Example</name>
-
- <properties>
- <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-cli</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-jms-client</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- </execution>
- <execution>
- <id>runClient</id>
- <goals>
- <goal>runClient</goal>
- </goals>
- <configuration>
- <clientClass>org.apache.activemq.artemis.jms.example.LargeMessageExample</clientClass>
- <args>
- <param>${basedir}/target/server0</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.broker</groupId>
- <artifactId>large-message</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
-
-</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/large-message/readme.html
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/large-message/readme.html b/examples/broker-features/standard/large-message/readme.html
deleted file mode 100644
index 0dc42cb..0000000
--- a/examples/broker-features/standard/large-message/readme.html
+++ /dev/null
@@ -1,200 +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 Large Message 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>Large Message Example</h1>
-
- <pre>To run the example, simply type <b>mvn verify</b> from this directory, This example will start and stop the server since it will look for a failure.</pre>
-
-
- <p>This example shows you how to send and receive very large messages with ActiveMQ Artemis.</p>
- <p>ActiveMQ Artemis supports the sending and receiving of huge messages, much larger than can fit in available RAM
- on the client or server. Effectively the only limit to message size is the amount of disk space you have on the server.</p>
- <p>Large messages are persisted on the server so they can survive a server restart. In other words ActiveMQ Artemis doesn't just
- do a simple socket stream from the sender to the consumer.</p>
- <p>In order to do this ActiveMQ Artemis provides an extension to JMS where you can use an InputStream or OutputStream as the source and destination for your messages. You can send messages as large as it would fit in your disk.</p>
- <p>You may also choose to read LargeMessages using the regular ByteStream or ByteMessage methods, but using the InputStream and OutputStream will provide you a much better performance</p>
-
- <h2>Example step-by-step</h2>
- <p>In this example we limit both the server and the client to be running in a maximum of 50MB of RAM,
- and we send a message with a body of size 256MB.</p>
- <p>ActiveMQ Artemis can support much large message sizes but we
- choose these sizes and limit RAM so the example runs more quickly.</p>
- <p>We create a file on disk representing the message body, create
- a FileInputStream on that file and set that InputStream as the body of the message before sending.</p>
- <p>The message is sent, then we stop the server, and restart it. This demonstrates the large message will survive a restart of the server.</p>
- <p>Once the server is restarted we receive the message and stream it's body to another file on disk.</p>
-
- <ol>
- <li>Create an initial context to perform the JNDI lookup.</li>
- <pre class="prettyprint">
- <code>initialContext = getContext(0);</code>
- </pre>
-
- <li>Perfom a lookup on the queue.</li>
- <pre class="prettyprint">
- <code>Queue queue = (Queue)initialContext.lookup("/queue/exampleQueue");</code>
- </pre>
-
- <li>Perform a lookup on the Connection Factory. This ConnectionFactory has a special attribute set on it. activemq-jms.xml)
- Messages with more than 10K are considered large.</li>
- <pre class="prettyprint">
- <code>ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory");</code>
- </pre>
-
- <li>Create the JMS objects for sending the message.</li>
- <pre class="prettyprint">
- <code>
- connection = cf.createConnection();
-
- Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
- MessageProducer producer = session.createProducer(queue);
- </code>
- </pre>
-
- <li>Create a huge file - this will form the body of the message we will send.</li>
- <pre class="prettyprint">
- <code>
- File fileInput = new File("huge_message_to_send.dat");
-
- fileInput.createNewFile();
-
- createFile(fileInput, FILE_SIZE);
- </code>
- </pre>
-
- <li>Create a BytesMessage</li>
- <pre class="prettyprint">
- <code>BytesMessage message = session.createBytesMessage();</code>
- </pre>
-
- <li>We set the InputStream on the message. When sending the message will read the InputStream
- until it gets EOF. In this case we point the InputStream at a file on disk, and it will suck up the entire
- file, however we could use any InputStream not just a FileInputStream.</li>
- <pre class="prettyprint"><code>
- FileInputStream fileInputStream = new FileInputStream(fileInput);
-
- BufferedInputStream bufferedInput = new BufferedInputStream(fileInputStream);
-
- message.setObjectProperty("JMS_AMQ_InputStream", bufferedInput);
- </code></pre>
-
- <li>Send the Message.</li>
- <pre class="prettyprint"><code>
- producer.send(message);
- </code></pre>
-
-
- <li>We send message to the queue. After the send completion the message file will be located at ./build/data/largeMessages</li>
- <pre class="prettyprint">
- <code>messageProducer.send(message);</code>
- </pre>
-
- <li>
- To demonstrate that that we're not simply streaming the message from sending to consumer, we stop
- the server and restart it before consuming the message. This demonstrates that the large message gets persisted, like a
- normal persistent message, on the server. If you look at ./build/data/largeMessages you will see the largeMessage
- stored on disk the server.
- </li>
- <pre class="prettyprint">
- <code>
- connection.close();
-
- initialContext.close();
-
- stopServer(0);
-
- // Give the server a little time to shutdown properly
- Thread.sleep(5000);
-
- startServer(0);
- </code>
- </pre>
-
- <li>Now the server is restarted we can recreate the JMS Objects, and start the new connection.</li>
- <pre class="prettyprint">
- <code>
- initialContext = getContext(0);
-
- queue = (Queue)initialContext.lookup("/queue/exampleQueue");
-
- cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory");
-
- connection = cf.createConnection();
-
- session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
- MessageConsumer messageConsumer = session.createConsumer(queue);
-
- connection.start();
-
- </code>
- </pre>
-
- <li>Receive the message. When we receive the large message we initially just receive the message with
- an empty body.</li>
- <pre class="prettyprint"><code>BytesMessage messageReceived = (BytesMessage)messageConsumer.receive(120000);
- </code></pre>
-
- <li>We set an OutputStream on the message. This causes the message body to be written to the
- OutputStream until there are no more bytes to be written.
- You don't have to use a FileOutputStream, you can use any OutputStream.
- You may choose to use the regular BytesMessage or
- StreamMessage interface but this method is much faster for large messages.</li>
- <pre class="prettyprint"><code>
- File outputFile = new File("huge_message_received.dat");
-
- FileOutputStream fileOutputStream = new FileOutputStream(outputFile);
-
- BufferedOutputStream bufferedOutput = new BufferedOutputStream(fileOutputStream);
-
- </code></pre>
-
- <li>This will save the stream and wait until the entire message is written before continuing.</li>
- <pre class="prettyprint"><code>
- messageReceived.setObjectProperty("JMS_AMQ_SaveStream", bufferedOutput);
- </code></pre>
-
- <li>Be sure to close our resources!</li>
-
- <pre class="prettyprint">
- <code>
- finally
- {
- if (initialContext != null)
- {
- initialContext.close();
- }
- if (connection != null)
- {
- connection.close();
- }
- }</code>
- </pre>
- </ol>
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/large-message/src/main/java/org/apache/activemq/artemis/jms/example/LargeMessageExample.java
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/large-message/src/main/java/org/apache/activemq/artemis/jms/example/LargeMessageExample.java b/examples/broker-features/standard/large-message/src/main/java/org/apache/activemq/artemis/jms/example/LargeMessageExample.java
deleted file mode 100644
index 88ad6cc..0000000
--- a/examples/broker-features/standard/large-message/src/main/java/org/apache/activemq/artemis/jms/example/LargeMessageExample.java
+++ /dev/null
@@ -1,193 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activemq.artemis.jms.example;
-
-import org.apache.activemq.artemis.util.ServerUtil;
-
-import javax.jms.BytesMessage;
-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.naming.InitialContext;
-import java.io.BufferedInputStream;
-import java.io.BufferedOutputStream;
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.FileOutputStream;
-import java.io.IOException;
-
-/**
- * This example demonstrates the ability of ActiveMQ Artemis to send and consume a very large message, much
- * bigger than can fit in RAM.
- */
-public class LargeMessageExample {
-
- /**
- * The message we will send is size 2GiB, even though we are only running in 50MB of RAM on both
- * client and server.
- * <p>
- * This may take some considerable time to create, send and consume - if it takes too long or you
- * don't have enough disk space just reduce the file size here
- */
- private static final long FILE_SIZE = 2L * 1024 * 1024 * 1024; // 2 GiB message
-
- public static void main(final String[] args) throws Exception {
- Process server = null;
- Connection connection = null;
- InitialContext initialContext = null;
-
- try {
- server = ServerUtil.startServer(args[0], LargeMessageExample.class.getSimpleName(), 0, 5000);
-
- // Step 1. Create an initial context to perform the JNDI lookup.
- initialContext = new InitialContext();
-
- // Step 2. Perfom a lookup on the queue
- Queue queue = (Queue) initialContext.lookup("queue/exampleQueue");
-
- // Step 3. Perform a lookup on the Connection Factory. This ConnectionFactory has a special attribute set on
- // it.
- // Messages with more than 10K are considered large
- ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("ConnectionFactory");
-
- // Step 4. Create the JMS objects
- connection = cf.createConnection();
-
- Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
- MessageProducer producer = session.createProducer(queue);
-
- // Step 5. Create a huge file - this will form the body of the message we will send.
-
- System.out.println("Creating a file to send of size " + FILE_SIZE +
- " bytes. This may take a little while... " +
- "If this is too big for your disk you can easily change the FILE_SIZE in the example.");
-
- File fileInput = new File("huge_message_to_send.dat");
-
- createFile(fileInput, FILE_SIZE);
-
- System.out.println("File created.");
-
- // Step 6. Create a BytesMessage
- BytesMessage message = session.createBytesMessage();
-
- // Step 7. We set the InputStream on the message. When sending the message will read the InputStream
- // until it gets EOF. In this case we point the InputStream at a file on disk, and it will suck up the entire
- // file, however we could use any InputStream not just a FileInputStream.
- FileInputStream fileInputStream = new FileInputStream(fileInput);
- BufferedInputStream bufferedInput = new BufferedInputStream(fileInputStream);
-
- message.setObjectProperty("JMS_AMQ_InputStream", bufferedInput);
-
- System.out.println("Sending the huge message.");
-
- // Step 9. Send the Message
- producer.send(message);
-
- System.out.println("Large Message sent");
-
- System.out.println("Stopping server.");
-
- // Step 10. To demonstrate that that we're not simply streaming the message from sending to consumer, we stop
- // the server and restart it before consuming the message. This demonstrates that the large message gets
- // persisted, like a
- // normal persistent message, on the server. If you look at ./build/data/largeMessages you will see the
- // largeMessage stored on disk the server
-
- connection.close();
-
- initialContext.close();
-
- ServerUtil.killServer(server);
-
- server = ServerUtil.startServer(args[0], "LargeMessageExample", 0, 5000);
-
- System.out.println("Server restarted.");
-
- // Step 11. Now the server is restarted we can recreate the JMS Objects, and start the new connection
-
- initialContext = new InitialContext();
-
- queue = (Queue) initialContext.lookup("queue/exampleQueue");
-
- cf = (ConnectionFactory) initialContext.lookup("ConnectionFactory");
-
- connection = cf.createConnection();
-
- session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
- MessageConsumer messageConsumer = session.createConsumer(queue);
-
- connection.start();
-
- System.out.println("Receiving message.");
-
- // Step 12. Receive the message. When we receive the large message we initially just receive the message with
- // an empty body.
- BytesMessage messageReceived = (BytesMessage) messageConsumer.receive(120000);
-
- System.out.println("Received message with: " + messageReceived.getLongProperty("_AMQ_LARGE_SIZE") +
- " bytes. Now streaming to file on disk.");
-
- // Step 13. We set an OutputStream on the message. This causes the message body to be written to the
- // OutputStream until there are no more bytes to be written.
- // You don't have to use a FileOutputStream, you can use any OutputStream.
- // You may choose to use the regular BytesMessage or
- // StreamMessage interface but this method is much faster for large messages.
-
- File outputFile = new File("huge_message_received.dat");
-
- FileOutputStream fileOutputStream = new FileOutputStream(outputFile);
-
- BufferedOutputStream bufferedOutput = new BufferedOutputStream(fileOutputStream);
-
- // Step 14. This will save the stream and wait until the entire message is written before continuing.
- messageReceived.setObjectProperty("JMS_AMQ_SaveStream", bufferedOutput);
-
- fileOutputStream.close();
-
- System.out.println("File streamed to disk. Size of received file on disk is " + outputFile.length());
- }
- finally {
- // Step 12. Be sure to close our resources!
- if (initialContext != null) {
- initialContext.close();
- }
-
- if (connection != null) {
- connection.close();
- }
-
- ServerUtil.killServer(server);
- }
- }
-
- private static void createFile(final File file, final long fileSize) throws IOException {
- FileOutputStream fileOut = new FileOutputStream(file);
- BufferedOutputStream buffOut = new BufferedOutputStream(fileOut);
- byte[] outBuffer = new byte[1024 * 1024];
- for (long i = 0; i < fileSize; i += outBuffer.length) {
- buffOut.write(outBuffer);
- }
- buffOut.close();
- }
-
-}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/large-message/src/main/resources/jndi.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/large-message/src/main/resources/jndi.properties b/examples/broker-features/standard/large-message/src/main/resources/jndi.properties
deleted file mode 100644
index 93537c4..0000000
--- a/examples/broker-features/standard/large-message/src/main/resources/jndi.properties
+++ /dev/null
@@ -1,20 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-
-java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
-connectionFactory.ConnectionFactory=tcp://localhost:61616
-queue.queue/exampleQueue=exampleQueue
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/standard/last-value-queue/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/standard/last-value-queue/pom.xml b/examples/broker-features/standard/last-value-queue/pom.xml
deleted file mode 100644
index e38c08e..0000000
--- a/examples/broker-features/standard/last-value-queue/pom.xml
+++ /dev/null
@@ -1,109 +0,0 @@
-<?xml version='1.0'?>
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.activemq.examples.broker</groupId>
- <artifactId>jms-examples</artifactId>
- <version>1.0.1-SNAPSHOT</version>
- </parent>
-
- <artifactId>last-value-queue</artifactId>
- <packaging>jar</packaging>
- <name>ActiveMQ Artemis JMS Last Value Queue Example</name>
-
- <properties>
- <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-jms-client</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create</id>
- <goals>
- <goal>create</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- </configuration>
- </execution>
- <execution>
- <id>start</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <spawn>true</spawn>
- <testURI>tcp://localhost:61616</testURI>
- <args>
- <param>run</param>
- </args>
- </configuration>
- </execution>
- <execution>
- <id>runClient</id>
- <goals>
- <goal>runClient</goal>
- </goals>
- <configuration>
- <clientClass>org.apache.activemq.artemis.jms.example.LastValueQueueExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.broker</groupId>
- <artifactId>last-value-queue</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
-
-</project>