public abstract class AsyncQueueRecord<R> extends Object implements Cacheable
AsyncQueue
element unitModifier and Type | Field and Description |
---|---|
protected CompletionHandler |
completionHandler |
protected Connection |
connection |
protected R |
currentResult |
protected boolean |
isRecycled |
protected Object |
message |
protected DebugPoint |
recycleTrack |
Constructor and Description |
---|
AsyncQueueRecord(Connection connection,
Object message,
R currentResult,
CompletionHandler completionHandler) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkRecycled() |
Connection |
getConnection() |
R |
getCurrentResult() |
<T> T |
getMessage() |
void |
notifyFailure(Throwable e) |
void |
notifyIncomplete() |
protected void |
set(Connection connection,
Object message,
R currentResult,
CompletionHandler completionHandler) |
void |
setMessage(Object message) |
protected Connection connection
protected Object message
protected R currentResult
protected CompletionHandler completionHandler
protected boolean isRecycled
protected DebugPoint recycleTrack
public AsyncQueueRecord(Connection connection, Object message, R currentResult, CompletionHandler completionHandler)
protected final void set(Connection connection, Object message, R currentResult, CompletionHandler completionHandler)
public Connection getConnection()
public final <T> T getMessage()
public final void setMessage(Object message)
public final R getCurrentResult()
public void notifyFailure(Throwable e)
public final void notifyIncomplete()
protected final void checkRecycled()
Copyright © 2014 Oracle Corporation. All rights reserved.