org.glassfish.grizzly.asyncqueue
Class AsyncWriteQueueRecord

java.lang.Object
  org.glassfish.grizzly.asyncqueue.AsyncQueueRecord<WriteResult>
      org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord

All Implemented Interfaces:

Cacheable

public class AsyncWriteQueueRecord
extends AsyncQueueRecord<WriteResult>

AsyncQueue write element unit

Author:

Alexey Stashok

Field Summary

Fields inherited from class org.glassfish.grizzly.asyncqueue.AsyncQueueRecord

completionHandler, connection, currentResult, future, interceptor, isRecycled, message, originalMessage, recycleTrack

Constructor Summary

protected

AsyncWriteQueueRecord(Connection connection, Object message, Future future, WriteResult currentResult, CompletionHandler completionHandler, Interceptor interceptor, Object dstAddress, Buffer outputBuffer, boolean isCloned, boolean isEmptyRecord)

Method Summary

static AsyncWriteQueueRecord	create(Connection connection, Object message, Future future, WriteResult currentResult, CompletionHandler completionHandler, Interceptor interceptor, Object dstAddress, Buffer outputBuffer, boolean isCloned, boolean isEmptyRecord)
Object	getDstAddress()
Buffer	getOutputBuffer()
boolean	isCloned()
boolean	isEmptyRecord()
void	recycle()
protected void	reset()
protected void	set(Connection connection, Object message, Future future, WriteResult currentResult, CompletionHandler completionHandler, Interceptor interceptor, Object dstAddress, Buffer outputBuffer, boolean isCloned, boolean isEmptyRecord)
void	setCloned(boolean isCloned)
void	setEmptyRecord(boolean isEmptyRecord)
void	setOutputBuffer(Buffer outputBuffer)

Methods inherited from class org.glassfish.grizzly.asyncqueue.AsyncQueueRecord

checkRecycled, getCompletionHandler, getConnection, getCurrentResult, getFuture, getInterceptor, getMessage, getOriginalMessage, set, setFuture, setMessage

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncWriteQueueRecord

protected AsyncWriteQueueRecord(Connection connection,
                                Object message,
                                Future future,
                                WriteResult currentResult,
                                CompletionHandler completionHandler,
                                Interceptor interceptor,
                                Object dstAddress,
                                Buffer outputBuffer,
                                boolean isCloned,
                                boolean isEmptyRecord)

Method Detail

create

public static AsyncWriteQueueRecord create(Connection connection,
                                           Object message,
                                           Future future,
                                           WriteResult currentResult,
                                           CompletionHandler completionHandler,
                                           Interceptor interceptor,
                                           Object dstAddress,
                                           Buffer outputBuffer,
                                           boolean isCloned,
                                           boolean isEmptyRecord)

set

protected void set(Connection connection,
                   Object message,
                   Future future,
                   WriteResult currentResult,
                   CompletionHandler completionHandler,
                   Interceptor interceptor,
                   Object dstAddress,
                   Buffer outputBuffer,
                   boolean isCloned,
                   boolean isEmptyRecord)

isCloned

public final boolean isCloned()

setCloned

public final void setCloned(boolean isCloned)

getDstAddress

public final Object getDstAddress()

getOutputBuffer

public Buffer getOutputBuffer()

setOutputBuffer

public void setOutputBuffer(Buffer outputBuffer)

isEmptyRecord

public boolean isEmptyRecord()

setEmptyRecord

public void setEmptyRecord(boolean isEmptyRecord)

reset

protected final void reset()

recycle

public void recycle()