[hornetq-commits] JBoss hornetq SVN: r8146 - in trunk: examples/jms and 20 other directories.

Author: jmesnil Date: 2009-10-27 06:18:02 -0400 (Tue, 27 Oct 2009) New Revision: 8146 Added: trunk/examples/jms/non-transaction-failover/ trunk/examples/jms/non-transaction-failover/build.bat trunk/examples/jms/non-transaction-failover/build.sh trunk/examples/jms/non-transaction-failover/build.xml trunk/examples/jms/non-transaction-failover/readme.html trunk/examples/jms/non-transaction-failover/server0/ trunk/examples/jms/non-transaction-failover/server0/client-jndi.properties trunk/examples/jms/non-transaction-failover/server0/hornetq-beans.xml trunk/examples/jms/non-transaction-failover/server0/hornetq-configuration.xml trunk/examples/jms/non-transaction-failover/server0/hornetq-jms.xml trunk/examples/jms/non-transaction-failover/server0/hornetq-users.xml trunk/examples/jms/non-transaction-failover/server1/ trunk/examples/jms/non-transaction-failover/server1/KILL_ME trunk/examples/jms/non-transaction-failover/server1/client-jndi.properties trunk/examples/jms/non-transaction-failover/server1/hornetq-beans.xml trunk/examples/jms/non-transaction-failover/server1/hornetq-configuration.xml trunk/examples/jms/non-transaction-failover/server1/hornetq-jms.xml trunk/examples/jms/non-transaction-failover/server1/hornetq-users.xml trunk/examples/jms/non-transaction-failover/src/ trunk/examples/jms/non-transaction-failover/src/org/ trunk/examples/jms/non-transaction-failover/src/org/hornetq/ trunk/examples/jms/non-transaction-failover/src/org/hornetq/jms/ trunk/examples/jms/non-transaction-failover/src/org/hornetq/jms/example/ trunk/examples/jms/non-transaction-failover/src/org/hornetq/jms/example/NonTransactionFailoverExample.java trunk/examples/jms/transaction-failover/ trunk/examples/jms/transaction-failover/build.bat trunk/examples/jms/transaction-failover/build.sh trunk/examples/jms/transaction-failover/build.xml trunk/examples/jms/transaction-failover/readme.html trunk/examples/jms/transaction-failover/server0/ trunk/examples/jms/transaction-failover/server0/client-jndi.properties trunk/examples/jms/transaction-failover/server0/hornetq-beans.xml trunk/examples/jms/transaction-failover/server0/hornetq-configuration.xml trunk/examples/jms/transaction-failover/server0/hornetq-jms.xml trunk/examples/jms/transaction-failover/server0/hornetq-users.xml trunk/examples/jms/transaction-failover/server1/ trunk/examples/jms/transaction-failover/server1/KILL_ME trunk/examples/jms/transaction-failover/server1/client-jndi.properties trunk/examples/jms/transaction-failover/server1/hornetq-beans.xml trunk/examples/jms/transaction-failover/server1/hornetq-configuration.xml trunk/examples/jms/transaction-failover/server1/hornetq-jms.xml trunk/examples/jms/transaction-failover/server1/hornetq-users.xml trunk/examples/jms/transaction-failover/src/ trunk/examples/jms/transaction-failover/src/org/ trunk/examples/jms/transaction-failover/src/org/hornetq/ trunk/examples/jms/transaction-failover/src/org/hornetq/jms/ trunk/examples/jms/transaction-failover/src/org/hornetq/jms/example/ trunk/examples/jms/transaction-failover/src/org/hornetq/jms/example/TransactionFailoverExample.java Modified: trunk/.classpath trunk/src/main/org/hornetq/core/client/ClientSession.java trunk/src/main/org/hornetq/core/client/impl/ClientConsumerImpl.java trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java trunk/tests/jms-tests/src/org/hornetq/jms/tests/message/MessageHeaderTest.java trunk/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java Log: failover examples * added examples for JMS failover with and without transactions * refactored ClientSession to flag its workDone when a consumer effectively consume a message Modified: trunk/.classpath =================================================================== --- trunk/.classpath 2009-10-27 02:24:40 UTC (rev 8145) +++ trunk/.classpath 2009-10-27 10:18:02 UTC (rev 8146) @@ -50,6 +50,7 @@ <classpathentry kind="src" path="examples/jms/message-group/src"/> <classpathentry kind="src" path="examples/jms/message-priority/src"/> <classpathentry kind="src" path="examples/jms/no-consumer-buffering/src"/> + <classpathentry kind="src" path="examples/jms/non-transaction-failover/src"/> <classpathentry kind="src" path="examples/jms/paging/src"/> <classpathentry kind="src" path="examples/jms/perf/src"/> <classpathentry kind="src" path="examples/jms/pre-acknowledge/src"/> @@ -72,6 +73,7 @@ <classpathentry kind="src" path="examples/jms/topic-hierarchies/src"/> <classpathentry kind="src" path="examples/jms/topic-selector-example1/src"/> <classpathentry kind="src" path="examples/jms/topic-selector-example2/src"/> + <classpathentry kind="src" path="examples/jms/transaction-failover/src"/> <classpathentry kind="src" path="examples/jms/transactional/src"/> <classpathentry kind="src" path="examples/jms/xa-heuristic/src"/> <classpathentry kind="src" path="examples/jms/xa-receive/src"/> Property changes on: trunk/examples/jms/non-transaction-failover ___________________________________________________________________ Name: svn:ignore + build Added: trunk/examples/jms/non-transaction-failover/build.bat =================================================================== --- trunk/examples/jms/non-transaction-failover/build.bat (rev 0) +++ trunk/examples/jms/non-transaction-failover/build.bat 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,13 @@ +@echo off + +set "OVERRIDE_ANT_HOME=..\..\..\tools\ant" + +if exist "..\..\..\src\bin\build.bat" ( + rem running from TRUNK + call ..\..\..\src\bin\build.bat %* +) else ( + rem running from the distro + call ..\..\..\bin\build.bat %* +) + +set "OVERRIDE_ANT_HOME=" Added: trunk/examples/jms/non-transaction-failover/build.sh =================================================================== --- trunk/examples/jms/non-transaction-failover/build.sh (rev 0) +++ trunk/examples/jms/non-transaction-failover/build.sh 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,15 @@ +#!/bin/sh + +OVERRIDE_ANT_HOME=../../../tools/ant +export OVERRIDE_ANT_HOME + +if [ -f "../../../src/bin/build.sh" ]; then + # running from TRUNK + ../../../src/bin/build.sh "$@" +else + # running from the distro + ../../../bin/build.sh "$@" +fi + + + Property changes on: trunk/examples/jms/non-transaction-failover/build.sh ___________________________________________________________________ Name: svn:executable + * Added: trunk/examples/jms/non-transaction-failover/build.xml =================================================================== --- trunk/examples/jms/non-transaction-failover/build.xml (rev 0) +++ trunk/examples/jms/non-transaction-failover/build.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,40 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE project [ + <!ENTITY libraries SYSTEM "../../../thirdparty/libraries.ent"> + ]> +<!-- + ~ Copyright 2009 Red Hat, Inc. + ~ Red Hat licenses this file to you under the Apache License, version + ~ 2.0 (the "License"); you may not use this file except in compliance + ~ with the License. You may obtain a copy of the License at + ~ http://www.apache.org/licenses/LICENSE-2.0 + ~ Unless required by applicable law or agreed to in writing, software + ~ distributed under the License is distributed on an "AS IS" BASIS, + ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + ~ implied. See the License for the specific language governing + ~ permissions and limitations under the License. + --> + +<project default="run" name="HornetQ JMS Non-transaction Failover Example"> + + <import file="../../common/build.xml"/> + + <target name="run" depends="delete-files"> + <antcall target="runExample"> + <param name="example.classname" value="org.hornetq.jms.example.NonTransactionFailoverExample"/> + <param name="hornetq.example.beans.file" value="server0 server1"/> + </antcall> + </target> + + <target name="runRemote" depends="delete-files"> + <antcall target="runExample"> + <param name="example.classname" value="org.hornetq.jms.example.NonTransactionFailoverExample"/> + <param name="hornetq.example.runServer" value="false"/> + </antcall> + </target> + + <target name="delete-files" depends="clean"> + <delete file="./server1/KILL_ME"/> + </target> + +</project> Added: trunk/examples/jms/non-transaction-failover/readme.html =================================================================== --- trunk/examples/jms/non-transaction-failover/readme.html (rev 0) +++ trunk/examples/jms/non-transaction-failover/readme.html 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,166 @@ +<html> + <head> + <title>HornetQ JMS Failover Without Transactions 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 Failover Without Transactions Example</h1> + + <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 wether the JMS session is transacter or not.</p> + <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 HornetQ 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>./build.sh</code> (or <code>build.bat</code> on windows) 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> + <br> + <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 &lt; 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 &lt; 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 &lt; 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 occured</li> + <pre class="prettyprint"> + try + { + message0.acknowledge(); + } + catch (JMSException e) + { + System.out.println("Got exception while acknowledging message: " + e.getMessage()); + ... + } + </pre> + + <li>The client must cope with the failover and recreate the JMS session</li> + <pre class="prettyprint"> + session.close(); + session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); + producer = session.createProducer(queue); + consumer = session.createConsumer(queue); + </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 &lt; numMessages; i++) + { + message0 = (TextMessage)consumer.receive(5000); + System.out.printf("Got message: %s (redelivered?: %s)\n", message0.getText(), message0.getJMSRedelivered()); + } + message0.acknowledge(); + </pre> + + <li>Send some more messages</li> + <pre class="prettyprint"> + for (int i = numMessages; i &lt; numMessages * 2; i++) + { + TextMessage message = session.createTextMessage("This is text message " + i); + producer.send(message); + System.out.println("Sent message: " + message.getText()); + } + </pre> + + <li>Consume them</li> + <pre class="prettyprint"> + for (int i = 0; i &lt; numMessages; i++) + { + TextMessage message = (TextMessage)consumer.receive(5000); + System.out.println("Got message: " + message.getText()); + message.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> \ No newline at end of file Property changes on: trunk/examples/jms/non-transaction-failover/server0 ___________________________________________________________________ Name: svn:ignore + data Added: trunk/examples/jms/non-transaction-failover/server0/client-jndi.properties =================================================================== --- trunk/examples/jms/non-transaction-failover/server0/client-jndi.properties (rev 0) +++ trunk/examples/jms/non-transaction-failover/server0/client-jndi.properties 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,3 @@ +java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory +java.naming.provider.url=jnp://localhost:1099 +java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces Added: trunk/examples/jms/non-transaction-failover/server0/hornetq-beans.xml =================================================================== --- trunk/examples/jms/non-transaction-failover/server0/hornetq-beans.xml (rev 0) +++ trunk/examples/jms/non-transaction-failover/server0/hornetq-beans.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,59 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<deployment xmlns="urn:jboss:bean-deployer:2.0"> + + <bean name="Naming" class="org.jnp.server.NamingBeanImpl"/> + + <!-- JNDI server. Disable this if you don't want JNDI --> + <bean name="JNDIServer" class="org.jnp.server.Main"> + <property name="namingInfo"> + <inject bean="Naming"/> + </property> + <property name="port">1099</property> + <property name="bindAddress">localhost</property> + <property name="rmiPort">1098</property> + <property name="rmiBindAddress">localhost</property> + </bean> + + <!-- MBean server --> + <bean name="MBeanServer" class="javax.management.MBeanServer"> + <constructor factoryClass="java.lang.management.ManagementFactory" + factoryMethod="getPlatformMBeanServer"/> + </bean> + + <!-- The core configuration --> + <bean name="Configuration" class="org.hornetq.core.config.impl.FileConfiguration"/> + + <!-- The security manager --> + <bean name="HornetQSecurityManager" class="org.hornetq.core.security.impl.HornetQSecurityManagerImpl"> + <start ignored="true"/> + <stop ignored="true"/> + </bean> + + <!-- The core server --> + <bean name="HornetQServer" class="org.hornetq.core.server.impl.HornetQServerImpl"> + <constructor> + <parameter> + <inject bean="Configuration"/> + </parameter> + <parameter> + <inject bean="MBeanServer"/> + </parameter> + <parameter> + <inject bean="HornetQSecurityManager"/> + </parameter> + </constructor> + <start ignored="true"/> + <stop ignored="true"/> + </bean> + + <!-- The JMS server --> + <bean name="JMSServerManager" class="org.hornetq.jms.server.impl.JMSServerManagerImpl"> + <constructor> + <parameter> + <inject bean="HornetQServer"/> + </parameter> + </constructor> + </bean> + +</deployment> Added: trunk/examples/jms/non-transaction-failover/server0/hornetq-configuration.xml =================================================================== --- trunk/examples/jms/non-transaction-failover/server0/hornetq-configuration.xml (rev 0) +++ trunk/examples/jms/non-transaction-failover/server0/hornetq-configuration.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,37 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd"> + <backup>true</backup> + + <!-- Connectors --> + + <connectors> + <connector name="netty-connector"> + <factory-class>org.hornetq.integration.transports.netty.NettyConnectorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="5445" type="Integer"/> + </connector> + </connectors> + + <!-- Acceptors --> + <acceptors> + <acceptor name="netty-acceptor"> + <factory-class>org.hornetq.integration.transports.netty.NettyAcceptorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="5445" type="Integer"/> + </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="createTempQueue" roles="guest"/> + <permission type="deleteTempQueue" roles="guest"/> + <permission type="consume" roles="guest"/> + <permission type="send" roles="guest"/> + </security-setting> + </security-settings> + +</configuration> Added: trunk/examples/jms/non-transaction-failover/server0/hornetq-jms.xml =================================================================== --- trunk/examples/jms/non-transaction-failover/server0/hornetq-jms.xml (rev 0) +++ trunk/examples/jms/non-transaction-failover/server0/hornetq-jms.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,18 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"> + <!--the connection factory used by the example--> + <connection-factory name="ConnectionFactory"> + <connector-ref connector-name="netty-connector"/> + + <entries> + <entry name="ConnectionFactory"/> + </entries> + </connection-factory> + + <!--the queue used by the example--> + <queue name="exampleQueue"> + <entry name="/queue/exampleQueue"/> + </queue> + +</configuration> Added: trunk/examples/jms/non-transaction-failover/server0/hornetq-users.xml =================================================================== --- trunk/examples/jms/non-transaction-failover/server0/hornetq-users.xml (rev 0) +++ trunk/examples/jms/non-transaction-failover/server0/hornetq-users.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,7 @@ +<configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd"> + <!-- the default user. this is used where username is null--> + <defaultuser name="guest" password="guest"> + <role name="guest"/> + </defaultuser> +</configuration> \ No newline at end of file Property changes on: trunk/examples/jms/non-transaction-failover/server1 ___________________________________________________________________ Name: svn:ignore + data Added: trunk/examples/jms/non-transaction-failover/server1/KILL_ME =================================================================== Added: trunk/examples/jms/non-transaction-failover/server1/client-jndi.properties =================================================================== --- trunk/examples/jms/non-transaction-failover/server1/client-jndi.properties (rev 0) +++ trunk/examples/jms/non-transaction-failover/server1/client-jndi.properties 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,3 @@ +java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory +java.naming.provider.url=jnp://localhost:2099 +java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces Added: trunk/examples/jms/non-transaction-failover/server1/hornetq-beans.xml =================================================================== --- trunk/examples/jms/non-transaction-failover/server1/hornetq-beans.xml (rev 0) +++ trunk/examples/jms/non-transaction-failover/server1/hornetq-beans.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,59 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<deployment xmlns="urn:jboss:bean-deployer:2.0"> + + <bean name="Naming" class="org.jnp.server.NamingBeanImpl"/> + + <!-- JNDI server. Disable this if you don't want JNDI --> + <bean name="JNDIServer" class="org.jnp.server.Main"> + <property name="namingInfo"> + <inject bean="Naming"/> + </property> + <property name="port">2099</property> + <property name="bindAddress">localhost</property> + <property name="rmiPort">2098</property> + <property name="rmiBindAddress">localhost</property> + </bean> + + <!-- MBean server --> + <bean name="MBeanServer" class="javax.management.MBeanServer"> + <constructor factoryClass="java.lang.management.ManagementFactory" + factoryMethod="getPlatformMBeanServer"/> + </bean> + + <!-- The core configuration --> + <bean name="Configuration" class="org.hornetq.core.config.impl.FileConfiguration"/> + + <!-- The security manager --> + <bean name="HornetQSecurityManager" class="org.hornetq.core.security.impl.HornetQSecurityManagerImpl"> + <start ignored="true"/> + <stop ignored="true"/> + </bean> + + <!-- The core server --> + <bean name="HornetQServer" class="org.hornetq.core.server.impl.HornetQServerImpl"> + <constructor> + <parameter> + <inject bean="Configuration"/> + </parameter> + <parameter> + <inject bean="MBeanServer"/> + </parameter> + <parameter> + <inject bean="HornetQSecurityManager"/> + </parameter> + </constructor> + <start ignored="true"/> + <stop ignored="true"/> + </bean> + + <!-- The JMS server --> + <bean name="JMSServerManager" class="org.hornetq.jms.server.impl.JMSServerManagerImpl"> + <constructor> + <parameter> + <inject bean="HornetQServer"/> + </parameter> + </constructor> + </bean> + +</deployment> Added: trunk/examples/jms/non-transaction-failover/server1/hornetq-configuration.xml =================================================================== --- trunk/examples/jms/non-transaction-failover/server1/hornetq-configuration.xml (rev 0) +++ trunk/examples/jms/non-transaction-failover/server1/hornetq-configuration.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,42 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq ../../../src/schema/hornetq-configuration.xsd"> + <backup-connector-ref connector-name="backup-connector"/> + + <!-- Connectors --> + + <connectors> + <connector name="netty-connector"> + <factory-class>org.hornetq.integration.transports.netty.NettyConnectorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="5446" type="Integer"/> + </connector> + + <connector name="backup-connector"> + <factory-class>org.hornetq.integration.transports.netty.NettyConnectorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="5445" type="Integer"/> + </connector> + </connectors> + + <!-- Acceptors --> + <acceptors> + <acceptor name="netty-acceptor"> + <factory-class>org.hornetq.integration.transports.netty.NettyAcceptorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="5446" type="Integer"/> + </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="createTempQueue" roles="guest"/> + <permission type="deleteTempQueue" roles="guest"/> + <permission type="consume" roles="guest"/> + <permission type="send" roles="guest"/> + </security-setting> + </security-settings> + +</configuration> Added: trunk/examples/jms/non-transaction-failover/server1/hornetq-jms.xml =================================================================== --- trunk/examples/jms/non-transaction-failover/server1/hornetq-jms.xml (rev 0) +++ trunk/examples/jms/non-transaction-failover/server1/hornetq-jms.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,18 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"> + <!--the connection factory used by the example--> + <connection-factory name="ConnectionFactory"> + <connector-ref connector-name="netty-connector" backup-connector-name="backup-connector"/> + + <entries> + <entry name="ConnectionFactory"/> + </entries> + </connection-factory> + + <!--the queue used by the example--> + <queue name="exampleQueue"> + <entry name="/queue/exampleQueue"/> + </queue> + +</configuration> Added: trunk/examples/jms/non-transaction-failover/server1/hornetq-users.xml =================================================================== --- trunk/examples/jms/non-transaction-failover/server1/hornetq-users.xml (rev 0) +++ trunk/examples/jms/non-transaction-failover/server1/hornetq-users.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,7 @@ +<configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd"> + <!-- the default user. this is used where username is null--> + <defaultuser name="guest" password="guest"> + <role name="guest"/> + </defaultuser> +</configuration> \ No newline at end of file Added: trunk/examples/jms/non-transaction-failover/src/org/hornetq/jms/example/NonTransactionFailoverExample.java =================================================================== --- trunk/examples/jms/non-transaction-failover/src/org/hornetq/jms/example/NonTransactionFailoverExample.java (rev 0) +++ trunk/examples/jms/non-transaction-failover/src/org/hornetq/jms/example/NonTransactionFailoverExample.java 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,157 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ +package org.hornetq.jms.example; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.JMSException; +import javax.jms.MessageConsumer; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.InitialContext; + +import org.hornetq.common.example.HornetQExample; + +/** + * A simple example that demonstrates failover of the JMS connection from one node to another + * when the live server crashes using a JMS <em>non-transacted</em> session. + * + * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a> + */ +public class NonTransactionFailoverExample extends HornetQExample +{ + public static void main(String[] args) + { + new NonTransactionFailoverExample().run(args); + } + + public boolean runExample() throws Exception + { + final int numMessages = 10; + + Connection connection = null; + + InitialContext initialContext = null; + + try + { + // Step 1. Get an initial context for looking up JNDI from the server #1 + initialContext = getContext(1); + + // Step 2. Look up the JMS resources from JNDI + Queue queue = (Queue)initialContext.lookup("/queue/exampleQueue"); + ConnectionFactory connectionFactory = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); + + // Step 3. Create a JMS Connection + connection = connectionFactory.createConnection(); + + // Step 4. Create a *non-transacted* JMS Session with client acknwoledgement + Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); + + // Step 5. Start the connection to ensure delivery occurs + connection.start(); + + // Step 6. Create a JMS MessageProducer and a MessageConsumer + MessageProducer producer = session.createProducer(queue); + MessageConsumer consumer = session.createConsumer(queue); + + // Step 7. Send some messages to server #1, the live server + 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()); + } + + // Step 8. Receive and acknowledge half of the sent messages + 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(); + + // Step 9. Receive the 2nd half of the sent messages but *do not* acknowledge them yet + for (int i = numMessages / 2; i < numMessages; i++) + { + message0 = (TextMessage)consumer.receive(5000); + System.out.println("Got message: " + message0.getText()); + } + + // Step 10. Crash server #1, the live server, and wait a little while to make sure + // it has really crashed + killServer(1); + Thread.sleep(2000); + + // Step 11. Acknowledging the 2nd half of the sent messages will fail as failover to the + // backup server has occured + try + { + message0.acknowledge(); + } + catch (JMSException e) + { + System.out.println("Got exception while acknowledging message: " + e.getMessage()); + // Step 12. Close the JMS session and recreate the JMS objects + session.close(); + session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); + producer = session.createProducer(queue); + consumer = session.createConsumer(queue); + } + + // Step 13. Consume again the 2nd half of the messages again. Note that they are not considered as redelivered. + 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(); + + // Step 14. Send some more messages + for (int i = numMessages; i < numMessages * 2; i++) + { + TextMessage message = session.createTextMessage("This is text message " + i); + producer.send(message); + System.out.println("Sent message: " + message.getText()); + } + + // Step 15. Consume them + for (int i = 0; i < numMessages; i++) + { + TextMessage message = (TextMessage)consumer.receive(5000); + System.out.println("Got message: " + message.getText()); + message.acknowledge(); + } + + return true; + } + finally + { + // Step 16. Be sure to close our resources! + + if (connection != null) + { + connection.close(); + } + + if (initialContext != null) + { + initialContext.close(); + } + } + } + +} Property changes on: trunk/examples/jms/transaction-failover ___________________________________________________________________ Name: svn:ignore + build Added: trunk/examples/jms/transaction-failover/build.bat =================================================================== --- trunk/examples/jms/transaction-failover/build.bat (rev 0) +++ trunk/examples/jms/transaction-failover/build.bat 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,13 @@ +@echo off + +set "OVERRIDE_ANT_HOME=..\..\..\tools\ant" + +if exist "..\..\..\src\bin\build.bat" ( + rem running from TRUNK + call ..\..\..\src\bin\build.bat %* +) else ( + rem running from the distro + call ..\..\..\bin\build.bat %* +) + +set "OVERRIDE_ANT_HOME=" Added: trunk/examples/jms/transaction-failover/build.sh =================================================================== --- trunk/examples/jms/transaction-failover/build.sh (rev 0) +++ trunk/examples/jms/transaction-failover/build.sh 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,15 @@ +#!/bin/sh + +OVERRIDE_ANT_HOME=../../../tools/ant +export OVERRIDE_ANT_HOME + +if [ -f "../../../src/bin/build.sh" ]; then + # running from TRUNK + ../../../src/bin/build.sh "$@" +else + # running from the distro + ../../../bin/build.sh "$@" +fi + + + Property changes on: trunk/examples/jms/transaction-failover/build.sh ___________________________________________________________________ Name: svn:executable + * Added: trunk/examples/jms/transaction-failover/build.xml =================================================================== --- trunk/examples/jms/transaction-failover/build.xml (rev 0) +++ trunk/examples/jms/transaction-failover/build.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,40 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE project [ + <!ENTITY libraries SYSTEM "../../../thirdparty/libraries.ent"> + ]> +<!-- + ~ Copyright 2009 Red Hat, Inc. + ~ Red Hat licenses this file to you under the Apache License, version + ~ 2.0 (the "License"); you may not use this file except in compliance + ~ with the License. You may obtain a copy of the License at + ~ http://www.apache.org/licenses/LICENSE-2.0 + ~ Unless required by applicable law or agreed to in writing, software + ~ distributed under the License is distributed on an "AS IS" BASIS, + ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + ~ implied. See the License for the specific language governing + ~ permissions and limitations under the License. + --> + +<project default="run" name="HornetQ JMS Transaction Failover Example"> + + <import file="../../common/build.xml"/> + + <target name="run" depends="delete-files"> + <antcall target="runExample"> + <param name="example.classname" value="org.hornetq.jms.example.TransactionFailoverExample"/> + <param name="hornetq.example.beans.file" value="server0 server1"/> + </antcall> + </target> + + <target name="runRemote" depends="delete-files"> + <antcall target="runExample"> + <param name="example.classname" value="org.hornetq.jms.example.TransactionFailoverExample"/> + <param name="hornetq.example.runServer" value="false"/> + </antcall> + </target> + + <target name="delete-files" depends="clean"> + <delete file="./server1/KILL_ME"/> + </target> + +</project> Added: trunk/examples/jms/transaction-failover/readme.html =================================================================== --- trunk/examples/jms/transaction-failover/readme.html (rev 0) +++ trunk/examples/jms/transaction-failover/readme.html 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,139 @@ +<html> + <head> + <title>HornetQ JMS Failover With Transaction 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 Failover With Transaction Example</h1> + + <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 wether the JMS session is transacter or not.</p> + <p>When a <em>transacted</em> JMS session is used, once-and-only once delivery is guaranteed.</p> + <ul> + <li>if the failover occurs while there is an in-flight transaction, the transaction will be flagged as <em>rollback only</em> and the JMS client will need to retry the transaction work.</li> + <li>if the failover occurs while there is <em>no</em> in-flight transaction, the failover will be transparent to the user.</li> + </ul> + <p>HornetQ also provides an example for <a href="../non-transactional-failover/readme.html">non-transaction failover</a>.</p> + <p>For more information on HornetQ 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>./build.sh</code> (or <code>build.bat</code> on windows) 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> + <br> + <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>transacted</em> Session</li> + <pre class="prettyprint"> + Session session = connection.createSession(true, 0); + </pre> + + <li>Start the connection to ensure delivery occurs</li> + <pre class="prettyprint"> + connection.start(); + </pre> + + <li>Create a JMS MessageProducer</li> + <pre class="prettyprint"> + MessageProducer producer = session.createProducer(queue); + </pre> + + <li>Create a JMS MessageConsumer</li> + <pre class="prettyprint"> + MessageConsumer consumer = session.createConsumer(queue); + </pre> + + <li>Send some messages to server #1 and commit the session</li> + <pre class="prettyprint"> + for (int i = 0; i &lt; numMessages; i++) + { + TextMessage message = session.createTextMessage("This is text message " + i); + producer.send(message); + System.out.println("Sent message: " + message.getText()); + } + session.commit(); + </pre> + + <li>Crash server #1, the live server, and wait a little while to make sure + it has really crashed.<br /> + When server #1 crashes, the client automatically detects the failure and automatically + fails over from server #1 to server #0 (in your real program you wouldn't need to sleep). + </li> + <pre class="prettyprint"> + killServer(1); // This causes the live server to crash + Thread.sleep(2000); // Just wait a little while to make sure the live server has really crashed. + </pre> + + <li>The client is transparently reconnected to server #0 - the backup server. + As no work has been done by the session during the failover, we can <em>transparently</em> consume messages + from the session.</li> + <pre class="prettyprint"> + for (int i = 0; i &lt; numMessages; i++) + { + TextMessage message0 = (TextMessage)consumer.receive(5000); + System.out.println("Got message: " + message0.getText()); + } + session.commit(); + </pre> + + <li>Send some more messages and commit the session</li> + <pre class="prettyprint"> + for (int i = numMessages; i &lt; numMessages * 2; i++) + { + TextMessage message = session.createTextMessage("This is text message " + i); + producer.send(message); + System.out.println("Sent message: " + message.getText()); + } + session.commit(); + </pre> + + <li>Consume them</li> + <pre class="prettyprint"> + for (int i = 0; i &lt; numMessages; i++) + { + TextMessage message0 = (TextMessage)consumer.receive(5000); + System.out.println("Got message: " + message0.getText()); + } + session.commit(); + </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> \ No newline at end of file Property changes on: trunk/examples/jms/transaction-failover/server0 ___________________________________________________________________ Name: svn:ignore + data Added: trunk/examples/jms/transaction-failover/server0/client-jndi.properties =================================================================== --- trunk/examples/jms/transaction-failover/server0/client-jndi.properties (rev 0) +++ trunk/examples/jms/transaction-failover/server0/client-jndi.properties 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,3 @@ +java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory +java.naming.provider.url=jnp://localhost:1099 +java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces Added: trunk/examples/jms/transaction-failover/server0/hornetq-beans.xml =================================================================== --- trunk/examples/jms/transaction-failover/server0/hornetq-beans.xml (rev 0) +++ trunk/examples/jms/transaction-failover/server0/hornetq-beans.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,59 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<deployment xmlns="urn:jboss:bean-deployer:2.0"> + + <bean name="Naming" class="org.jnp.server.NamingBeanImpl"/> + + <!-- JNDI server. Disable this if you don't want JNDI --> + <bean name="JNDIServer" class="org.jnp.server.Main"> + <property name="namingInfo"> + <inject bean="Naming"/> + </property> + <property name="port">1099</property> + <property name="bindAddress">localhost</property> + <property name="rmiPort">1098</property> + <property name="rmiBindAddress">localhost</property> + </bean> + + <!-- MBean server --> + <bean name="MBeanServer" class="javax.management.MBeanServer"> + <constructor factoryClass="java.lang.management.ManagementFactory" + factoryMethod="getPlatformMBeanServer"/> + </bean> + + <!-- The core configuration --> + <bean name="Configuration" class="org.hornetq.core.config.impl.FileConfiguration"/> + + <!-- The security manager --> + <bean name="HornetQSecurityManager" class="org.hornetq.core.security.impl.HornetQSecurityManagerImpl"> + <start ignored="true"/> + <stop ignored="true"/> + </bean> + + <!-- The core server --> + <bean name="HornetQServer" class="org.hornetq.core.server.impl.HornetQServerImpl"> + <constructor> + <parameter> + <inject bean="Configuration"/> + </parameter> + <parameter> + <inject bean="MBeanServer"/> + </parameter> + <parameter> + <inject bean="HornetQSecurityManager"/> + </parameter> + </constructor> + <start ignored="true"/> + <stop ignored="true"/> + </bean> + + <!-- The JMS server --> + <bean name="JMSServerManager" class="org.hornetq.jms.server.impl.JMSServerManagerImpl"> + <constructor> + <parameter> + <inject bean="HornetQServer"/> + </parameter> + </constructor> + </bean> + +</deployment> Added: trunk/examples/jms/transaction-failover/server0/hornetq-configuration.xml =================================================================== --- trunk/examples/jms/transaction-failover/server0/hornetq-configuration.xml (rev 0) +++ trunk/examples/jms/transaction-failover/server0/hornetq-configuration.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,37 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd"> + <backup>true</backup> + + <!-- Connectors --> + + <connectors> + <connector name="netty-connector"> + <factory-class>org.hornetq.integration.transports.netty.NettyConnectorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="5445" type="Integer"/> + </connector> + </connectors> + + <!-- Acceptors --> + <acceptors> + <acceptor name="netty-acceptor"> + <factory-class>org.hornetq.integration.transports.netty.NettyAcceptorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="5445" type="Integer"/> + </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="createTempQueue" roles="guest"/> + <permission type="deleteTempQueue" roles="guest"/> + <permission type="consume" roles="guest"/> + <permission type="send" roles="guest"/> + </security-setting> + </security-settings> + +</configuration> Added: trunk/examples/jms/transaction-failover/server0/hornetq-jms.xml =================================================================== --- trunk/examples/jms/transaction-failover/server0/hornetq-jms.xml (rev 0) +++ trunk/examples/jms/transaction-failover/server0/hornetq-jms.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,18 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"> + <!--the connection factory used by the example--> + <connection-factory name="ConnectionFactory"> + <connector-ref connector-name="netty-connector"/> + + <entries> + <entry name="ConnectionFactory"/> + </entries> + </connection-factory> + + <!--the queue used by the example--> + <queue name="exampleQueue"> + <entry name="/queue/exampleQueue"/> + </queue> + +</configuration> Added: trunk/examples/jms/transaction-failover/server0/hornetq-users.xml =================================================================== --- trunk/examples/jms/transaction-failover/server0/hornetq-users.xml (rev 0) +++ trunk/examples/jms/transaction-failover/server0/hornetq-users.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,7 @@ +<configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd"> + <!-- the default user. this is used where username is null--> + <defaultuser name="guest" password="guest"> + <role name="guest"/> + </defaultuser> +</configuration> \ No newline at end of file Property changes on: trunk/examples/jms/transaction-failover/server1 ___________________________________________________________________ Name: svn:ignore + data Added: trunk/examples/jms/transaction-failover/server1/KILL_ME =================================================================== Added: trunk/examples/jms/transaction-failover/server1/client-jndi.properties =================================================================== --- trunk/examples/jms/transaction-failover/server1/client-jndi.properties (rev 0) +++ trunk/examples/jms/transaction-failover/server1/client-jndi.properties 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,3 @@ +java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory +java.naming.provider.url=jnp://localhost:2099 +java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces Added: trunk/examples/jms/transaction-failover/server1/hornetq-beans.xml =================================================================== --- trunk/examples/jms/transaction-failover/server1/hornetq-beans.xml (rev 0) +++ trunk/examples/jms/transaction-failover/server1/hornetq-beans.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,59 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<deployment xmlns="urn:jboss:bean-deployer:2.0"> + + <bean name="Naming" class="org.jnp.server.NamingBeanImpl"/> + + <!-- JNDI server. Disable this if you don't want JNDI --> + <bean name="JNDIServer" class="org.jnp.server.Main"> + <property name="namingInfo"> + <inject bean="Naming"/> + </property> + <property name="port">2099</property> + <property name="bindAddress">localhost</property> + <property name="rmiPort">2098</property> + <property name="rmiBindAddress">localhost</property> + </bean> + + <!-- MBean server --> + <bean name="MBeanServer" class="javax.management.MBeanServer"> + <constructor factoryClass="java.lang.management.ManagementFactory" + factoryMethod="getPlatformMBeanServer"/> + </bean> + + <!-- The core configuration --> + <bean name="Configuration" class="org.hornetq.core.config.impl.FileConfiguration"/> + + <!-- The security manager --> + <bean name="HornetQSecurityManager" class="org.hornetq.core.security.impl.HornetQSecurityManagerImpl"> + <start ignored="true"/> + <stop ignored="true"/> + </bean> + + <!-- The core server --> + <bean name="HornetQServer" class="org.hornetq.core.server.impl.HornetQServerImpl"> + <constructor> + <parameter> + <inject bean="Configuration"/> + </parameter> + <parameter> + <inject bean="MBeanServer"/> + </parameter> + <parameter> + <inject bean="HornetQSecurityManager"/> + </parameter> + </constructor> + <start ignored="true"/> + <stop ignored="true"/> + </bean> + + <!-- The JMS server --> + <bean name="JMSServerManager" class="org.hornetq.jms.server.impl.JMSServerManagerImpl"> + <constructor> + <parameter> + <inject bean="HornetQServer"/> + </parameter> + </constructor> + </bean> + +</deployment> Added: trunk/examples/jms/transaction-failover/server1/hornetq-configuration.xml =================================================================== --- trunk/examples/jms/transaction-failover/server1/hornetq-configuration.xml (rev 0) +++ trunk/examples/jms/transaction-failover/server1/hornetq-configuration.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,42 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq ../../../src/schema/hornetq-configuration.xsd"> + <backup-connector-ref connector-name="backup-connector"/> + + <!-- Connectors --> + + <connectors> + <connector name="netty-connector"> + <factory-class>org.hornetq.integration.transports.netty.NettyConnectorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="5446" type="Integer"/> + </connector> + + <connector name="backup-connector"> + <factory-class>org.hornetq.integration.transports.netty.NettyConnectorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="5445" type="Integer"/> + </connector> + </connectors> + + <!-- Acceptors --> + <acceptors> + <acceptor name="netty-acceptor"> + <factory-class>org.hornetq.integration.transports.netty.NettyAcceptorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="5446" type="Integer"/> + </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="createTempQueue" roles="guest"/> + <permission type="deleteTempQueue" roles="guest"/> + <permission type="consume" roles="guest"/> + <permission type="send" roles="guest"/> + </security-setting> + </security-settings> + +</configuration> Added: trunk/examples/jms/transaction-failover/server1/hornetq-jms.xml =================================================================== --- trunk/examples/jms/transaction-failover/server1/hornetq-jms.xml (rev 0) +++ trunk/examples/jms/transaction-failover/server1/hornetq-jms.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,18 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"> + <!--the connection factory used by the example--> + <connection-factory name="ConnectionFactory"> + <connector-ref connector-name="netty-connector" backup-connector-name="backup-connector"/> + + <entries> + <entry name="ConnectionFactory"/> + </entries> + </connection-factory> + + <!--the queue used by the example--> + <queue name="exampleQueue"> + <entry name="/queue/exampleQueue"/> + </queue> + +</configuration> Added: trunk/examples/jms/transaction-failover/server1/hornetq-users.xml =================================================================== --- trunk/examples/jms/transaction-failover/server1/hornetq-users.xml (rev 0) +++ trunk/examples/jms/transaction-failover/server1/hornetq-users.xml 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,7 @@ +<configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd"> + <!-- the default user. this is used where username is null--> + <defaultuser name="guest" password="guest"> + <role name="guest"/> + </defaultuser> +</configuration> \ No newline at end of file Added: trunk/examples/jms/transaction-failover/src/org/hornetq/jms/example/TransactionFailoverExample.java =================================================================== --- trunk/examples/jms/transaction-failover/src/org/hornetq/jms/example/TransactionFailoverExample.java (rev 0) +++ trunk/examples/jms/transaction-failover/src/org/hornetq/jms/example/TransactionFailoverExample.java 2009-10-27 10:18:02 UTC (rev 8146) @@ -0,0 +1,131 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ +package org.hornetq.jms.example; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.MessageConsumer; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.InitialContext; + +import org.hornetq.common.example.HornetQExample; + +/** + * A simple example that demonstrates failover of the JMS connection from one node to another + * when the live server crashes using a JMS <em>transacted</em> session. + * + * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a> + */ +public class TransactionFailoverExample extends HornetQExample +{ + public static void main(String[] args) + { + new TransactionFailoverExample().run(args); + } + + public boolean runExample() throws Exception + { + final int numMessages = 10; + + Connection connection = null; + + InitialContext initialContext = null; + + try + { + // Step 1. Get an initial context for looking up JNDI from the server #1 + initialContext = getContext(1); + + // Step 2. Look-up the JMS resources from JNDI + Queue queue = (Queue)initialContext.lookup("/queue/exampleQueue"); + ConnectionFactory connectionFactory = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); + + // Step 3. We create a JMS Connection + connection = connectionFactory.createConnection(); + + // Step 4. We create a *transacted* JMS Session + Session session = connection.createSession(true, 0); + + // Step 5. We start the connection to ensure delivery occurs + connection.start(); + + // Step 6. We create a JMS MessageProducer + MessageProducer producer = session.createProducer(queue); + + // Step 7. We create a JMS MessageConsumer + MessageConsumer consumer = session.createConsumer(queue); + + // Step 8. We send some messages to server #1, the live server + 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()); + } + session.commit(); + + // Step 9. We now cause server #1, the live server to crash, and wait a little while to make sure + // it has really crashed + killServer(1); + Thread.sleep(2000); + + // Step 10. We are now transparently reconnected to server #0, the backup server. + // We consume the messages sent before the crash of the live server and commit the session. + for (int i = 0; i < numMessages; i++) + { + TextMessage message0 = (TextMessage)consumer.receive(5000); + System.out.println("Got message: " + message0.getText()); + } + session.commit(); + + // Step 11. We now send some more messages and commit the session + for (int i = numMessages; i < numMessages * 2; i++) + { + TextMessage message = session.createTextMessage("This is text message " + i); + producer.send(message); + System.out.println("Sent message: " + message.getText()); + } + session.commit(); + + // Step 12. And consume them and commit the session + for (int i = 0; i < numMessages; i++) + { + TextMessage message0 = (TextMessage)consumer.receive(5000); + System.out.println("Got message: " + message0.getText()); + } + session.commit(); + + return true; + } + finally + { + // Step 13. Be sure to close our resources! + + if (connection != null) + { + System.out.println("CLOSING"); + connection.close(); + System.out.println("CLOSED"); + } + + if (initialContext != null) + { + initialContext.close(); + } + } + } + +} Modified: trunk/src/main/org/hornetq/core/client/ClientSession.java =================================================================== --- trunk/src/main/org/hornetq/core/client/ClientSession.java 2009-10-27 02:24:40 UTC (rev 8145) +++ trunk/src/main/org/hornetq/core/client/ClientSession.java 2009-10-27 10:18:02 UTC (rev 8146) @@ -117,6 +117,8 @@ XAResource getXAResource(); + boolean isRollbackOnly(); + void commit() throws HornetQException; void rollback() throws HornetQException; Modified: trunk/src/main/org/hornetq/core/client/impl/ClientConsumerImpl.java =================================================================== --- trunk/src/main/org/hornetq/core/client/impl/ClientConsumerImpl.java 2009-10-27 02:24:40 UTC (rev 8145) +++ trunk/src/main/org/hornetq/core/client/impl/ClientConsumerImpl.java 2009-10-27 10:18:02 UTC (rev 8146) @@ -245,6 +245,8 @@ if (m != null) { + session.workDone(); + if (m.containsProperty(FORCED_DELIVERY_MESSAGE)) { Long seq = (Long)m.getProperty(FORCED_DELIVERY_MESSAGE); @@ -707,6 +709,9 @@ { return; } + + session.workDone(); + // We pull the message from the buffer from inside the Runnable so we can ensure priority // ordering. If we just added a Runnable with the message to the executor immediately as we get it // we could not do that Modified: trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java =================================================================== --- trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java 2009-10-27 02:24:40 UTC (rev 8145) +++ trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java 2009-10-27 10:18:02 UTC (rev 8146) @@ -475,6 +475,11 @@ workDone = false; } + public boolean isRollbackOnly() + { + return rollbackOnly; + } + public void rollback() throws HornetQException { rollback(false); @@ -511,6 +516,8 @@ { start(); } + + rollbackOnly = false; } public ClientMessage createClientMessage(final byte type, @@ -712,8 +719,6 @@ clMessage.setFlowControlSize(message.getRequiredBufferSize()); - workDone(); - consumer.handleMessage(message.getClientMessage()); } } Modified: trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java =================================================================== --- trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java 2009-10-27 02:24:40 UTC (rev 8145) +++ trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java 2009-10-27 10:18:02 UTC (rev 8146) @@ -462,6 +462,11 @@ { session.rollback(); } + + public boolean isRollbackOnly() + { + return session.isRollbackOnly(); + } public void rollback(boolean considerLastMessageAsDelivered) throws HornetQException { Modified: trunk/tests/jms-tests/src/org/hornetq/jms/tests/message/MessageHeaderTest.java =================================================================== --- trunk/tests/jms-tests/src/org/hornetq/jms/tests/message/MessageHeaderTest.java 2009-10-27 02:24:40 UTC (rev 8145) +++ trunk/tests/jms-tests/src/org/hornetq/jms/tests/message/MessageHeaderTest.java 2009-10-27 10:18:02 UTC (rev 8146) @@ -1028,6 +1028,12 @@ { } + public boolean isRollbackOnly() + { + + return false; + } + public void rollback() throws HornetQException { } Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java 2009-10-27 02:24:40 UTC (rev 8145) +++ trunk/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java 2009-10-27 10:18:02 UTC (rev 8146) @@ -222,6 +222,8 @@ fail(session, latch); + assertTrue(session.isRollbackOnly()); + try { session.commit(); @@ -271,10 +273,92 @@ session.addFailureListener(new MyListener()); + ClientProducer producer = session.createProducer(ADDRESS); + + final int numMessages = 100; + + for (int i = 0; i < numMessages; i++) + { + ClientMessage message = session.createClientMessage(i % 2 == 0); + + setBody(i, message); + + message.putIntProperty("counter", i); + + producer.send(message); + } + + session.commit(); + + fail(session, latch); + + // committing again should work since didn't send anything since last commit + + assertFalse(session.isRollbackOnly()); + + session.commit(); + ClientConsumer consumer = session.createConsumer(ADDRESS); session.start(); + for (int i = 0; i < numMessages; i++) + { + // Only the persistent messages will survive + + if (i % 2 == 0) + { + ClientMessage message = consumer.receive(1000); + + assertNotNull(message); + + assertMessageBody(i, message); + + assertEquals(i, message.getProperty("counter")); + + message.acknowledge(); + } + } + + assertNull(consumer.receive(1000)); + + session.commit(); + + session.close(); + + assertEquals(0, sf.numSessions()); + + assertEquals(0, sf.numConnections()); + } + + public void testTransactedMessagesWithConsumerStartedBedoreFailover() throws Exception + { + ClientSessionFactoryInternal sf = getSessionFactory(); + + sf.setBlockOnNonPersistentSend(true); + sf.setBlockOnPersistentSend(true); + + ClientSession session = sf.createSession(false, false); + + session.createQueue(ADDRESS, ADDRESS, null, true); + + final CountDownLatch latch = new CountDownLatch(1); + + class MyListener implements FailureListener + { + public void connectionFailed(HornetQException me) + { + latch.countDown(); + } + } + + session.addFailureListener(new MyListener()); + + // create a consumer and start the session before failover + ClientConsumer consumer = session.createConsumer(ADDRESS); + + session.start(); + ClientProducer producer = session.createProducer(ADDRESS); final int numMessages = 100; @@ -290,15 +374,23 @@ producer.send(message); } + // messages will be delivered to the consumer when the session is committed session.commit(); + assertFalse(session.isRollbackOnly()); + fail(session, latch); - // committing again should work since didn't send anything since last commit - session.commit(); + + session.close(); + + session = sf.createSession(false, false); + + consumer = session.createConsumer(ADDRESS); - + session.start(); + for (int i = 0; i < numMessages; i++) { // Only the persistent messages will survive @@ -327,7 +419,7 @@ assertEquals(0, sf.numConnections()); } - + public void testTransactedMessagesConsumedSoRollback() throws Exception { ClientSessionFactoryInternal sf = getSessionFactory(); @@ -389,6 +481,8 @@ fail(session2, latch); + assertTrue(session2.isRollbackOnly()); + try { session2.commit(); @@ -474,6 +568,8 @@ fail(session2, latch); + assertFalse(session2.isRollbackOnly()); + consumer = session2.createConsumer(ADDRESS); for (int i = numMessages / 2; i < numMessages; i++) @@ -1637,7 +1733,8 @@ try { - session.commit(); + session.commit(); + fail("commit succeeded"); } catch (HornetQException e2) {