Author: chirino
Date: Fri Nov 17 11:17:59 2006
New Revision: 476262
URL: http://svn.apache.org/viewvc?view=rev&rev=476262
Log:
added some comments about what we should problably do...
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java?view=diff&rev=476262&r1=476261&r2=476262
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java
Fri Nov 17 11:17:59 2006
@@ -66,7 +66,13 @@
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)
