mirror of https://github.com/apache/activemq.git
added some comments about what we should problably do...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476262 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
94f16ac6ab
commit
411e750806
|
@ -66,7 +66,13 @@ public class KahaMessageStore implements MessageStore, UsageListener{
|
|||
|
||||
public synchronized void addMessage(ConnectionContext context,Message message) throws IOException{
|
||||
StoreEntry item = messageContainer.placeLast(message);
|
||||
// TODO: we should do the following but it is not need if the message is being added within a persistence transaction
|
||||
// but since I can't tell if one is running right now.. I'll leave this out for now.
|
||||
// if( message.isResponseRequired() ) {
|
||||
// messageContainer.force();
|
||||
// }
|
||||
cache.put(message.getMessageId(),item);
|
||||
|
||||
}
|
||||
|
||||
public synchronized void addMessageReference(ConnectionContext context,MessageId messageId,long expirationTime,String messageRef)
|
||||
|
|
Loading…
Reference in New Issue