Merge pull request #166 from olegz/INT-2212

removed dependency on removed Message when disassociating it from MessageGroupMetadata
This commit is contained in:
Mark Fisher
2011-11-03 11:11:45 -04:00

View File

@@ -186,12 +186,9 @@ public abstract class AbstractKeyValueMessageStore extends AbstractMessageGroupS
UUID firstId = messageGroupMetadata.firstId();
if (firstId != null){
Message<?> message = this.removeMessage(firstId);
messageGroupMetadata.remove(message.getHeaders().getId());
messageGroupMetadata.remove(firstId);
this.doStore(MESSAGE_GROUP_KEY_PREFIX + groupId, messageGroupMetadata);
return message;
return this.removeMessage(firstId);
}
}
return null;