rabbit.httpio
Class HttpResponseReader

java.lang.Object
  rabbit.httpio.HttpResponseReader

All Implemented Interfaces:

AsyncListener, HttpHeaderListener, HttpHeaderSentListener

public class HttpResponseReader
extends java.lang.Object
implements HttpHeaderSentListener, HttpHeaderListener

A handler that write one http header and reads a response

Author:

Robert Olofsson

Constructor Summary

HttpResponseReader(java.nio.channels.SocketChannel channel, NioHandler nioHandler, TrafficLogger tl, BufferHandler bufHandler, HttpHeader header, boolean fullURI, boolean strictHttp, HttpResponseListener listener)
Create a new HttpResponseReader.

Method Summary

void	closed() The socket connection has been closed, either by this end or the other side.
void	failed(java.lang.Exception cause) Reading failed
void	httpHeaderRead(HttpHeader header, BufferHandle bh, boolean keepalive, boolean isChunked, long dataSize) One http header has been read
void	httpHeaderSent() The http header has been sent.
void	sendRequestAndWaitForResponse() Start the process of sending the header and reading the response.
void	timeout() The operation timed out

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpResponseReader

public HttpResponseReader(java.nio.channels.SocketChannel channel,
                          NioHandler nioHandler,
                          TrafficLogger tl,
                          BufferHandler bufHandler,
                          HttpHeader header,
                          boolean fullURI,
                          boolean strictHttp,
                          HttpResponseListener listener)
                   throws java.io.IOException

Create a new HttpResponseReader.

Parameters:

channel - the Channel to the client

nioHandler - the NioHandler to use for network and background tasks

tl - the network statistics gatherer

bufHandler - the BufferHandler to use

header - the request to send

fullURI - if true the request will have a full uri instead of just a relative one

strictHttp - if true then use strict http

listener - the listener that will be notified when the response has been read.

Throws:

java.io.IOException - if the request can not be sent

Method Detail

sendRequestAndWaitForResponse

public void sendRequestAndWaitForResponse()

Start the process of sending the header and reading the response.

httpHeaderSent

public void httpHeaderSent()

Description copied from interface: HttpHeaderSentListener

The http header has been sent.

Specified by:

httpHeaderSent in interface HttpHeaderSentListener

httpHeaderRead

public void httpHeaderRead(HttpHeader header,
                           BufferHandle bh,
                           boolean keepalive,
                           boolean isChunked,
                           long dataSize)

Description copied from interface: HttpHeaderListener

One http header has been read

Specified by:

httpHeaderRead in interface HttpHeaderListener

Parameters:

header - the HttpHeader that was read

bh - the BufferHandle that may or may not hold unread data.

keepalive - if the sender want to use keepalive.

isChunked - if false content is not chunked, if true content is chunked.

dataSize - the contents size or -1 if size is unknown.

closed

public void closed()

Description copied from interface: HttpHeaderListener

The socket connection has been closed, either by this end or the other side. Quite common on persistent connections.

Specified by:

closed in interface HttpHeaderListener

failed

public void failed(java.lang.Exception cause)

Description copied from interface: AsyncListener

Reading failed

Specified by:

failed in interface AsyncListener

Parameters:

cause - the real reason the operation failed.

timeout

public void timeout()

Description copied from interface: AsyncListener

The operation timed out

Specified by:

timeout in interface AsyncListener