public class AsyncWriteQueueRecord extends AsyncQueueRecord<WriteResult>
AsyncQueue
write element unitcompletionHandler, connection, currentResult, isRecycled, message, recycleTrack
Modifier | Constructor and Description |
---|---|
protected |
AsyncWriteQueueRecord(Connection connection,
WritableMessage message,
WriteResult currentResult,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isEmptyRecord) |
Modifier and Type | Method and Description |
---|---|
boolean |
canBeAggregated() |
static AsyncWriteQueueRecord |
create(Connection connection,
WritableMessage message,
WriteResult currentResult,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushbackHandler,
boolean isEmptyRecord) |
Object |
getDstAddress() |
long |
getInitialMessageSize() |
PushBackHandler |
getPushBackHandler()
Deprecated.
|
WritableMessage |
getWritableMessage() |
boolean |
isEmptyRecord() |
boolean |
isFinished() |
void |
notifyCompleteAndRecycle() |
void |
recycle() |
long |
remaining() |
protected void |
reset() |
protected void |
set(Connection connection,
WritableMessage message,
WriteResult currentResult,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isEmptyRecord) |
void |
setEmptyRecord(boolean isEmptyRecord) |
checkRecycled, getConnection, getCurrentResult, getMessage, notifyFailure, notifyIncomplete, set, setMessage
protected AsyncWriteQueueRecord(Connection connection, WritableMessage message, WriteResult currentResult, CompletionHandler completionHandler, Object dstAddress, PushBackHandler pushBackHandler, boolean isEmptyRecord)
public static AsyncWriteQueueRecord create(Connection connection, WritableMessage message, WriteResult currentResult, CompletionHandler completionHandler, Object dstAddress, PushBackHandler pushbackHandler, boolean isEmptyRecord)
protected void set(Connection connection, WritableMessage message, WriteResult currentResult, CompletionHandler completionHandler, Object dstAddress, PushBackHandler pushBackHandler, boolean isEmptyRecord)
public final Object getDstAddress()
public final WritableMessage getWritableMessage()
public boolean isEmptyRecord()
public void setEmptyRecord(boolean isEmptyRecord)
public long getInitialMessageSize()
public long remaining()
@Deprecated public PushBackHandler getPushBackHandler()
public boolean canBeAggregated()
public void notifyCompleteAndRecycle()
public boolean isFinished()
protected final void reset()
public void recycle()
Copyright © 2014 Oracle Corporation. All rights reserved.