diff options
| author | Marnie McCormack <marnie@apache.org> | 2007-04-06 15:22:42 +0000 |
|---|---|---|
| committer | Marnie McCormack <marnie@apache.org> | 2007-04-06 15:22:42 +0000 |
| commit | 1416791e86802c6ac798810662549f5facb30a59 (patch) | |
| tree | b2798a869c82ee9193f5a5104c4c270c9cf188aa /qpid/java/client/example/src | |
| parent | f90f46c05b12e9e38bff1ac8418add1b3fa074d8 (diff) | |
| download | qpid-python-1416791e86802c6ac798810662549f5facb30a59.tar.gz | |
QPID-381 Amended session constructor to make non-transactional and client ack mode.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@526197 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/example/src')
| -rw-r--r-- | qpid/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java index 4e92a6c678..d443dca828 100644 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java +++ b/qpid/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); |