org.codehaus.activemq.journal.impl
Class LogFileManager
java.lang.Object
org.codehaus.activemq.journal.impl.LogFileManager
- public class LogFileManager
- extends Object
The LogFileManager manages concurent access to a LogFile.
- Version:
- $Revision: 1.7 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LogFileManager
public LogFileManager(byte fileManagerId,
LongSequenceGenerator sequenceGenerator,
File logDirectory)
throws IOException
LogFileManager
public LogFileManager(byte fileManagerId,
LongSequenceGenerator sequenceGenerator,
LogFile logFile)
write
public RecordLocationImpl write(byte[] data,
boolean sync)
throws IOException
- Throws:
IOException
setMark
public void setMark(RecordLocationImpl recordLocator,
boolean force)
throws InvalidRecordLocationException,
InterruptedException,
IOException
- Parameters:
recordLocator
- force
-
- Returns:
-
- Throws:
InvalidRecordLocationException
IOException
InterruptedException
getMark
public RecordLocationImpl getMark()
- Returns:
getNextRecordLocation
public RecordLocationImpl getNextRecordLocation(RecordLocationImpl lastLocation)
throws IOException,
InvalidRecordLocationException
- Parameters:
lastLocation
-
- Returns:
-
- Throws:
IOException
InvalidRecordLocationException
read
public byte[] read(RecordLocationImpl location)
throws IOException,
InvalidRecordLocationException
- Parameters:
location
-
- Returns:
-
- Throws:
InvalidRecordLocationException
IOException
setJournalEventListener
public void setJournalEventListener(JournalEventListener eventListener)
- Parameters:
eventListener
-
close
public void close()
- Throws:
InterruptedException
getLastSequenceId
public long getLastSequenceId()
getLogDirectory
public File getLogDirectory()
- Returns:
getTotalSegements
public int getTotalSegements()
getInitialSegmentSize
public int getInitialSegmentSize()
Copyright © 2004 Protique, Ltd.. All Rights Reserved.