public final class AsyncReadQueueRecord extends AsyncQueueRecord<ReadResult>
AsyncQueue
read element unitModifier and Type | Field and Description |
---|---|
protected Interceptor |
interceptor |
completionHandler, connection, isRecycled, message, recycleTrack
Modifier and Type | Method and Description |
---|---|
static AsyncReadQueueRecord |
create(Connection connection,
Buffer message,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
ReadResult |
getCurrentResult()
Returns the current record result object.
|
Interceptor |
getInterceptor() |
boolean |
isFinished() |
void |
notifyComplete() |
void |
recycle() |
protected void |
reset() |
protected void |
set(Connection connection,
Object message,
CompletionHandler completionHandler,
Interceptor interceptor) |
checkRecycled, getConnection, getMessage, notifyFailure, notifyIncomplete, set, setMessage
protected Interceptor interceptor
public static AsyncReadQueueRecord create(Connection connection, Buffer message, CompletionHandler completionHandler, Interceptor<ReadResult> interceptor)
public final Interceptor getInterceptor()
public final void notifyComplete()
public boolean isFinished()
public ReadResult getCurrentResult()
AsyncQueueRecord
getCurrentResult
in class AsyncQueueRecord<ReadResult>
protected final void set(Connection connection, Object message, CompletionHandler completionHandler, Interceptor interceptor)
protected final void reset()
public void recycle()
Copyright © 2015 Oracle Corporation. All rights reserved.