activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r591145 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java
Date Thu, 01 Nov 2007 21:23:46 GMT
Author: rajdavies
Date: Thu Nov  1 14:23:44 2007
New Revision: 591145

URL: http://svn.apache.org/viewvc?rev=591145&view=rev
Log:
Fix for https://issues.apache.org/activemq/browse/AMQ-1485
Fix npe for above

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

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java?rev=591145&r1=591144&r2=591145&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java
Thu Nov  1 14:23:44 2007
@@ -77,6 +77,7 @@
     public HashIndex(File directory, String name, IndexManager indexManager) throws IOException
{
         this.directory = directory;
         this.name = name;
+        this.indexManager = indexManager;
         openIndexFile();
         pageCache = new LRUCache<Long, HashPage>(pageCacheSize, pageCacheSize, 0.75f,
true);
     }
@@ -176,7 +177,6 @@
 
     public synchronized void load() {
         if (loaded.compareAndSet(false, true)) {
-            this.indexManager = indexManager;
             int capacity = 1;
             while (capacity < numberOfBins) {
                 capacity <<= 1;



Mime
View raw message