Class LogRecord

java.lang.Object

com.swiftmq.impl.store.standard.log.LogOperation

com.swiftmq.impl.store.standard.log.LogRecord

Direct Known Subclasses:

AbortLogRecord, CommitLogRecord, StartLogRecord

public abstract class LogRecord
extends LogOperation

Field Summary

Fields

Modifier and Type	Field	Description
static final int	ABORT
static final int	COMMIT
static final int	START

Fields inherited from class LogOperation

OPER_CLOSE_LOG, OPER_INITIATE_SYNC, OPER_LOG_REC, OPER_SYNC_LOG

Constructor Summary

Constructors

Constructor	Description
LogRecord(long txId, com.swiftmq.tools.concurrent.Semaphore semaphore, List journal, CacheReleaseListener cacheReleaseListener, com.swiftmq.tools.concurrent.AsyncCompletionCallback callback, List messagePageRefs)

Method Summary

Modifier and Type	Method	Description
static LogRecord	create(int type)
CacheReleaseListener	getCacheReleaseListener()
com.swiftmq.tools.concurrent.AsyncCompletionCallback	getCallback()
List	getJournal()
abstract int	getLogType()
long	getMagic()
List	getMessagePageRefs()
com.swiftmq.tools.concurrent.Semaphore	getSemaphore()
long	getTxId()
boolean	isComplete()
void	readContent(DataInput in)
void	readContent(DataInput in, boolean includeMagic)
void	setMagic(long magic)
String	toString()
void	writeContent(DataOutput out)
void	writeContent(DataOutput out, boolean includeMagic)

Methods inherited from class Object

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

Field Details

START

public static final int START

See Also:

• Constant Field Values

COMMIT

public static final int COMMIT

See Also:

• Constant Field Values

ABORT

public static final int ABORT

See Also:

• Constant Field Values

Constructor Details

LogRecord

public LogRecord(long txId,
 com.swiftmq.tools.concurrent.Semaphore semaphore,
 List journal,
 CacheReleaseListener cacheReleaseListener,
 com.swiftmq.tools.concurrent.AsyncCompletionCallback callback,
 List messagePageRefs)

Method Details

create

public static LogRecord create(int type)

getTxId

public long getTxId()

getSemaphore

public com.swiftmq.tools.concurrent.Semaphore getSemaphore()

getLogType

public abstract int getLogType()

getJournal

public List getJournal()

getCacheReleaseListener

public CacheReleaseListener getCacheReleaseListener()

getCallback

public com.swiftmq.tools.concurrent.AsyncCompletionCallback getCallback()

getMessagePageRefs

public List getMessagePageRefs()

isComplete

public boolean isComplete()

getMagic

public long getMagic()

setMagic

public void setMagic(long magic)

writeContent

public void writeContent(DataOutput out)
                  throws IOException

Throws:

IOException

writeContent

public void writeContent(DataOutput out,
 boolean includeMagic)
                  throws IOException

Throws:

IOException

readContent

public void readContent(DataInput in)
                 throws IOException

Throws:

IOException

readContent

public void readContent(DataInput in,
 boolean includeMagic)
                 throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object