Explicitly close the journal file when done reading instead of waitin…

…g for the GC to do it.
twitter-archive · Sep 23, 2011 · ebd4b78 · ebd4b78
1 parent da18a2f
commit ebd4b78
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/scala/net/lag/kestrel/Journal.scala b/src/main/scala/net/lag/kestrel/Journal.scala
@@ -209,6 +209,7 @@ class Journal(queuePath: String, queueName: String, syncJournal: => Boolean, mul
             f(item)
           case (JournalItem.EndOfFile, _) =>
             // move to next file and try again.
+            rj.close
             readerFilename = Journal.journalAfter(new File(queuePath), queueName, readerFilename.get)
             reader = Some(new FileInputStream(new File(queuePath, readerFilename.get)).getChannel)
             fillReadBehind(f)