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 | 8438aeee36f4488f61cf8bf9e2354eab9aa34000 (patch) | |
| tree | ac4554d92e83b00be66409b0af40bc2c38aca82c /java/client/example/src | |
| parent | 70da584bd2e48bd56320f7ca1f6e94dfa430596d (diff) | |
| download | qpid-python-8438aeee36f4488f61cf8bf9e2354eab9aa34000.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/qpid@526197 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/example/src')
| -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); |