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 int
ABORT
static int
COMMIT
static int
START
-
Fields inherited from class com.swiftmq.impl.store.standard.log.LogOperation
OPER_CLOSE_LOG, OPER_INITIATE_SYNC, OPER_LOG_REC, OPER_SYNC_LOG
-
-
Constructor Summary
Constructors Constructor Description LogRecord(long txId, Semaphore semaphore, java.util.List journal, CacheReleaseListener cacheReleaseListener, AsyncCompletionCallback callback, java.util.List messagePageRefs)
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description static LogRecord
create(int type)
CacheReleaseListener
getCacheReleaseListener()
AsyncCompletionCallback
getCallback()
java.util.List
getJournal()
abstract int
getLogType()
long
getMagic()
java.util.List
getMessagePageRefs()
Semaphore
getSemaphore()
long
getTxId()
boolean
isComplete()
void
readContent(java.io.DataInput in)
void
readContent(java.io.DataInput in, boolean includeMagic)
void
setMagic(long magic)
java.lang.String
toString()
void
writeContent(java.io.DataOutput out)
void
writeContent(java.io.DataOutput out, boolean includeMagic)
-
-
-
Field Detail
-
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 Detail
-
LogRecord
public LogRecord(long txId, Semaphore semaphore, java.util.List journal, CacheReleaseListener cacheReleaseListener, AsyncCompletionCallback callback, java.util.List messagePageRefs)
-
-
Method Detail
-
create
public static LogRecord create(int type)
-
getTxId
public long getTxId()
-
getSemaphore
public Semaphore getSemaphore()
-
getLogType
public abstract int getLogType()
-
getJournal
public java.util.List getJournal()
-
getCacheReleaseListener
public CacheReleaseListener getCacheReleaseListener()
-
getCallback
public AsyncCompletionCallback getCallback()
-
getMessagePageRefs
public java.util.List getMessagePageRefs()
-
isComplete
public boolean isComplete()
-
getMagic
public long getMagic()
-
setMagic
public void setMagic(long magic)
-
writeContent
public void writeContent(java.io.DataOutput out) throws java.io.IOException
- Throws:
java.io.IOException
-
writeContent
public void writeContent(java.io.DataOutput out, boolean includeMagic) throws java.io.IOException
- Throws:
java.io.IOException
-
readContent
public void readContent(java.io.DataInput in) throws java.io.IOException
- Throws:
java.io.IOException
-
readContent
public void readContent(java.io.DataInput in, boolean includeMagic) throws java.io.IOException
- Throws:
java.io.IOException
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-