diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2009-10-05 15:03:16 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2009-10-05 15:03:16 +0000 |
| commit | 8c6f534c948b86320f5e2088114790a40dbddb23 (patch) | |
| tree | 6e2658444c3ce04c5d0c1dec524249ce2faf4bd8 /qpid/java/client/src | |
| parent | 56d83b36d6f862bfdea3b39b4fee8be0eb8dcdb8 (diff) | |
| download | qpid-python-8c6f534c948b86320f5e2088114790a40dbddb23.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@821823 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/src')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java index 2dfecc80ac..667785c441 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java +++ b/qpid/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; |