From 78b5205154be9a85806cac925a0d2de9d11aaa5b Mon Sep 17 00:00:00 2001 From: Marnie McCormack Date: Fri, 6 Apr 2007 15:21:33 +0000 Subject: 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 --- .../src/main/java/org/apache/qpid/example/subscriber/Subscriber.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'java/client/example/src') 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); -- cgit v1.2.1