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 | d3cc015488955b0baa60cbd9b8dbe579aed26d40 (patch) | |
| tree | d3ba3fd6fc93ed460d82cad1217549e7b59550b4 /java | |
| parent | e9d132e3767e0d46fdc11001c520521cbe010929 (diff) | |
| download | qpid-python-d3cc015488955b0baa60cbd9b8dbe579aed26d40.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/qpid@1057462 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/Session.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/transport/Session.java b/java/common/src/main/java/org/apache/qpid/transport/Session.java index ea7eca302b..8207e6f5cf 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/Session.java +++ b/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); } |