http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/stomp/readme.html ---------------------------------------------------------------------- diff --git a/examples/jms/stomp/readme.html b/examples/jms/stomp/readme.html index 3935090..8f07f11 100644 --- a/examples/jms/stomp/readme.html +++ b/examples/jms/stomp/readme.html @@ -27,104 +27,12 @@ under the License. <body onload="prettyPrint()"> <h1>Stomp 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 configure ActiveMQ Artemis to send and receive Stomp messages.</p> <p>The example will start a ActiveMQ Artemis server configured with Stomp and JMS.</p> - <p>The client will open a socket to send one Stomp message (using TCP directly). + <p>The client will open a socket to send one Stomp message (using TCP directly). The client will then consume a message from a JMS Queue and check it is the message sent with Stomp.</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>We create a TCP socket to connect to the Stomp port - <pre class="prettyprint"> - Socket socket = new Socket("localhost", 61613); - </pre> - - <li>We send a CONNECT frame to connect to the server</li> - <pre class="prettyprint"> - String connectFrame = "CONNECT\n" + - "login: guest\n" + - "passcode: guest\n" + - "request-id: 1\n" + - "\n" + - Stomp.NULL; - sendFrame(socket, connectFrame); - </pre> - - <li>We send a SEND frame (a Stomp message) to the destination <code>jms.queue.exampleQueue</code> - (which corresponds to the ActiveMQ Artemis address for the JMS Queue <code>exampleQueue</code>) with a text body</li> - <pre class="prettyprint"> - String text = "Hello, world from Stomp!"; - String message = "SEND\n" + - "destination: jms.queue.exampleQueue\n" + - "\n" + - text + - Stomp.NULL; - sendFrame(socket, message); - System.out.println("Sent Stomp message: " + text); - </pre> - - <li>We send a DISCONNECT frame to disconnect from the server</li> - <pre class="prettyprint"> - String disconnectFrame = "DISCONNECT\n" + - "\n" + - Stomp.NULL; - sendFrame(socket, disconnectFrame); - </pre> - - <li>We close the TCP socket</li> - <pre class="prettyprint"> - socket.close(); - </pre> - - <li>We create an initial context to perform the JNDI lookup.</li> - <pre class="prettyprint"> - initialContext = getContext(0); - </pre> - - <li>We perform a lookup on the queue and the connection factory</li> - <pre class="prettyprint"> - Queue queue = (Queue)initialContext.lookup("/queue/exampleQueue"); - ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); - </pre> - - <li>We create a JMS Connection, Session and a MessageConsumer on the queue</li> - <pre class="prettyprint"> - connection = cf.createConnection(); - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - MessageConsumer consumer = session.createConsumer(queue); - </pre> - - <li>We start the connection</li> - <pre class="prettyprint"> - <code>connection.start();</code> - </pre> - - <li>We receive the message. Stomp messages are mapped to JMS TextMessage.</li> - <pre class="prettyprint"> - TextMessage messageReceived = (TextMessage)consumer.receive(5000); - System.out.println("Received JMS message: " + messageReceived.getText()); - </pre> - - <li>And finally, <b>always</b> remember to close your JMS connections and resources after use, in a <code>finally</code> block. Closing a JMS connection will automatically close all of its sessions, consumers, producer and browser objects</li> - - <pre class="prettyprint"> - <code>finally - { - if (initialContext != null) - { - initialContext.close(); - } - if (connection != null) - { - connection.close(); - } - }</code> - </pre> - - - - </ol> </body> </html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/stomp1.1/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/pom.xml b/examples/jms/stomp1.1/pom.xml index b17e9c0..68ed6cd 100644 --- a/examples/jms/stomp1.1/pom.xml +++ b/examples/jms/stomp1.1/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,9 +28,9 @@ under the License. <version>1.0.1-SNAPSHOT</version> </parent> - <artifactId>artemis-jms-stomp1.1-example</artifactId> + <artifactId>stomp1.1</artifactId> <packaging>jar</packaging> - <name>ActiveMQ Artemis JMS Stomp 1.1 Example</name> + <name>ActiveMQ Artemis JMS Stomp Example</name> <properties> <activemq.basedir>${project.basedir}/../../..</activemq.basedir> @@ -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.StompExample</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-stomp1.1-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.StompExample</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>stomp1.1</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/stomp1.1/readme.html ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/readme.html b/examples/jms/stomp1.1/readme.html index afa0d06..5c3fe61 100644 --- a/examples/jms/stomp1.1/readme.html +++ b/examples/jms/stomp1.1/readme.html @@ -27,112 +27,12 @@ under the License. <body onload="prettyPrint()"> <h1>Stomp 1.1 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 configure ActiveMQ Artemis to send and receive Stomp messages using Stomp 1.1 protocol.</p> <p>The example will start a ActiveMQ Artemis server configured with Stomp and JMS.</p> - <p>The client will open a socket to initiate a Stomp 1.1 connection and then send one Stomp message (using TCP directly). + <p>The client will open a socket to initiate a Stomp 1.1 connection and then send one Stomp message (using TCP directly). The client will then consume a message from a JMS Queue and check it is the message sent with Stomp.</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>We create a TCP socket to connect to the Stomp port - <pre class="prettyprint"> - Socket socket = new Socket("localhost", 61613); - </pre> - - <li>We negotiate a Stomp 1.1 connection to the server</li> - <pre class="prettyprint"> - String connectFrame = "CONNECT\n" + - "accept-version:1.1\n" + - "host:localhost\n" + - "login:guest\n" + - "passcode:guest\n" + - "request-id:1\n" + - "\n" + - END_OF_FRAME; - sendFrame(socket, connectFrame); - </pre> - - <li>We receive a response showing that the connection version</li> - <pre> - String response = receiveFrame(socket); - System.out.println("response: " + response); - </pre> - - <li>We send a SEND frame (a Stomp message) to the destination <code>jms.queue.exampleQueue</code> - (which corresponds to the ActiveMQ Artemis address for the JMS Queue <code>exampleQueue</code>) with a text body</li> - <pre class="prettyprint"> - String text = "Hello World from Stomp 1.1 !"; - String message = "SEND\n" + - "destination:jms.queue.exampleQueue\n" + - "\n" + - text + - END_OF_FRAME; - sendFrame(socket, message); - System.out.println("Sent Stomp message: " + text); - </pre> - - <li>We send a DISCONNECT frame to disconnect from the server</li> - <pre class="prettyprint"> - String disconnectFrame = "DISCONNECT\n" + - "\n" + - Stomp.NULL; - sendFrame(socket, disconnectFrame); - </pre> - - <li>We close the TCP socket</li> - <pre class="prettyprint"> - socket.close(); - </pre> - - <li>We create an initial context to perform the JNDI lookup.</li> - <pre class="prettyprint"> - initialContext = getContext(0); - </pre> - - <li>We perform a lookup on the queue and the connection factory</li> - <pre class="prettyprint"> - Queue queue = (Queue)initialContext.lookup("/queue/exampleQueue"); - ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); - </pre> - - <li>We create a JMS Connection, Session and a MessageConsumer on the queue</li> - <pre class="prettyprint"> - connection = cf.createConnection(); - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - MessageConsumer consumer = session.createConsumer(queue); - </pre> - - <li>We start the connection</li> - <pre class="prettyprint"> - <code>connection.start();</code> - </pre> - - <li>We receive the message. Stomp messages are mapped to JMS TextMessage.</li> - <pre class="prettyprint"> - TextMessage messageReceived = (TextMessage)consumer.receive(5000); - System.out.println("Received JMS message: " + messageReceived.getText()); - </pre> - - <li>And finally, <b>always</b> remember to close your JMS connections and resources after use, in a <code>finally</code> block. Closing a JMS connection will automatically close all of its sessions, consumers, producer and browser objects</li> - - <pre class="prettyprint"> - <code>finally - { - if (initialContext != null) - { - initialContext.close(); - } - if (connection != null) - { - connection.close(); - } - }</code> - </pre> - - - - </ol> </body> </html> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/stomp1.1/src/main/resources/activemq/server0/broker.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/src/main/resources/activemq/server0/broker.xml b/examples/jms/stomp1.1/src/main/resources/activemq/server0/broker.xml index 9688ae9..fea1cca 100644 --- a/examples/jms/stomp1.1/src/main/resources/activemq/server0/broker.xml +++ b/examples/jms/stomp1.1/src/main/resources/activemq/server0/broker.xml @@ -29,13 +29,13 @@ under the License. <core xmlns="urn:activemq:core"> - <bindings-directory>${data.dir:./data}/bindings</bindings-directory> + <bindings-directory>./data/bindings</bindings-directory> - <journal-directory>${data.dir:./data}/journal</journal-directory> + <journal-directory>./data/journal</journal-directory> - <large-messages-directory>${data.dir:./data}/largemessages</large-messages-directory> + <large-messages-directory>./data/largemessages</large-messages-directory> - <paging-directory>${data.dir:./data}/paging</paging-directory> + <paging-directory>./data/paging</paging-directory> <!-- Acceptors --> <acceptors> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/stomp1.2/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.2/pom.xml b/examples/jms/stomp1.2/pom.xml index e673181..3cee1db 100644 --- a/examples/jms/stomp1.2/pom.xml +++ b/examples/jms/stomp1.2/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-stomp1.2-example</artifactId> + <artifactId>stomp1.2</artifactId> <packaging>jar</packaging> <name>ActiveMQ Artemis JMS Stomp 1.2 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.StompExample</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-stomp1.2-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.StompExample</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>stomp1.2</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/stomp1.2/readme.html ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.2/readme.html b/examples/jms/stomp1.2/readme.html index f8d94ee..3661f04 100644 --- a/examples/jms/stomp1.2/readme.html +++ b/examples/jms/stomp1.2/readme.html @@ -27,112 +27,12 @@ under the License. <body onload="prettyPrint()"> <h1>Stomp 1.2 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 configure ActiveMQ Artemis to send and receive Stomp messages using Stomp 1.2 protocol.</p> <p>The example will start a ActiveMQ Artemis server configured with Stomp and JMS.</p> - <p>The client will open a socket to initiate a Stomp 1.2 connection and then send one Stomp message (using TCP directly). + <p>The client will open a socket to initiate a Stomp 1.2 connection and then send one Stomp message (using TCP directly). The client will then consume a message from a JMS Queue and check it is the message sent with Stomp.</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>We create a TCP socket to connect to the Stomp port - <pre class="prettyprint"> - Socket socket = new Socket("localhost", 61613); - </pre> - - <li>We negotiate a Stomp 1.2 connection to the server</li> - <pre class="prettyprint"> - String connectFrame = "CONNECT\n" + - "accept-version:1.1\n" + - "host:localhost\n" + - "login:guest\n" + - "passcode:guest\n" + - "request-id:1\n" + - "\n" + - END_OF_FRAME; - sendFrame(socket, connectFrame); - </pre> - - <li>We receive a response showing that the connection version</li> - <pre> - String response = receiveFrame(socket); - System.out.println("response: " + response); - </pre> - - <li>We send a SEND frame (a Stomp message) to the destination <code>jms.queue.exampleQueue</code> - (which corresponds to the ActiveMQ Artemis address for the JMS Queue <code>exampleQueue</code>) with a text body</li> - <pre class="prettyprint"> - String text = "Hello World from Stomp 1.2 !"; - String message = "SEND\n" + - "destination:jms.queue.exampleQueue\n" + - "\n" + - text + - END_OF_FRAME; - sendFrame(socket, message); - System.out.println("Sent Stomp message: " + text); - </pre> - - <li>We send a DISCONNECT frame to disconnect from the server</li> - <pre class="prettyprint"> - String disconnectFrame = "DISCONNECT\n" + - "\n" + - Stomp.NULL; - sendFrame(socket, disconnectFrame); - </pre> - - <li>We close the TCP socket</li> - <pre class="prettyprint"> - socket.close(); - </pre> - - <li>We create an initial context to perform the JNDI lookup.</li> - <pre class="prettyprint"> - initialContext = getContext(0); - </pre> - - <li>We perform a lookup on the queue and the connection factory</li> - <pre class="prettyprint"> - Queue queue = (Queue)initialContext.lookup("/queue/exampleQueue"); - ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); - </pre> - - <li>We create a JMS Connection, Session and a MessageConsumer on the queue</li> - <pre class="prettyprint"> - connection = cf.createConnection(); - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - MessageConsumer consumer = session.createConsumer(queue); - </pre> - - <li>We start the connection</li> - <pre class="prettyprint"> - <code>connection.start();</code> - </pre> - - <li>We receive the message. Stomp messages are mapped to JMS TextMessage.</li> - <pre class="prettyprint"> - TextMessage messageReceived = (TextMessage)consumer.receive(5000); - System.out.println("Received JMS message: " + messageReceived.getText()); - </pre> - - <li>And finally, <b>always</b> remember to close your JMS connections and resources after use, in a <code>finally</code> block. Closing a JMS connection will automatically close all of its sessions, consumers, producer and browser objects</li> - - <pre class="prettyprint"> - <code>finally - { - if (initialContext != null) - { - initialContext.close(); - } - if (connection != null) - { - connection.close(); - } - }</code> - </pre> - - - - </ol> </body> </html> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/stomp1.2/src/main/resources/activemq/server0/broker.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.2/src/main/resources/activemq/server0/broker.xml b/examples/jms/stomp1.2/src/main/resources/activemq/server0/broker.xml index 9688ae9..fea1cca 100644 --- a/examples/jms/stomp1.2/src/main/resources/activemq/server0/broker.xml +++ b/examples/jms/stomp1.2/src/main/resources/activemq/server0/broker.xml @@ -29,13 +29,13 @@ under the License. <core xmlns="urn:activemq:core"> - <bindings-directory>${data.dir:./data}/bindings</bindings-directory> + <bindings-directory>./data/bindings</bindings-directory> - <journal-directory>${data.dir:./data}/journal</journal-directory> + <journal-directory>./data/journal</journal-directory> - <large-messages-directory>${data.dir:./data}/largemessages</large-messages-directory> + <large-messages-directory>./data/largemessages</large-messages-directory> - <paging-directory>${data.dir:./data}/paging</paging-directory> + <paging-directory>./data/paging</paging-directory> <!-- Acceptors --> <acceptors> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/stop-server-failover/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stop-server-failover/pom.xml b/examples/jms/stop-server-failover/pom.xml index 2ba5e69..0a1a9fa 100644 --- a/examples/jms/stop-server-failover/pom.xml +++ b/examples/jms/stop-server-failover/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-stop-server-failover-example</artifactId> + <artifactId>stop-server-failover</artifactId> <packaging>jar</packaging> <name>ActiveMQ Artemis JMS Stop Server Failover Example</name> @@ -37,121 +38,132 @@ 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>create0</id> - <goals> - <goal>create</goal> - </goals> - <configuration> - <instance>${basedir}/target/server0</instance> - <sharedStore>true</sharedStore> - <slave>false</slave> - <dataFolder>../data</dataFolder> - <failoverOnShutdown>true</failoverOnShutdown> - </configuration> - </execution> - <execution> - <id>create1</id> - <goals> - <goal>create</goal> - </goals> - <configuration> - <instance>${basedir}/target/server1</instance> - <sharedStore>true</sharedStore> - <slave>true</slave> - <dataFolder>../data</dataFolder> - <failoverOnShutdown>true</failoverOnShutdown> - </configuration> - </execution> - <execution> - <id>start0</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <spawn>true</spawn> - <location>${basedir}/target/server0</location> - <testURI>tcp://localhost:61616</testURI> - <args> - <param>run</param> - </args> - <name>server0</name> - </configuration> - </execution> - <execution> - <id>start1</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <spawn>true</spawn> - <location>${basedir}/target/server1</location> - <testURI>tcp://localhost:61617</testURI> - <args> - <param>run</param> - </args> - <name>server1</name> - </configuration> - </execution> - <execution> - <id>runClient</id> - <goals> - <goal>runClient</goal> - </goals> - <configuration> - <clientClass>org.apache.activemq.artemis.jms.example.StopServerFailoverExample</clientClass> - </configuration> - </execution> - <execution> - <id>stop0</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <location>${basedir}/target/server0</location> - <args> - <param>stop</param> - </args> - </configuration> - </execution> - <execution> - <id>stop1</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <location>${basedir}/target/server1</location> - <args> - <param>stop</param> - </args> - </configuration> - </execution> - </executions> - <dependencies> - <dependency> - <groupId>org.apache.activemq.examples.jms</groupId> - <artifactId>artemis-jms-stop-server-failover-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>create0</id> + <goals> + <goal>create</goal> + </goals> + <configuration> + <ignore>${noServer}</ignore> + <instance>${basedir}/target/server0</instance> + <sharedStore>true</sharedStore> + <slave>false</slave> + <dataFolder>../data</dataFolder> + <failoverOnShutdown>true</failoverOnShutdown> + </configuration> + </execution> + <execution> + <id>create1</id> + <goals> + <goal>create</goal> + </goals> + <configuration> + <ignore>${noServer}</ignore> + <instance>${basedir}/target/server1</instance> + <sharedStore>true</sharedStore> + <slave>true</slave> + <dataFolder>../data</dataFolder> + <failoverOnShutdown>true</failoverOnShutdown> + </configuration> + </execution> + <execution> + <id>start0</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noServer}</ignore> + <spawn>true</spawn> + <location>${basedir}/target/server0</location> + <testURI>tcp://localhost:61616</testURI> + <args> + <param>run</param> + </args> + <name>server0</name> + </configuration> + </execution> + <execution> + <id>start1</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noServer}</ignore> + <spawn>true</spawn> + <location>${basedir}/target/server1</location> + <testURI>tcp://localhost:61617</testURI> + <args> + <param>run</param> + </args> + <name>server1</name> + </configuration> + </execution> + <execution> + <id>runClient</id> + <goals> + <goal>runClient</goal> + </goals> + <configuration> + <clientClass>org.apache.activemq.artemis.jms.example.StopServerFailoverExample</clientClass> + </configuration> + </execution> + <execution> + <id>stop0</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noServer}</ignore> + <location>${basedir}/target/server0</location> + <args> + <param>stop</param> + </args> + </configuration> + </execution> + <execution> + <id>stop1</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noServer}</ignore> + <location>${basedir}/target/server1</location> + <args> + <param>stop</param> + </args> + </configuration> + </execution> + </executions> + <dependencies> + <dependency> + <groupId>org.apache.activemq.examples.jms</groupId> + <artifactId>stop-server-failover</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/stop-server-failover/readme.html ---------------------------------------------------------------------- diff --git a/examples/jms/stop-server-failover/readme.html b/examples/jms/stop-server-failover/readme.html index 0e83d37..bea5755 100644 --- a/examples/jms/stop-server-failover/readme.html +++ b/examples/jms/stop-server-failover/readme.html @@ -26,130 +26,19 @@ 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, <br>or <b>mvn -PnoServer verify</b> if you want to start and create the server manually.</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> <p>For more information on ActiveMQ Artemis failover and HA, and clustering in general, please see the clustering 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> - <ol> - <li>Get an initial context for looking up JNDI from server #1.</li> - <pre class="prettyprint"> - initialContext = getContext(1); - </pre> - - <li>Look up the JMS resources from JNDI on server #1.</li> - <pre class="prettyprint"> - Queue queue = (Queue)initialContext.lookup("/queue/exampleQueue"); - ConnectionFactory connectionFactory = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); - </pre> - - <li>Create a JMS Connection</li> - <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(); - </pre> - - <li>Create a JMS MessageProducer and MessageConsumer</li> - <pre class="prettyprint"> - MessageProducer producer = session.createProducer(queue); - MessageConsumer consumer = session.createConsumer(queue); - </pre> - - <li>Send some messages to server #1</li> - <pre class="prettyprint"> - for (int i = 0; i < numMessages; i++) - { - TextMessage message = session.createTextMessage("This is text message " + i); - producer.send(message); - System.out.println("Sent message: " + message.getText()); - } - </pre> - - <li>Receive and acknowledge half of the sent messages</li> - <pre class="prettyprint"> - TextMessage message0 = null; - for (int i = 0; i < numMessages / 2; i++) - { - message0 = (TextMessage)consumer.receive(5000); - System.out.println("Got message: " + message0.getText()); - } - 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++) - { - message0 = (TextMessage)consumer.receive(5000); - 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); - Thread.sleep(2000); - </pre> - - <li>Acknowledging the second half of the sent messages will fail as failover to the backup server has occurred</li> - <pre class="prettyprint"> - try - { - message0.acknowledge(); - } - catch (JMSException e) - { - 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++) - { - message0 = (TextMessage)consumer.receive(5000); - System.out.printf("Got message: %s (redelivered?: %s)\n", message0.getText(), message0.getJMSRedelivered()); - } - 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"> - finally - { - if (connection != null) - { - connection.close(); - } - - if (initialContext != null) - { - initialContext.close(); - } - } - </pre> - - </ol> </body> </html> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/symmetric-cluster/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/symmetric-cluster/pom.xml b/examples/jms/symmetric-cluster/pom.xml index d6ed189..f471314 100644 --- a/examples/jms/symmetric-cluster/pom.xml +++ b/examples/jms/symmetric-cluster/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-symmetric-cluster-example</artifactId> + <artifactId>symmetric-cluster</artifactId> <packaging>jar</packaging> <name>ActiveMQ Artemis JMS Symmetric Cluster Example</name> @@ -41,270 +42,288 @@ 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>create0</id> - <goals> - <goal>create</goal> - </goals> - <configuration> - <instance>${basedir}/target/server0</instance> - <configuration>${basedir}/target/classes/activemq/server0</configuration> - <javaOptions>-Dudp-address=${udp-address}</javaOptions> - </configuration> - </execution> - <execution> - <id>create1</id> - <goals> - <goal>create</goal> - </goals> - <configuration> - <instance>${basedir}/target/server1</instance> - <configuration>${basedir}/target/classes/activemq/server1</configuration> - <javaOptions>-Dudp-address=${udp-address}</javaOptions> - </configuration> - </execution> - <execution> - <id>create2</id> - <goals> - <goal>create</goal> - </goals> - <configuration> - <instance>${basedir}/target/server2</instance> - <configuration>${basedir}/target/classes/activemq/server2</configuration> - <javaOptions>-Dudp-address=${udp-address}</javaOptions> - </configuration> - </execution> - <execution> - <id>create3</id> - <goals> - <goal>create</goal> - </goals> - <configuration> - <instance>${basedir}/target/server3</instance> - <configuration>${basedir}/target/classes/activemq/server3</configuration> - <javaOptions>-Dudp-address=${udp-address}</javaOptions> - </configuration> - </execution> - <execution> - <id>create4</id> - <goals> - <goal>create</goal> - </goals> - <configuration> - <instance>${basedir}/target/server4</instance> - <configuration>${basedir}/target/classes/activemq/server4</configuration> - <javaOptions>-Dudp-address=${udp-address}</javaOptions> - </configuration> - </execution> - <execution> - <id>create5</id> - <goals> - <goal>create</goal> - </goals> - <configuration> - <instance>${basedir}/target/server5</instance> - <configuration>${basedir}/target/classes/activemq/server5</configuration> - <javaOptions>-Dudp-address=${udp-address}</javaOptions> - </configuration> - </execution> - <execution> - <id>start0</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <spawn>true</spawn> - <location>${basedir}/target/server0</location> - <testURI>tcp://localhost:61616</testURI> - <args> - <param>run</param> - </args> - <name>server0</name> - </configuration> - </execution> - <execution> - <id>start1</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <spawn>true</spawn> - <location>${basedir}/target/server1</location> - <testURI>tcp://localhost:61617</testURI> - <args> - <param>run</param> - </args> - <name>server1</name> - </configuration> - </execution> - <execution> - <id>start2</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <spawn>true</spawn> - <location>${basedir}/target/server2</location> - <testURI>tcp://localhost:61618</testURI> - <args> - <param>run</param> - </args> - <name>server2</name> - </configuration> - </execution> - <execution> - <id>start3</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <spawn>true</spawn> - <location>${basedir}/target/server3</location> - <testURI>tcp://localhost:61619</testURI> - <args> - <param>run</param> - </args> - <name>server3</name> - </configuration> - </execution> - <execution> - <id>start4</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <spawn>true</spawn> - <location>${basedir}/target/server4</location> - <testURI>tcp://localhost:61620</testURI> - <args> - <param>run</param> - </args> - <name>server4</name> - </configuration> - </execution> - <execution> - <id>start5</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <spawn>true</spawn> - <location>${basedir}/target/server5</location> - <testURI>tcp://localhost:61621</testURI> - <args> - <param>run</param> - </args> - <name>server5</name> - </configuration> - </execution> - <execution> - <id>runClient</id> - <goals> - <goal>runClient</goal> - </goals> - <configuration> - <clientClass>org.apache.activemq.artemis.jms.example.SymmetricClusterExample</clientClass> - </configuration> - </execution> - <execution> - <id>stop0</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <location>${basedir}/target/server0</location> - <args> - <param>stop</param> - </args> - </configuration> - </execution> - <execution> - <id>stop1</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <location>${basedir}/target/server1</location> - <args> - <param>stop</param> - </args> - </configuration> - </execution> - <execution> - <id>stop2</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <location>${basedir}/target/server2</location> - <args> - <param>stop</param> - </args> - </configuration> - </execution> - <execution> - <id>stop3</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <location>${basedir}/target/server3</location> - <args> - <param>stop</param> - </args> - </configuration> - </execution> - <execution> - <id>stop4</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <location>${basedir}/target/server4</location> - <args> - <param>stop</param> - </args> - </configuration> - </execution> - <execution> - <id>stop5</id> - <goals> - <goal>cli</goal> - </goals> - <configuration> - <location>${basedir}/target/server5</location> - <args> - <param>stop</param> - </args> - </configuration> - </execution> - </executions> - <dependencies> - <dependency> - <groupId>org.apache.activemq.examples.jms</groupId> - <artifactId>artemis-jms-symmetric-cluster-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>create0</id> + <goals> + <goal>create</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <instance>${basedir}/target/server0</instance> + <configuration>${basedir}/target/classes/activemq/server0</configuration> + <javaOptions>-Dudp-address=${udp-address}</javaOptions> + </configuration> + </execution> + <execution> + <id>create1</id> + <goals> + <goal>create</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <instance>${basedir}/target/server1</instance> + <configuration>${basedir}/target/classes/activemq/server1</configuration> + <javaOptions>-Dudp-address=${udp-address}</javaOptions> + </configuration> + </execution> + <execution> + <id>create2</id> + <goals> + <goal>create</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <instance>${basedir}/target/server2</instance> + <configuration>${basedir}/target/classes/activemq/server2</configuration> + <javaOptions>-Dudp-address=${udp-address}</javaOptions> + </configuration> + </execution> + <execution> + <id>create3</id> + <goals> + <goal>create</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <instance>${basedir}/target/server3</instance> + <configuration>${basedir}/target/classes/activemq/server3</configuration> + <javaOptions>-Dudp-address=${udp-address}</javaOptions> + </configuration> + </execution> + <execution> + <id>create4</id> + <goals> + <goal>create</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <instance>${basedir}/target/server4</instance> + <configuration>${basedir}/target/classes/activemq/server4</configuration> + <javaOptions>-Dudp-address=${udp-address}</javaOptions> + </configuration> + </execution> + <execution> + <id>create5</id> + <goals> + <goal>create</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <instance>${basedir}/target/server5</instance> + <configuration>${basedir}/target/classes/activemq/server5</configuration> + <javaOptions>-Dudp-address=${udp-address}</javaOptions> + </configuration> + </execution> + <execution> + <id>start0</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <spawn>true</spawn> + <location>${basedir}/target/server0</location> + <testURI>tcp://localhost:61616</testURI> + <args> + <param>run</param> + </args> + <name>server0</name> + </configuration> + </execution> + <execution> + <id>start1</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <spawn>true</spawn> + <location>${basedir}/target/server1</location> + <testURI>tcp://localhost:61617</testURI> + <args> + <param>run</param> + </args> + <name>server1</name> + </configuration> + </execution> + <execution> + <id>start2</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <spawn>true</spawn> + <location>${basedir}/target/server2</location> + <testURI>tcp://localhost:61618</testURI> + <args> + <param>run</param> + </args> + <name>server2</name> + </configuration> + </execution> + <execution> + <id>start3</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <spawn>true</spawn> + <location>${basedir}/target/server3</location> + <testURI>tcp://localhost:61619</testURI> + <args> + <param>run</param> + </args> + <name>server3</name> + </configuration> + </execution> + <execution> + <id>start4</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <spawn>true</spawn> + <location>${basedir}/target/server4</location> + <testURI>tcp://localhost:61620</testURI> + <args> + <param>run</param> + </args> + <name>server4</name> + </configuration> + </execution> + <execution> + <id>start5</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <spawn>true</spawn> + <location>${basedir}/target/server5</location> + <testURI>tcp://localhost:61621</testURI> + <args> + <param>run</param> + </args> + <name>server5</name> + </configuration> + </execution> + <execution> + <id>runClient</id> + <goals> + <goal>runClient</goal> + </goals> + <configuration> + <clientClass>org.apache.activemq.artemis.jms.example.SymmetricClusterExample</clientClass> + </configuration> + </execution> + <execution> + <id>stop0</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <location>${basedir}/target/server0</location> + <args> + <param>stop</param> + </args> + </configuration> + </execution> + <execution> + <id>stop1</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <location>${basedir}/target/server1</location> + <args> + <param>stop</param> + </args> + </configuration> + </execution> + <execution> + <id>stop2</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <location>${basedir}/target/server2</location> + <args> + <param>stop</param> + </args> + </configuration> + </execution> + <execution> + <id>stop3</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <location>${basedir}/target/server3</location> + <args> + <param>stop</param> + </args> + </configuration> + </execution> + <execution> + <id>stop4</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <location>${basedir}/target/server4</location> + <args> + <param>stop</param> + </args> + </configuration> + </execution> + <execution> + <id>stop5</id> + <goals> + <goal>cli</goal> + </goals> + <configuration> + <ignore>${noSever}</ignore> + <location>${basedir}/target/server5</location> + <args> + <param>stop</param> + </args> + </configuration> + </execution> + </executions> + <dependencies> + <dependency> + <groupId>org.apache.activemq.examples.jms</groupId> + <artifactId>symmetric-cluster</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/symmetric-cluster/readme.html ---------------------------------------------------------------------- diff --git a/examples/jms/symmetric-cluster/readme.html b/examples/jms/symmetric-cluster/readme.html index 8be9587..dc8ebc2 100644 --- a/examples/jms/symmetric-cluster/readme.html +++ b/examples/jms/symmetric-cluster/readme.html @@ -27,6 +27,9 @@ under the License. <body onload="prettyPrint()"> <h1>JMS Symmetric Cluster 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 examples demonstrates a <b>symmetric cluster</b> set-up with ActiveMQ Artemis.</p> <p>ActiveMQ Artemis has extremely flexible clustering which allows you to set-up servers in many different topologies.</p> @@ -67,210 +70,5 @@ under the License. by consumers on different nodes.</p> <p>For more information on configuring ActiveMQ Artemis clustering in general, please see the clustering 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> - - <ol> - <li>We instantiate a connection factory directly, specifying the UDP address and port for discovering - the list of servers in the cluster. - We could use JNDI to look-up a connection factory, but we'd need to know the JNDI server host and port for the - specific server to do that, and that server might not be available at the time. By creating the - connection factory directly we avoid having to worry about a JNDI look-up. - In an app server environment you could use HA-JNDI to lookup from the clustered JNDI servers without - having to know about a specific one. - </li> - - <pre class="prettyprint"> - <code> - ConnectionFactory cf = ActiveMQJMSClient.createConnectionFactoryWithHA("231.7.7.7", 9876); - </code> - </pre> - - <li>Directly instantiate JMS Queue and Topic objects</li> - <pre class="prettyprint"> - <code> - Queue queue = new ActiveMQQueue("exampleQueue"); - - Topic topic = ActiveMQJMSClient.createActiveMQTopic("exampleTopic"); - </code> - </pre> - - <li>We create six connections, they should be to different nodes of the cluster in a round-robin fashion - and start them.</li> - <pre class="prettyprint"> - <code> - connection0 = cf.createConnection(); - - connection1 = cf.createConnection(); - - connection2 = cf.createConnection(); - - connection3 = cf.createConnection(); - - connection4 = cf.createConnection(); - - connection5 = cf.createConnection(); - - connection0.start(); - - connection1.start(); - - connection2.start(); - - connection3.start(); - - connection4.start(); - - connection5.start(); - </code> - </pre> - - <li>We create a session on each connection.</li> - <pre class="prettyprint"> - <code> - Session session0 = connection0.createSession(false, Session.AUTO_ACKNOWLEDGE); - - Session session1 = connection1.createSession(false, Session.AUTO_ACKNOWLEDGE); - - Session session2 = connection2.createSession(false, Session.AUTO_ACKNOWLEDGE); - - Session session3 = connection0.createSession(false, Session.AUTO_ACKNOWLEDGE); - - Session session4 = connection1.createSession(false, Session.AUTO_ACKNOWLEDGE); - - Session session5 = connection2.createSession(false, Session.AUTO_ACKNOWLEDGE); - </code> - </pre> - - <li>We create a topic subscriber on each server.</li> - <pre class="prettyprint"> - <code> - MessageConsumer subscriber0 = session0.createConsumer(topic); - - MessageConsumer subscriber1 = session1.createConsumer(topic); - - MessageConsumer subscriber2 = session2.createConsumer(topic); - - MessageConsumer subscriber3 = session3.createConsumer(topic); - - MessageConsumer subscriber4 = session4.createConsumer(topic); - - MessageConsumer subscriber5 = session5.createConsumer(topic); - </code> - </pre> - - <li>We create a queue consumer on server 0.</li> - <pre class="prettyprint"> - <code> - MessageConsumer consumer0 = session0.createConsumer(queue); - </code> - </pre> - - <li>We create an anonymous message producer on server 2.</li> - <pre class="prettyprint"> - <code> - MessageProducer producer2 = session2.createProducer(null); - </code> - </pre> - - <li>We send 500 messages each to the queue and topic.</li> - <pre class="prettyprint"> - <code> - final int numMessages = 500; - - for (int i = 0; i < numMessages; i++) - { - TextMessage message1 = session2.createTextMessage("Topic message 1"); - - producer2.send(topic, message1); - - TextMessage message2 = session2.createTextMessage("Queue message 1"); - - producer2.send(queue, message2); - } - </code> - </pre> - <li>Verify all subscribers and consumer receive the messages.</li> - <pre class="prettyprint"> - <code> - for (int i = 0; i < numMessages; i++) - { - TextMessage received0 = (TextMessage)subscriber0.receive(5000); - - if (received0 == null) - { - return false; - } - - TextMessage received1 = (TextMessage)subscriber1.receive(5000); - - if (received1 == null) - { - return false; - } - - TextMessage received2 = (TextMessage)subscriber2.receive(5000); - - if (received2 == null) - { - return false; - } - - TextMessage received3 = (TextMessage)subscriber3.receive(5000); - - if (received3 == null) - { - return false; - } - - TextMessage received4 = (TextMessage)subscriber4.receive(5000); - - if (received4 == null) - { - return false; - } - - TextMessage received5 = (TextMessage)subscriber5.receive(5000); - - if (received5 == null) - { - return false; - } - - TextMessage received6 = (TextMessage)consumer0.receive(5000); - - if (received6 == null) - { - return false; - } - } - </code> - </pre> - - <li>Be sure to close our resources!</li> - - <pre class="prettyprint"> - <code> - finally - { - if (connection0 != null) - { - connection0.close(); - } - - if (connection1 != null) - { - connection1.close(); - } - - if (connection2 != null) - { - connection2.close(); - } - } - </code> - </pre> - - </ol> </body> </html> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/symmetric-cluster/src/main/resources/activemq/server0/broker.xml ---------------------------------------------------------------------- diff --git a/examples/jms/symmetric-cluster/src/main/resources/activemq/server0/broker.xml b/examples/jms/symmetric-cluster/src/main/resources/activemq/server0/broker.xml index 9c672d7..cd89de7 100644 --- a/examples/jms/symmetric-cluster/src/main/resources/activemq/server0/broker.xml +++ b/examples/jms/symmetric-cluster/src/main/resources/activemq/server0/broker.xml @@ -30,13 +30,13 @@ under the License. <core xmlns="urn:activemq:core"> - <bindings-directory>${data.dir:./data}/bindings</bindings-directory> + <bindings-directory>./data/bindings</bindings-directory> - <journal-directory>${data.dir:./data}/journal</journal-directory> + <journal-directory>./data/journal</journal-directory> - <large-messages-directory>${data.dir:./data}/largemessages</large-messages-directory> + <large-messages-directory>./data/largemessages</large-messages-directory> - <paging-directory>${data.dir:./data}/paging</paging-directory> + <paging-directory>./data/paging</paging-directory> <!-- Connectors --> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/symmetric-cluster/src/main/resources/activemq/server1/broker.xml ---------------------------------------------------------------------- diff --git a/examples/jms/symmetric-cluster/src/main/resources/activemq/server1/broker.xml b/examples/jms/symmetric-cluster/src/main/resources/activemq/server1/broker.xml index f02759b..d95a1cd 100644 --- a/examples/jms/symmetric-cluster/src/main/resources/activemq/server1/broker.xml +++ b/examples/jms/symmetric-cluster/src/main/resources/activemq/server1/broker.xml @@ -30,13 +30,13 @@ under the License. <core xmlns="urn:activemq:core"> - <bindings-directory>${data.dir:./data}/bindings</bindings-directory> + <bindings-directory>./data/bindings</bindings-directory> - <journal-directory>${data.dir:./data}/journal</journal-directory> + <journal-directory>./data/journal</journal-directory> - <large-messages-directory>${data.dir:./data}/largemessages</large-messages-directory> + <large-messages-directory>./data/largemessages</large-messages-directory> - <paging-directory>${data.dir:./data}/paging</paging-directory> + <paging-directory>./data/paging</paging-directory> <!-- Connectors --> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/symmetric-cluster/src/main/resources/activemq/server2/broker.xml ---------------------------------------------------------------------- diff --git a/examples/jms/symmetric-cluster/src/main/resources/activemq/server2/broker.xml b/examples/jms/symmetric-cluster/src/main/resources/activemq/server2/broker.xml index a188e71..ef006fd 100644 --- a/examples/jms/symmetric-cluster/src/main/resources/activemq/server2/broker.xml +++ b/examples/jms/symmetric-cluster/src/main/resources/activemq/server2/broker.xml @@ -30,13 +30,13 @@ under the License. <core xmlns="urn:activemq:core"> - <bindings-directory>${data.dir:./data}/bindings</bindings-directory> + <bindings-directory>./data/bindings</bindings-directory> - <journal-directory>${data.dir:./data}/journal</journal-directory> + <journal-directory>./data/journal</journal-directory> - <large-messages-directory>${data.dir:./data}/largemessages</large-messages-directory> + <large-messages-directory>./data/largemessages</large-messages-directory> - <paging-directory>${data.dir:./data}/paging</paging-directory> + <paging-directory>./data/paging</paging-directory> <!-- Connectors --> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/symmetric-cluster/src/main/resources/activemq/server3/broker.xml ---------------------------------------------------------------------- diff --git a/examples/jms/symmetric-cluster/src/main/resources/activemq/server3/broker.xml b/examples/jms/symmetric-cluster/src/main/resources/activemq/server3/broker.xml index 43ab47c..a780ace 100644 --- a/examples/jms/symmetric-cluster/src/main/resources/activemq/server3/broker.xml +++ b/examples/jms/symmetric-cluster/src/main/resources/activemq/server3/broker.xml @@ -30,13 +30,13 @@ under the License. <core xmlns="urn:activemq:core"> - <bindings-directory>${data.dir:./data}/bindings</bindings-directory> + <bindings-directory>./data/bindings</bindings-directory> - <journal-directory>${data.dir:./data}/journal</journal-directory> + <journal-directory>./data/journal</journal-directory> - <large-messages-directory>${data.dir:./data}/largemessages</large-messages-directory> + <large-messages-directory>./data/largemessages</large-messages-directory> - <paging-directory>${data.dir:./data}/paging</paging-directory> + <paging-directory>./data/paging</paging-directory> <!-- Connectors --> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/symmetric-cluster/src/main/resources/activemq/server4/broker.xml ---------------------------------------------------------------------- diff --git a/examples/jms/symmetric-cluster/src/main/resources/activemq/server4/broker.xml b/examples/jms/symmetric-cluster/src/main/resources/activemq/server4/broker.xml index ce4afab..20b622e 100644 --- a/examples/jms/symmetric-cluster/src/main/resources/activemq/server4/broker.xml +++ b/examples/jms/symmetric-cluster/src/main/resources/activemq/server4/broker.xml @@ -30,13 +30,13 @@ under the License. <core xmlns="urn:activemq:core"> - <bindings-directory>${data.dir:./data}/bindings</bindings-directory> + <bindings-directory>./data/bindings</bindings-directory> - <journal-directory>${data.dir:./data}/journal</journal-directory> + <journal-directory>./data/journal</journal-directory> - <large-messages-directory>${data.dir:./data}/largemessages</large-messages-directory> + <large-messages-directory>./data/largemessages</large-messages-directory> - <paging-directory>${data.dir:./data}/paging</paging-directory> + <paging-directory>./data/paging</paging-directory> <!-- Connectors --> <connectors> http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/dd820318/examples/jms/symmetric-cluster/src/main/resources/activemq/server5/broker.xml ---------------------------------------------------------------------- diff --git a/examples/jms/symmetric-cluster/src/main/resources/activemq/server5/broker.xml b/examples/jms/symmetric-cluster/src/main/resources/activemq/server5/broker.xml index d23612a..033af43 100644 --- a/examples/jms/symmetric-cluster/src/main/resources/activemq/server5/broker.xml +++ b/examples/jms/symmetric-cluster/src/main/resources/activemq/server5/broker.xml @@ -30,13 +30,13 @@ under the License. <core xmlns="urn:activemq:core"> - <bindings-directory>${data.dir:./data}/bindings</bindings-directory> + <bindings-directory>./data/bindings</bindings-directory> - <journal-directory>${data.dir:./data}/journal</journal-directory> + <journal-directory>./data/journal</journal-directory> - <large-messages-directory>${data.dir:./data}/largemessages</large-messages-directory> + <large-messages-directory>./data/largemessages</large-messages-directory> - <paging-directory>${data.dir:./data}/paging</paging-directory> + <paging-directory>./data/paging</paging-directory> <!-- Connectors --> <connectors>
