From c68f328d629b9b11af8869aec0fb938beeaf535e 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@1057462 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'qpid/java') 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); } -- cgit v1.2.1