QPID-381 Amended session constructor to be non-transactional and use client ack mode.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@526195 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 2 insertions, 2 deletions

diff --git a/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java b/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java
index 4e92a6c678..d443dca828 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java
@@ -123,8 +123,8 @@ public class Subscriber
         {
              _connection = _connectionFactory.createConnection();
 
-             //create a transactional session
-            Session session =  _connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
+            //Non transactional session using client acknowledgement
+            Session session =  _connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
 
             //Create a consumer with a destination of our queue which will use defaults for prefetch etc
             _consumer = session.createConsumer(_destination);