public class AsyncWriteQueueRecord extends AsyncQueueRecord<RecordWriteResult>
AsyncQueue
write element unitModifier and Type | Field and Description |
---|---|
static int |
UNCOUNTABLE_RECORD_SPACE_VALUE |
completionHandler, connection, isRecycled, message, recycleTrack
Modifier | Constructor and Description |
---|---|
protected |
AsyncWriteQueueRecord(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
Modifier and Type | Method and Description |
---|---|
boolean |
canBeAggregated() |
static AsyncWriteQueueRecord |
create(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushbackHandler,
boolean isUncountable) |
long |
getBytesToReserve() |
RecordWriteResult |
getCurrentResult()
Returns the current record result object.
|
Object |
getDstAddress() |
long |
getInitialMessageSize() |
PushBackHandler |
getPushBackHandler()
Deprecated.
|
WritableMessage |
getWritableMessage() |
boolean |
isFinished() |
boolean |
isUncountable() |
void |
notifyCompleteAndRecycle() |
void |
recycle() |
long |
remaining() |
protected void |
reset() |
protected void |
set(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
void |
setUncountable(boolean isUncountable) |
checkRecycled, getConnection, getMessage, notifyFailure, notifyIncomplete, set, setMessage
public static final int UNCOUNTABLE_RECORD_SPACE_VALUE
protected AsyncWriteQueueRecord(Connection connection, WritableMessage message, CompletionHandler completionHandler, Object dstAddress, PushBackHandler pushBackHandler, boolean isUncountable)
public static AsyncWriteQueueRecord create(Connection connection, WritableMessage message, CompletionHandler completionHandler, Object dstAddress, PushBackHandler pushbackHandler, boolean isUncountable)
protected void set(Connection connection, WritableMessage message, CompletionHandler completionHandler, Object dstAddress, PushBackHandler pushBackHandler, boolean isUncountable)
public final Object getDstAddress()
public final WritableMessage getWritableMessage()
public boolean isUncountable()
remaining()
, but is constant
UNCOUNTABLE_RECORD_SPACE_VALUE
.public void setUncountable(boolean isUncountable)
public long getBytesToReserve()
public long getInitialMessageSize()
public long remaining()
public RecordWriteResult getCurrentResult()
AsyncQueueRecord
getCurrentResult
in class AsyncQueueRecord<RecordWriteResult>
@Deprecated public PushBackHandler getPushBackHandler()
public boolean canBeAggregated()
public void notifyCompleteAndRecycle()
public boolean isFinished()
protected final void reset()
public void recycle()
Copyright © 2015 Oracle Corporation. All rights reserved.