com.bytelightning.opensource.pokerface

Class TargetRequestProducer

java.lang.Object

com.bytelightning.opensource.pokerface.TargetBase

com.bytelightning.opensource.pokerface.TargetRequestProducer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.http.nio.protocol.HttpAsyncRequestProducer

public class TargetRequestProducer
extends TargetBase
implements org.apache.http.nio.protocol.HttpAsyncRequestProducer

This class forwards the request we received from a client on to a remote Target. In the streaming spirit, this class is created as soon as a remote Target is identified, and may actually make the HttpRequest to the remote Target before we have fully received the content of the request from the client. This class uses the BufferIOController to coordinate reading flow control from the RequestForTargetConsumer's incoming request content buffer. For this reason, this class has the responsibility for closing the buffer that was given to the RequestForTargetConsumer by the RequestHandler

Field Summary

Fields

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

Fields inherited from class com.bytelightning.opensource.pokerface.TargetBase

Via

Constructor Summary

Constructors

Constructor and Description
TargetRequestProducer(TargetDescriptor targetDesc, org.apache.http.HttpRequest clientRequest, org.apache.http.protocol.HttpContext context, BufferIOController buffer) Primary constructor

Method Summary

Modifier and Type	Method and Description
void	close() Close the content buffer given to us by the RequestForTargetConsumer.
void	failed(Exception ex)
org.apache.http.HttpRequest	generateRequest()
org.apache.http.HttpHost	getTarget()
boolean	isRepeatable() This class is not repeatable as it is created solely for this transaction.
void	produceContent(org.apache.http.nio.ContentEncoder encoder, org.apache.http.nio.IOControl ioctrl) This method is only called if the request has content (e.g.
void	requestCompleted(org.apache.http.protocol.HttpContext context)
void	resetRequest() Does nothing as this class is not repeatable because it is created solely for this transaction.

Methods inherited from class com.bytelightning.opensource.pokerface.TargetBase

BuildHeaderRemovalList, CreateHttpViaHeader

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

TargetRequestProducer

public TargetRequestProducer(TargetDescriptor targetDesc,
                             org.apache.http.HttpRequest clientRequest,
                             org.apache.http.protocol.HttpContext context,
                             BufferIOController buffer)

Primary constructor

Parameters:

targetDesc - The remote Target

clientRequest - The request we received from the client.

context - The context of this request / response transaction.

buffer - The buffer containing the content (if any) of the original request from the client.

Method Detail

close

public void close()
           throws IOException

Close the content buffer given to us by the RequestForTargetConsumer.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getTarget

public org.apache.http.HttpHost getTarget()

Specified by:

getTarget in interface org.apache.http.nio.protocol.HttpAsyncRequestProducer

generateRequest

public org.apache.http.HttpRequest generateRequest()

Specified by:

generateRequest in interface org.apache.http.nio.protocol.HttpAsyncRequestProducer

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 request has content (e.g. POST). It flips it's buffer (which the RequestForTargetConsumer has asynchronously written into), reads the request data and encodes it out to the remote Target.

Specified by:

produceContent in interface org.apache.http.nio.protocol.HttpAsyncRequestProducer

Throws:

IOException

requestCompleted

public void requestCompleted(org.apache.http.protocol.HttpContext context)

Specified by:

requestCompleted in interface org.apache.http.nio.protocol.HttpAsyncRequestProducer

isRepeatable

public boolean isRepeatable()

This class is not repeatable as it is created solely for this transaction.

Specified by:

isRepeatable in interface org.apache.http.nio.protocol.HttpAsyncRequestProducer

resetRequest

public void resetRequest()

Does nothing as this class is not repeatable because it is created solely for this transaction.

Specified by:

resetRequest in interface org.apache.http.nio.protocol.HttpAsyncRequestProducer

failed

public void failed(Exception ex)

Specified by:

failed in interface org.apache.http.nio.protocol.HttpAsyncRequestProducer