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