Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-5354 - patch applied with thanks

This commit is contained in:
gtully 2014-09-15 15:59:00 +01:00
parent 8ab9a56d35
commit a0c42a61dd
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
View File

@ -1369,13 +1369,16 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
Long id = sd.messageIdIndex.get(tx, command.getMessageId()); Long id = sd.messageIdIndex.get(tx, command.getMessageId());
if (id != null) { if (id != null) {
sd.orderIndex.put( MessageKeys previousKeys = sd.orderIndex.put(
tx, tx,
command.getPrioritySupported() ? command.getPriority() : javax.jms.Message.DEFAULT_PRIORITY, command.getPrioritySupported() ? command.getPriority() : javax.jms.Message.DEFAULT_PRIORITY,
id, id,
new MessageKeys(command.getMessageId(), location) new MessageKeys(command.getMessageId(), location)
); );
sd.locationIndex.put(tx, location, id); sd.locationIndex.put(tx, location, id);
if(previousKeys != null) {
sd.locationIndex.remove(tx, previousKeys.location);
}
} else { } else {
LOG.warn("Non existent message update attempt rejected. Destination: {}://{}, Message id: {}", command.getDestination().getType(), command.getDestination().getName(), command.getMessageId()); LOG.warn("Non existent message update attempt rejected. Destination: {}://{}, Message id: {}", command.getDestination().getType(), command.getDestination().getName(), command.getMessageId());
} }