From d3cc015488955b0baa60cbd9b8dbe579aed26d40 Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Tue, 11 Jan 2011 03:05:32 +0000 Subject: 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 --- java/common/src/main/java/org/apache/qpid/transport/Session.java | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'java/common/src') 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); } -- cgit v1.2.1