summaryrefslogtreecommitdiff
path: root/java/client/src
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2009-10-05 15:03:16 +0000
committerMartin Ritchie <ritchiem@apache.org>2009-10-05 15:03:16 +0000
commit199dc525df58cd7793afd3ebd1900de57a63f9c2 (patch)
tree31acbf89eef47fe57e8448969c7a3b52e28cb138 /java/client/src
parent41628c7e879480eeb59cf29b235976e092cf1fee (diff)
downloadqpid-python-199dc525df58cd7793afd3ebd1900de57a63f9c2.tar.gz
Fix for dirty sessions, start to test that sessions are dirty when required.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@821823 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java1
1 files changed, 1 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
index 2dfecc80ac..667785c441 100644
--- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
+++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
@@ -779,6 +779,7 @@ public abstract class BasicMessageConsumer<U> extends Closeable implements Messa
else
{
_session.addDeliveredMessage(msg.getDeliveryTag());
+ _session.markDirty();
}
break;