mirror of https://github.com/apache/activemq.git
https://issues.apache.org/jira/browse/AMQ-5454 https://issues.apache.org/jira/browse/AMQ-6070 - in the case of duplicates from the store the regiondestination was not set
This commit is contained in:
parent
179dc3acb2
commit
88ec9dad9d
|
@ -97,9 +97,9 @@ public abstract class AbstractStoreCursor extends AbstractPendingMessageCursor i
|
||||||
|
|
||||||
public synchronized boolean recoverMessage(Message message, boolean cached) throws Exception {
|
public synchronized boolean recoverMessage(Message message, boolean cached) throws Exception {
|
||||||
boolean recovered = false;
|
boolean recovered = false;
|
||||||
|
message.setRegionDestination(regionDestination);
|
||||||
if (recordUniqueId(message.getMessageId())) {
|
if (recordUniqueId(message.getMessageId())) {
|
||||||
if (!cached) {
|
if (!cached) {
|
||||||
message.setRegionDestination(regionDestination);
|
|
||||||
if( message.getMemoryUsage()==null ) {
|
if( message.getMemoryUsage()==null ) {
|
||||||
message.setMemoryUsage(this.getSystemUsage().getMemoryUsage());
|
message.setMemoryUsage(this.getSystemUsage().getMemoryUsage());
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue