Top Description Fields Constructors Methods
org.glassfish.grizzly.asyncqueue

public final Class AsyncReadQueueRecord

extends AsyncQueueRecord<ReadResult<K, L>>
Class Inheritance
Imports
org.glassfish.grizzly.Buffer, .CompletionHandler, .Connection, .Grizzly, .Interceptor, .ReadResult, .ThreadCache, org.glassfish.grizzly.utils.DebugPoint
AsyncQueue read element unit
Author
Alexey Stashok

Field Summary

Modifier and TypeField and Description
private static final ThreadCache.CachedTypeIndex<AsyncReadQueueRecord>
CACHE_IDX

protected Interceptor<R>
interceptor

private final RecordReadResult<K, L>
readResult

Inherited from org.glassfish.grizzly.asyncqueue.AsyncQueueRecord:
completionHandlerconnectionisRecycledmessagerecycleTrack

Constructor Summary

AccessConstructor and Description
private
AsyncReadQueueRecord(final Connection<L> connection, final Buffer message, final CompletionHandler<E> completionHandler, final Interceptor<ReadResult<K, L>> interceptor)

Method Summary

Modifier and TypeMethod and Description
public static AsyncReadQueueRecord
create(final Connection<L> connection, final Buffer message, final CompletionHandler<E> completionHandler, final Interceptor<ReadResult<K, L>> interceptor)

public ReadResult<K, L>
getCurrentResult()

Implements abstract org.glassfish.grizzly.asyncqueue.AsyncQueueRecord.getCurrentResult.

Returns the current record result object.

public Interceptor<R>
getInterceptor()

public boolean
isFinished()

public void
notifyComplete()

public void
recycle()

Implements org.glassfish.grizzly.Cacheable.recycle.

protected void
reset()

protected void
set(final Connection<L> connection, final Object message, final CompletionHandler<E> completionHandler, final Interceptor<R> interceptor)

Inherited from org.glassfish.grizzly.asyncqueue.AsyncQueueRecord:
checkRecycledgetConnectiongetMessagenotifyFailurenotifyIncompletesetsetMessage

Field Detail

CACHE_IDXback to summary
private static final ThreadCache.CachedTypeIndex<AsyncReadQueueRecord> CACHE_IDX
interceptorback to summary
protected Interceptor<R> interceptor
readResultback to summary
private final RecordReadResult<K, L> readResult

Constructor Detail

AsyncReadQueueRecordback to summary
private AsyncReadQueueRecord(final Connection<L> connection, final Buffer message, final CompletionHandler<E> completionHandler, final Interceptor<ReadResult<K, L>> interceptor)

Method Detail

createback to summary
public static AsyncReadQueueRecord create(final Connection<L> connection, final Buffer message, final CompletionHandler<E> completionHandler, final Interceptor<ReadResult<K, L>> interceptor)
getCurrentResultback to summary
public ReadResult<K, L> getCurrentResult()

Implements abstract org.glassfish.grizzly.asyncqueue.AsyncQueueRecord.getCurrentResult.

Doc from org.glassfish.grizzly.asyncqueue.AsyncQueueRecord.getCurrentResult.

Returns the current record result object.

Annotations
@Override
getInterceptorback to summary
public Interceptor<R> getInterceptor()
isFinishedback to summary
public boolean isFinished()
notifyCompleteback to summary
public void notifyComplete()
Annotations
@SuppressWarnings:unchecked
recycleback to summary
public void recycle()

Implements org.glassfish.grizzly.Cacheable.recycle.

Annotations
@Override
resetback to summary
protected void reset()
setback to summary
protected void set(final Connection<L> connection, final Object message, final CompletionHandler<E> completionHandler, final Interceptor<R> interceptor)
Annotations
@SuppressWarnings:unchecked