Package com.swiftmq.impl.store.standard.log

Class LogManagerEventProcessor

java.lang.Object

com.swiftmq.impl.store.standard.log.LogManagerEventProcessor

All Implemented Interfaces:

LogManager

public class LogManagerEventProcessor
extends Object
implements LogManager

Field Summary

Fields inherited from interface com.swiftmq.impl.store.standard.log.LogManager

checkPointVerbose, FILENAME, PROP_VERBOSE, TP_LM

Constructor Summary

Constructors

Constructor	Description
LogManagerEventProcessor(StoreContext ctx, CheckPointHandler checkPointHandler, String path, long maxLogSize, boolean forceSync)

Method Summary

Modifier and Type	Method	Description
RandomAccessFile	getLogFile()
void	initLogFile()
boolean	isForceSync()
void	process(List<Object> events)
void	setForceSync(boolean forceSync)
void	setLogManagerListener(LogManagerListener logManagerListener)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

LogManagerEventProcessor

public LogManagerEventProcessor(StoreContext ctx,
 CheckPointHandler checkPointHandler,
 String path,
 long maxLogSize,
 boolean forceSync)
                         throws Exception

Throws:

Exception

Method Details

initLogFile

public void initLogFile()

Specified by:

initLogFile in interface LogManager

setLogManagerListener

public void setLogManagerListener(LogManagerListener logManagerListener)

Specified by:

setLogManagerListener in interface LogManager

getLogFile

public RandomAccessFile getLogFile()

Specified by:

getLogFile in interface LogManager

setForceSync

public void setForceSync(boolean forceSync)

Specified by:

setForceSync in interface LogManager

isForceSync

public boolean isForceSync()

Specified by:

isForceSync in interface LogManager

process

public void process(List<Object> events)

toString

public String toString()

Overrides:

toString in class Object