Class SPARQLRequestProcessorImpl

java.lang.Object

se.liu.ida.hefquin.federation.access.impl.reqproc.SPARQLRequestProcessorImpl

All Implemented Interfaces:

SolMapRetrievalProcessor<SPARQLRequest,SPARQLEndpoint>, SPARQLRequestProcessor, RequestProcessor<SPARQLRequest,SolMapsResponse,SPARQLEndpoint>

public class SPARQLRequestProcessorImpl
extends Object
implements SPARQLRequestProcessor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	SPARQLRequestProcessorImpl.MySolutionConsumer

Field Summary

Fields

Modifier and Type	Field	Description
protected final HttpClient	httpClient
protected final long	overallTimeout

Constructor Summary

Constructors

Constructor	Description
SPARQLRequestProcessorImpl()
SPARQLRequestProcessorImpl(long connectionTimeout, long overallTimeout)	The given timeouts are specified in milliseconds.

Method Summary

Modifier and Type	Method	Description
SolMapsResponse	performRequest(SPARQLRequest req, SPARQLEndpoint fm)
protected SolMapsResponse	performRequestWithQueryExecutionHTTP(SPARQLRequest req, SPARQLEndpoint fm)
protected SolMapsResponse	performRequestWithRDFConnection(SPARQLRequest req, SPARQLEndpoint fm)

Methods inherited from class java.lang.Object

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

Methods inherited from interface se.liu.ida.hefquin.federation.access.impl.reqproc.SolMapRetrievalProcessor

isSupportedResponseType

Methods inherited from interface se.liu.ida.hefquin.federation.access.impl.reqproc.SPARQLRequestProcessor

isSupportedMemberType, isSupportedRequestType

Field Details

httpClient

protected final HttpClient httpClient

overallTimeout

protected final long overallTimeout

Constructor Details

SPARQLRequestProcessorImpl

public SPARQLRequestProcessorImpl()

SPARQLRequestProcessorImpl

public SPARQLRequestProcessorImpl(long connectionTimeout,
 long overallTimeout)

The given timeouts are specified in milliseconds. Any value <= 0 means no timeout.

Method Details

performRequest

public SolMapsResponse performRequest(SPARQLRequest req,
 SPARQLEndpoint fm)
                               throws FederationAccessException

Specified by:

performRequest in interface RequestProcessor<SPARQLRequest,SolMapsResponse,SPARQLEndpoint>

Throws:

FederationAccessException

performRequestWithQueryExecutionHTTP

protected SolMapsResponse performRequestWithQueryExecutionHTTP(SPARQLRequest req,
 SPARQLEndpoint fm)
                                                        throws FederationAccessException

Throws:

FederationAccessException

performRequestWithRDFConnection

protected SolMapsResponse performRequestWithRDFConnection(SPARQLRequest req,
 SPARQLEndpoint fm)
                                                   throws FederationAccessException

Throws:

FederationAccessException