diff options
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); } |