Package com.franz.agraph.http.handler

Class AGTQRXMLStreamer

java.lang.Object

com.franz.agraph.http.handler.AGResponseHandler

com.franz.agraph.http.handler.AGTQRStreamer

com.franz.agraph.http.handler.AGTQRXMLStreamer

public class AGTQRXMLStreamer
extends AGTQRStreamer

Similar to SPARQLResultsXMLParser but uses XMLStreamReader instead of SAXParser so the results streaming in the http response can be processed in a TupleQueryResult pulling from the stream.

Since:

v2.1.0

Constructor Summary

Constructors

Constructor	Description
AGTQRXMLStreamer(AGValueFactory vf)

Method Summary

Modifier and Type	Method	Description
String	getRequestMIMEType()
TupleQueryResult	getResult()
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 com.franz.agraph.http.handler.AGTQRStreamer

createStreamer

Methods inherited from class java.lang.Object

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

Constructor Details

AGTQRXMLStreamer

public AGTQRXMLStreamer(AGValueFactory vf)

Method Details

getRequestMIMEType

public String getRequestMIMEType()

Specified by:

getRequestMIMEType in class AGTQRStreamer

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 AGTQRXMLStreamer.Result.

Overrides:

releaseConnection in class AGTQRStreamer

Returns:

Boolean always returns true

handleResponse

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

Specified by:

handleResponse in class AGTQRStreamer

Throws:

IOException

AGHttpException

getResult

public TupleQueryResult getResult()

Specified by:

getResult in class AGTQRStreamer