com.franz.agraph.http.handler

Class AGTQRStreamer

java.lang.Object

com.franz.agraph.http.handler.AGResponseHandler

com.franz.agraph.http.handler.AGTQRStreamer

Direct Known Subclasses:

AGTQRJSONStreamer, AGTQRTSVStreamer, AGTQRXMLStreamer

public abstract class AGTQRStreamer
extends AGResponseHandler

Constructor Summary

Constructors

Constructor and Description
AGTQRStreamer(String mimeType)

Method Summary

Modifier and Type	Method and Description
static AGTQRStreamer	createStreamer(TupleQueryResultFormat format, AGValueFactory vf)
abstract String	getRequestMIMEType()
abstract TupleQueryResult	getResult()
abstract void	handleResponse(org.apache.http.HttpResponse httpResponse, org.apache.http.client.methods.HttpUriRequest httpUriRequest)
boolean	releaseConnection() False because the Result will release the HTTP resources.

Methods inherited from class java.lang.Object

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

Constructor Detail

AGTQRStreamer

public AGTQRStreamer(String mimeType)

Method Detail

getRequestMIMEType

public abstract String getRequestMIMEType()

Overrides:

getRequestMIMEType in class AGResponseHandler

releaseConnection

public boolean releaseConnection()

False because the Result will release the HTTP resources. For most responses, AGHTTPClient releases resources after calling handleResponse(HttpResponse, HttpUriRequest), but here the results are pulled when needed from the Result class, which is an inner class of child classes.

Overrides:

releaseConnection in class AGResponseHandler

Returns:

Boolean always returns true

handleResponse

public abstract void handleResponse(org.apache.http.HttpResponse httpResponse,
                                    org.apache.http.client.methods.HttpUriRequest httpUriRequest)
                             throws IOException,
                                    AGHttpException

Specified by:

handleResponse in class AGResponseHandler

Throws:

IOException

AGHttpException

getResult

public abstract TupleQueryResult getResult()

createStreamer

public static AGTQRStreamer createStreamer(TupleQueryResultFormat format,
                                           AGValueFactory vf)