Package se.liu.ida.hefquin.engine.federation.access.impl.reqproc

Class SPARQLRequestProcessorImpl

java.lang.Object

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

All Implemented Interfaces:

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

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
protected static HttpClient	createHttpClient(long connectionTimeout)
SolMapsResponse	performRequest(SPARQLRequest req, SPARQLEndpoint fm)	Assumes that fm has a SolMapRetrievalInterface.
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

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

createHttpClient

protected static HttpClient createHttpClient(long connectionTimeout)

performRequest

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

Description copied from interface: SolMapRetrievalProcessor

Assumes that fm has a SolMapRetrievalInterface.

Specified by:

performRequest in interface RequestProcessor<SPARQLRequest,SPARQLEndpoint>

Specified by:

performRequest in interface SolMapRetrievalProcessor<SPARQLRequest,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