activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r476262 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java
Date Fri, 17 Nov 2006 19:18:00 GMT
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)



Mime
View raw message