Class BlockingFederationAccessManagerImpl

java.lang.Object

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

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

se.liu.ida.hefquin.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.federation.access.impl.FederationAccessManagerBase1

FederationAccessManagerBase1.FunctionToObtainCardinalityResponseFromSolMapsResponse, FederationAccessManagerBase1.FunctionToObtainCardinalityResponseFromTPFResponse

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicLong	counterBRTPFRequests
protected AtomicLong	counterOtherRequests
protected AtomicLong	counterRequests
protected AtomicLong	counterSPARQLRequests
protected AtomicLong	counterTPFRequests

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

reqProcBRTPF, reqProcSPARQL, reqProcTPF

Fields inherited from class se.liu.ida.hefquin.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, RESTRequestProcessor reqProcREST)

Method Summary

Modifier and Type	Method	Description
protected FederationAccessStatsImpl	_getStats()
protected void	_resetStats()
<ReqType extends DataRetrievalRequest, RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember> CompletableFuture<RespType>	issueRequest(ReqType req, MemberType fm)
void	shutdown()	Shuts down all thread pools associated with this federation access manager.

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

getReqProc

Methods inherited from class se.liu.ida.hefquin.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

counterOtherRequests

protected AtomicLong counterOtherRequests

counterRequests

protected AtomicLong counterRequests

Constructor Details

BlockingFederationAccessManagerImpl

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

Method Details

issueRequest

public <ReqType extends DataRetrievalRequest,
RespType extends DataRetrievalResponse<?>,
MemberType extends FederationMember>
CompletableFuture<RespType> issueRequest(ReqType req,
 MemberType 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

shutdown

public void shutdown()

Description copied from interface: FederationAccessManager

Shuts down all thread pools associated with this federation access manager.