[hornetq-commits] JBoss hornetq SVN: r8557 - in trunk/examples/jms/non-transaction-failover: src/org/hornetq/jms/example and 1 other directory.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2009-12-04 11:10:51 -0500 (Fri, 04 Dec 2009)
New Revision: 8557

Modified:
   trunk/examples/jms/non-transaction-failover/readme.html
   trunk/examples/jms/non-transaction-failover/src/org/hornetq/jms/example/NonTransactionFailoverExample.java
Log:
updated non-transaction-failover example

Modified: trunk/examples/jms/non-transaction-failover/readme.html
===================================================================
--- trunk/examples/jms/non-transaction-failover/readme.html	2009-12-04 15:46:18 UTC (rev 8556)
+++ trunk/examples/jms/non-transaction-failover/readme.html	2009-12-04 16:10:51 UTC (rev 8557)
@@ -101,18 +101,9 @@
            }
            catch (JMSException e)
            {
-              System.out.println("Got exception while acknowledging message: " + e.getMessage());
-              ...
+              System.err.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">
@@ -124,26 +115,6 @@
            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">

Modified: 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	2009-12-04 15:46:18 UTC (rev 8556)
+++ trunk/examples/jms/non-transaction-failover/src/org/hornetq/jms/example/NonTransactionFailoverExample.java	2009-12-04 16:10:51 UTC (rev 8557)
@@ -104,15 +104,10 @@
          }
          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);
+            System.err.println("Got exception while acknowledging message: " + e.getMessage());
          }
 
-         // Step 13. Consume again the 2nd half of the messages again. Note that they are not considered as redelivered.
+         // Step 12. 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);
@@ -120,27 +115,11 @@
          }
          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!
+         // Step 13. Be sure to close our resources!
 
          if (connection != null)
          {