Class MarketPriceFetchRequestService

java.lang.Object

com.bluebell.greenhouse.radicle.services.AbstractGenericEntityService<MarketPriceFetchRequest, MarketPriceFetchRequestRepository>

com.bluebell.greenhouse.radicle.services.market.price.MarketPriceFetchRequestService

@Service
@Transactional(readOnly=true)
public class MarketPriceFetchRequestService
extends AbstractGenericEntityService<MarketPriceFetchRequest, MarketPriceFetchRequestRepository>

Service-layer for MarketPriceFetchRequest.

Version:

3.0.6

Author:

Stephen Prizio

Constructor Summary

Constructors

Constructor	Description
MarketPriceFetchRequestService(MarketPriceFetchRequestRepository marketPriceFetchRequestRepository)	Creates the service.

Method Summary

Modifier and Type	Method	Description
List<MarketPriceFetchRequest>	claimPendingRequests(int batchSize)	Claims a batch of pending requests for background resolution.
void	markFailed(MarketPriceFetchRequest request, String error)	Marks a request as failed.
void	markResolved(MarketPriceFetchRequest request)	Marks a request as resolved.
void	markUnresolvable(MarketPriceFetchRequest request, String error)	Marks a request as unresolvable.
MarketPriceFetchRequest	queueRequest(SymbolAlias symbolAlias, DataSource dataSource, MarketTimeInterval timeInterval, LocalDateTime start, LocalDateTime end, String requestedByFlow)	Queues a market price fetch request when no active matching request already exists.

Methods inherited from class AbstractGenericEntityService

refreshEntity, resolveEntity, resolveEntity, resolveEntity

Methods inherited from class Object

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

Constructor Details

MarketPriceFetchRequestService

public MarketPriceFetchRequestService(MarketPriceFetchRequestRepository marketPriceFetchRequestRepository)

Creates the service.

Parameters:

marketPriceFetchRequestRepository - MarketPriceFetchRequestRepository

Method Details

queueRequest

@Transactional
public MarketPriceFetchRequest queueRequest(SymbolAlias symbolAlias,
 DataSource dataSource,
 MarketTimeInterval timeInterval,
 LocalDateTime start,
 LocalDateTime end,
 String requestedByFlow)

Queues a market price fetch request when no active matching request already exists.

Parameters:

symbolAlias - SymbolAlias

dataSource - DataSource

timeInterval - MarketTimeInterval

start - request start

end - request end

requestedByFlow - calling flow

Returns:

persisted or reused MarketPriceFetchRequest

claimPendingRequests

@Transactional
public List<MarketPriceFetchRequest> claimPendingRequests(int batchSize)

Claims a batch of pending requests for background resolution.

Parameters:

batchSize - batch size

Returns:

claimed List of MarketPriceFetchRequest

markResolved

@Transactional
public void markResolved(MarketPriceFetchRequest request)

Marks a request as resolved.

Parameters:

request - MarketPriceFetchRequest

markFailed

@Transactional
public void markFailed(MarketPriceFetchRequest request,
 String error)

Marks a request as failed.

Parameters:

request - MarketPriceFetchRequest

error - error message

markUnresolvable

@Transactional
public void markUnresolvable(MarketPriceFetchRequest request,
 String error)

Marks a request as unresolvable.

Parameters:

request - MarketPriceFetchRequest

error - reason