[jboss-cvs] JBoss Messaging SVN: r4792 - trunk/examples/messaging/src/org/jboss/messaging/example.

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2008-08-12 08:53:32 -0400 (Tue, 12 Aug 2008)
New Revision: 4792

Modified:
   trunk/examples/messaging/src/org/jboss/messaging/example/SSLClient.java
   trunk/examples/messaging/src/org/jboss/messaging/example/SimpleClient.java
   trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java
Log:
in the core examples, added session acknowledgement after consuming the messages

Modified: trunk/examples/messaging/src/org/jboss/messaging/example/SSLClient.java
===================================================================
--- trunk/examples/messaging/src/org/jboss/messaging/example/SSLClient.java	2008-08-11 07:57:24 UTC (rev 4791)
+++ trunk/examples/messaging/src/org/jboss/messaging/example/SSLClient.java	2008-08-12 12:53:32 UTC (rev 4792)
@@ -69,6 +69,7 @@
          ClientConsumer clientConsumer = clientSession.createConsumer(queue);
          clientConnection.start();
          Message msg = clientConsumer.receive(5000);
+         clientSession.acknowledge();
          System.out.println("msg.getPayload() = " + msg.getBody().getString());
       }
       catch(Exception e)

Modified: trunk/examples/messaging/src/org/jboss/messaging/example/SimpleClient.java
===================================================================
--- trunk/examples/messaging/src/org/jboss/messaging/example/SimpleClient.java	2008-08-11 07:57:24 UTC (rev 4791)
+++ trunk/examples/messaging/src/org/jboss/messaging/example/SimpleClient.java	2008-08-12 12:53:32 UTC (rev 4792)
@@ -58,6 +58,7 @@
          clientConnection.start();
          Message msg = clientConsumer.receive(5000);
          System.out.println("msg.getPayload() = " + msg.getBody().getString());
+         clientSession.acknowledge();
       }
       catch(Exception e)
       {

Modified: trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java
===================================================================
--- trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java	2008-08-11 07:57:24 UTC (rev 4791)
+++ trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java	2008-08-12 12:53:32 UTC (rev 4792)
@@ -76,6 +76,7 @@
          ClientConsumer clientConsumer = clientSession.createConsumer(atestq);
          clientConnection.start();
          Message msg = clientConsumer.receive(5000);
+         clientSession.acknowledge();
          System.out.println("msg.getPayload() = " + msg.getBody().getString());
       }
       catch (Exception e)