com.bytelightning.opensource.pokerface

Class BufferContentProducer

java.lang.Object

com.bytelightning.opensource.pokerface.BufferContentProducer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.http.nio.entity.HttpAsyncContentProducer

public class BufferContentProducer
extends Object
implements org.apache.http.nio.entity.HttpAsyncContentProducer

Produces asynchronous content from an IOControlled byte buffer. This class is primarily used to produce the content from a remote target back to a requesting client.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	Logger

Constructor Summary

Constructors

Constructor and Description
BufferContentProducer(BufferIOController buffer, String txId, String role) Primary constructor

Method Summary

Modifier and Type	Method and Description
void	close() This specialization closes the content buffer.
boolean	isRepeatable()
void	produceContent(org.apache.http.nio.ContentEncoder encoder, org.apache.http.nio.IOControl ioctrl) This method is only called if the response has content (which is typically the case).

Methods inherited from class java.lang.Object

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

Field Detail

Logger

protected static final org.slf4j.Logger Logger

Constructor Detail

BufferContentProducer

public BufferContentProducer(BufferIOController buffer,
                             String txId,
                             String role)

Primary constructor

Parameters:

buffer - The buffer that content will be produced from

txId - The transaction id that this object is participating in

role - The roll of this producer (e.g. server, proxy, etc.).

Method Detail

isRepeatable

public boolean isRepeatable()

Specified by:

isRepeatable in interface org.apache.http.nio.entity.HttpAsyncContentProducer

close

public void close()
           throws IOException

This specialization closes the content buffer.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

produceContent

public void produceContent(org.apache.http.nio.ContentEncoder encoder,
                           org.apache.http.nio.IOControl ioctrl)
                    throws IOException

This method is only called if the response has content (which is typically the case). It flips it's buffer (which some other object has asynchronously written into), reads the response data and encodes it out to the client who requested it.

Specified by:

produceContent in interface org.apache.http.nio.entity.HttpAsyncContentProducer

Throws:

IOException