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
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intstatic final intstatic final intFields inherited from class com.swiftmq.impl.store.standard.log.LogOperation
OPER_CLOSE_LOG, OPER_INITIATE_SYNC, OPER_LOG_REC, OPER_SYNC_LOG -
Constructor Summary
ConstructorsConstructorDescriptionLogRecord(long txId, Semaphore semaphore, List journal, CacheReleaseListener cacheReleaseListener, AsyncCompletionCallback callback, List messagePageRefs) -
Method Summary
Modifier and TypeMethodDescriptionstatic LogRecordcreate(int type) AsyncCompletionCallbackabstract intlonggetMagic()SemaphorelonggetTxId()booleanvoidreadContent(DataInput in) voidreadContent(DataInput in, boolean includeMagic) voidsetMagic(long magic) toString()voidwriteContent(DataOutput out) voidwriteContent(DataOutput out, boolean includeMagic)
-
Field Details
-
START
public static final int START- See Also:
-
COMMIT
public static final int COMMIT- See Also:
-
ABORT
public static final int ABORT- See Also:
-
-
Constructor Details
-
LogRecord
public LogRecord(long txId, Semaphore semaphore, List journal, CacheReleaseListener cacheReleaseListener, AsyncCompletionCallback callback, List messagePageRefs)
-
-
Method Details
-
create
-
getTxId
public long getTxId() -
getSemaphore
public Semaphore getSemaphore() -
getLogType
public abstract int getLogType() -
getJournal
-
getCacheReleaseListener
-
getCallback
public AsyncCompletionCallback getCallback() -
getMessagePageRefs
-
isComplete
public boolean isComplete() -
getMagic
public long getMagic() -
setMagic
public void setMagic(long magic) -
writeContent
- Throws:
IOException
-
writeContent
- Throws:
IOException
-
readContent
- Throws:
IOException
-
readContent
- Throws:
IOException
-
toString
-