activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r582574 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java
Date Sun, 07 Oct 2007 04:42:29 GMT
Author: rajdavies
Date: Sat Oct  6 21:42:24 2007
New Revision: 582574

URL: http://svn.apache.org/viewvc?rev=582574&view=rev
Log:
Fix for https://issues.apache.org/activemq/browse/AMQ-1445

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java?rev=582574&r1=582573&r2=582574&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java
Sat Oct  6 21:42:24 2007
@@ -258,12 +258,15 @@
      */
     public synchronized IndexItem getNextEntry(IndexItem current) {
         IndexItem result = null;
-        if (current != null && current.getNextItem() >= 0) {
+        if (current != null ) {
+        	current = (IndexItem) refreshEntry(current);
+        	if(current.getNextItem() >= 0){
             try {
                 result = indexManager.getIndex(current.getNextItem());
             } catch (IOException e) {
                 throw new RuntimeException("Failed to get next index from " + indexManager
+ " for " + current, e);
             }
+        	}
         }
         // essential last get's updated consistently
         if (result != null && last != null && last.equals(result)) {



Mime
View raw message