diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2011-01-11 03:05:32 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2011-01-11 03:05:32 +0000 |
| commit | c68f328d629b9b11af8869aec0fb938beeaf535e (patch) | |
| tree | bc7bf94082f3459740726ed9baedb5d8956e5d76 /qpid/java/common | |
| parent | cc5e2c7fd0f55eabba8d0ec55a3ddec2d526c70b (diff) | |
| download | qpid-python-c68f328d629b9b11af8869aec0fb938beeaf535e.tar.gz | |
QPID-2995
The redelivered flag is now set on messages that are restransmitted after failover.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1057462 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java index ea7eca302b..8207e6f5cf 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java @@ -260,6 +260,10 @@ public class Session extends SessionInvoker m = new ExecutionSync(); m.setId(i); } + else if (m instanceof MessageTransfer) + { + ((MessageTransfer)m).getHeader().get(DeliveryProperties.class).setRedelivered(true); + } sessionCommandPoint(m.getId(), 0); send(m); } |