Package com.persequor.saga.modules.id.service

Class IdRequestQueueService

java.lang.Object

com.persequor.saga.modules.id.service.IdRequestQueueService

public class IdRequestQueueService
extends Object

Constructor Summary

Constructors

Constructor	Description
IdRequestQueueService(IdModuleRequestRepository requestRepository, QueuedIdRequestRepository repository, com.persequor.extension.lock.ILockService lockService)

Method Summary

Modifier and Type	Method	Description
void	fail(QueuedIdRequest idQueue)
Optional<QueuedIdRequest>	getQueuedIdRequest(String issuerId, UUID sagaOrderId)
List<QueuedIdRequest>	getQueuedIdRequests(String issuerId)
void	purgeFromQueues(UUID sagaOrderId, String issuerId)
void	removeIdQueue(QueuedIdRequest idQueue)
void	saveQueuedIdRequest(QueuedIdRequest idQueue)
Optional<IdRequest>	unfailRequest(UUID sagaOrderId, String userOrderId)
void	wakeUp(String key)

Methods inherited from class java.lang.Object

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

Constructor Details

IdRequestQueueService

@Inject
public IdRequestQueueService(IdModuleRequestRepository requestRepository,
 QueuedIdRequestRepository repository,
 com.persequor.extension.lock.ILockService lockService)

Method Details

getQueuedIdRequests

public List<QueuedIdRequest> getQueuedIdRequests(String issuerId)

getQueuedIdRequest

public Optional<QueuedIdRequest> getQueuedIdRequest(String issuerId,
 UUID sagaOrderId)

saveQueuedIdRequest

public void saveQueuedIdRequest(QueuedIdRequest idQueue)

removeIdQueue

public void removeIdQueue(QueuedIdRequest idQueue)

wakeUp

public void wakeUp(String key)

fail

public void fail(QueuedIdRequest idQueue)

unfailRequest

public Optional<IdRequest> unfailRequest(UUID sagaOrderId,
 String userOrderId)

purgeFromQueues

public void purgeFromQueues(UUID sagaOrderId,
 String issuerId)