org.glassfish.grizzly.asyncqueue
Class AsyncQueueRecord<R>

java.lang.Object
  org.glassfish.grizzly.asyncqueue.AsyncQueueRecord<R>

All Implemented Interfaces:

Cacheable

Direct Known Subclasses:

AsyncReadQueueRecord, AsyncWriteQueueRecord

public abstract class AsyncQueueRecord<R>
extends Object
implements Cacheable

AsyncQueue element unit

Author:

Alexey Stashok

Field Summary

protected CompletionHandler	completionHandler
protected Connection	connection
protected R	currentResult
protected Future	future
protected Interceptor	interceptor
protected boolean	isRecycled
protected Object	message
protected Object	originalMessage
protected DebugPoint	recycleTrack

Constructor Summary

AsyncQueueRecord(Connection connection, Object originalMessage, Future future, R currentResult, CompletionHandler completionHandler, Interceptor interceptor)

Method Summary

protected void	checkRecycled()
CompletionHandler	getCompletionHandler()
Connection	getConnection()
R	getCurrentResult()
Future	getFuture()
Interceptor	getInterceptor()
Object	getMessage()
Object	getOriginalMessage()
protected void	set(Connection connection, Object originalMessage, Future future, R currentResult, CompletionHandler completionHandler, Interceptor interceptor)
void	setFuture(Future future)
void	setMessage(Object message)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.glassfish.grizzly.Cacheable

recycle

Field Detail

connection

protected Connection connection

originalMessage

protected Object originalMessage

message

protected Object message

future

protected Future future

currentResult

protected R currentResult

completionHandler

protected CompletionHandler completionHandler

interceptor

protected Interceptor interceptor

isRecycled

protected boolean isRecycled

recycleTrack

protected DebugPoint recycleTrack

Constructor Detail

AsyncQueueRecord

public AsyncQueueRecord(Connection connection,
                        Object originalMessage,
                        Future future,
                        R currentResult,
                        CompletionHandler completionHandler,
                        Interceptor interceptor)

Method Detail

set

protected final void set(Connection connection,
                         Object originalMessage,
                         Future future,
                         R currentResult,
                         CompletionHandler completionHandler,
                         Interceptor interceptor)

getConnection

public Connection getConnection()

getOriginalMessage

public Object getOriginalMessage()

getMessage

public final Object getMessage()

setMessage

public final void setMessage(Object message)

getFuture

public final Future getFuture()

setFuture

public void setFuture(Future future)

getCurrentResult

public final R getCurrentResult()

getCompletionHandler

public final CompletionHandler getCompletionHandler()

getInterceptor

public final Interceptor getInterceptor()

checkRecycled

protected final void checkRecycled()