diff options
| -rw-r--r-- | java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java | 4 |
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); |