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

Class BlockingFederationAccessManagerImpl

java.lang.Object

se.liu.ida.hefquin.engine.federation.access.impl.FederationAccessManagerBase1

se.liu.ida.hefquin.engine.federation.access.impl.FederationAccessManagerBase2

se.liu.ida.hefquin.engine.federation.access.impl.BlockingFederationAccessManagerImpl

All Implemented Interfaces:

StatsProvider, FederationAccessManager

public class BlockingFederationAccessManagerImpl
extends FederationAccessManagerBase2

A very simple FederationAccessManager that simply blocks for each request.

Nested Class Summary

Nested classes/interfaces inherited from class se.liu.ida.hefquin.engine.federation.access.impl.FederationAccessManagerBase1

FederationAccessManagerBase1.FunctionToObtainCardinalityResponseFromSolMapsResponse, FederationAccessManagerBase1.FunctionToObtainCardinalityResponseFromTPFResponse

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicLong	counterBRTPFRequests
protected AtomicLong	counterNeo4jRequests
protected AtomicLong	counterSPARQLRequests
protected AtomicLong	counterTPFRequests

Fields inherited from class se.liu.ida.hefquin.engine.federation.access.impl.FederationAccessManagerBase2

reqProcBRTPF, reqProcNeo4j, reqProcSPARQL, reqProcTPF

Fields inherited from class se.liu.ida.hefquin.engine.federation.access.impl.FederationAccessManagerBase1

countVar, enNumberOfBRTPFCardRequestsIssued, enNumberOfSPARQLCardRequestsIssued, enNumberOfTPFCardRequestsIssued, enOverallNumberOfCardRequestsIssued, issuedCardRequestsBRTPF, issuedCardRequestsSPARQL, issuedCardRequestsTPF

Constructor Summary

Constructors

Constructor	Description
BlockingFederationAccessManagerImpl(SPARQLRequestProcessor reqProcSPARQL, TPFRequestProcessor reqProcTPF, BRTPFRequestProcessor reqProcBRTPF, Neo4jRequestProcessor reqProcNeo4j)

Method Summary

Modifier and Type	Method	Description
protected FederationAccessStatsImpl	_getStats()
protected void	_resetStats()
CompletableFuture<TPFResponse>	issueRequest(BRTPFRequest req, BRTPFServer fm)
CompletableFuture<RecordsResponse>	issueRequest(Neo4jRequest req, Neo4jServer fm)
CompletableFuture<SolMapsResponse>	issueRequest(SPARQLRequest req, SPARQLEndpoint fm)
CompletableFuture<TPFResponse>	issueRequest(TPFRequest req, BRTPFServer fm)
CompletableFuture<TPFResponse>	issueRequest(TPFRequest req, TPFServer fm)

Methods inherited from class se.liu.ida.hefquin.engine.federation.access.impl.FederationAccessManagerBase1

getFctToObtainCardinalityResponseFromSolMapsResponse, getFctToObtainCardinalityResponseFromTPFResponse, getStats, issueCardinalityRequest, issueCardinalityRequest, issueCardinalityRequest, issueCardinalityRequest, resetStats

Methods inherited from class java.lang.Object

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

Field Details

counterSPARQLRequests

protected AtomicLong counterSPARQLRequests

counterTPFRequests

protected AtomicLong counterTPFRequests

counterBRTPFRequests

protected AtomicLong counterBRTPFRequests

counterNeo4jRequests

protected AtomicLong counterNeo4jRequests

Constructor Details

BlockingFederationAccessManagerImpl

public BlockingFederationAccessManagerImpl(SPARQLRequestProcessor reqProcSPARQL,
 TPFRequestProcessor reqProcTPF,
 BRTPFRequestProcessor reqProcBRTPF,
 Neo4jRequestProcessor reqProcNeo4j)

Method Details

issueRequest

public CompletableFuture<SolMapsResponse> issueRequest(SPARQLRequest req,
 SPARQLEndpoint fm)
                                                throws FederationAccessException

Throws:

FederationAccessException

issueRequest

public CompletableFuture<TPFResponse> issueRequest(TPFRequest req,
 TPFServer fm)
                                            throws FederationAccessException

Throws:

FederationAccessException

issueRequest

public CompletableFuture<TPFResponse> issueRequest(TPFRequest req,
 BRTPFServer fm)
                                            throws FederationAccessException

Throws:

FederationAccessException

issueRequest

public CompletableFuture<TPFResponse> issueRequest(BRTPFRequest req,
 BRTPFServer fm)
                                            throws FederationAccessException

Throws:

FederationAccessException

issueRequest

public CompletableFuture<RecordsResponse> issueRequest(Neo4jRequest req,
 Neo4jServer fm)
                                                throws FederationAccessException

Throws:

FederationAccessException

_resetStats

protected void _resetStats()

Specified by:

_resetStats in class FederationAccessManagerBase1

_getStats

protected FederationAccessStatsImpl _getStats()

Specified by:

_getStats in class FederationAccessManagerBase1