diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2007-09-10 12:40:53 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2007-09-10 12:40:53 +0000 |
| commit | a3888992865a54a3686c0e59b11a5d37d125bac4 (patch) | |
| tree | e41266ab8435a5f9b07fe2a5f4cda1383b462a20 /qpid/java/client | |
| parent | a41a1bcc8d5df4e801712682409f86a78fef3eb8 (diff) | |
| download | qpid-python-a3888992865a54a3686c0e59b11a5d37d125bac4.tar.gz | |
updated recover
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574226 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpidity/jms/SessionImpl.java | 19 |
1 files changed, 11 insertions, 8 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpidity/jms/SessionImpl.java b/qpid/java/client/src/main/java/org/apache/qpidity/jms/SessionImpl.java index 010a43ab41..675a51625a 100644 --- a/qpid/java/client/src/main/java/org/apache/qpidity/jms/SessionImpl.java +++ b/qpid/java/client/src/main/java/org/apache/qpidity/jms/SessionImpl.java @@ -122,7 +122,7 @@ public class SessionImpl implements Session * This session connection */ private ConnectionImpl _connection; - + /** * This will be used as the message actor id * This in turn will be set as the destination @@ -465,13 +465,13 @@ public class SessionImpl implements Session throw new IllegalStateException("Session is transacted"); } // release all unack messages + RangeSet ranges = new RangeSet(); for (QpidMessage message : _unacknowledgedMessages) { - // release this message - RangeSet ranges = new RangeSet(); + // release this message ranges.add(message.getMessageTransferId()); - getQpidSession().messageRelease(ranges); } + getQpidSession().messageRelease(ranges); } /** @@ -599,7 +599,8 @@ public class SessionImpl implements Session MessageConsumerImpl consumer; try { - consumer = new MessageConsumerImpl(this, (DestinationImpl) destination, messageSelector, noLocal, null,String.valueOf(_consumerTag.incrementAndGet())); + consumer = new MessageConsumerImpl(this, (DestinationImpl) destination, messageSelector, noLocal, null, + String.valueOf(_consumerTag.incrementAndGet())); } catch (Exception e) { @@ -726,7 +727,8 @@ public class SessionImpl implements Session try { subscriber = new TopicSubscriberImpl(this, topic, messageSelector, noLocal, - _connection.getClientID() + ":" + name,String.valueOf(_consumerTag.incrementAndGet())); + _connection.getClientID() + ":" + name, + String.valueOf(_consumerTag.incrementAndGet())); } catch (Exception e) { @@ -770,7 +772,8 @@ public class SessionImpl implements Session QueueBrowserImpl browser; try { - browser = new QueueBrowserImpl(this, queue, messageSelector,String.valueOf(_consumerTag.incrementAndGet())); + browser = + new QueueBrowserImpl(this, queue, messageSelector, String.valueOf(_consumerTag.incrementAndGet())); } catch (Exception e) { @@ -1301,7 +1304,7 @@ public class SessionImpl implements Session { try { - // mc.onMessage(message.getMessage()); + // mc.onMessage(message.getMessage()); mc.notifyMessageListener(message.getMessage()); } catch (RuntimeException t) |