mirror of https://github.com/apache/activemq.git
Fixed AMQ-5160, removed producer's retain property from retained messages
This commit is contained in:
parent
78950ec596
commit
c915b19a20
|
@ -56,6 +56,7 @@ public class RetainedMessageSubscriptionRecoveryPolicy implements SubscriptionRe
|
|||
if (message.getContent().getLength() > 0) {
|
||||
// non zero length message content
|
||||
retainedMessage = message.copy();
|
||||
retainedMessage.getMessage().removeProperty(RETAIN_PROPERTY);
|
||||
retainedMessage.getMessage().setProperty(RETAINED_PROPERTY, true);
|
||||
} else {
|
||||
// clear retained message
|
||||
|
|
Loading…
Reference in New Issue