Package com.persequor.saga.modules.compliance.services

Class ComplianceStatusService

java.lang.Object

com.persequor.saga.modules.compliance.services.ComplianceStatusService

public class ComplianceStatusService
extends Object

Constructor Summary

Constructors

Constructor	Description
ComplianceStatusService(StorageService storageService, EventFetchingService eventFetchingService, javax.inject.Provider<ComplianceSubModuleService> subModuleService)

Method Summary

Modifier and Type	Method	Description
void	changeStatus(IComplianceServiceReply originalReply, MessageStatus newStatus, String message, ZonedDateTime replyTime)	Changes a compliance reply status, by creating a new reply with the new status, message and time.
ComplianceServiceReplyList	getAllStatuses(UUID sagaEventId)
ComplianceServiceReplyList	getAllStatuses(UUID sagaEventId, String complianceRepository)
Map<String,ComplianceServiceReplyList>	getAllStatusesMapped(UUID sagaEventId)
Map<UUID,Map<String,IComplianceServiceReply>>	getDominantComplianceReplies(Collection<UUID> sagaEventIds, List<String> regulations)
Map<UUID,Map<String,Map<String,IComplianceServiceReply>>>	getDominantComplianceRepliesByEventType(Collection<UUID> sagaEventIds, List<String> regulations)
Optional<IComplianceServiceReply>	getLatestStatus(UUID sagaEventId, String complianceRepository)
Optional<IComplianceServiceReply>	getLatestStatus(UUID sagaEventId, String complianceRepository, IMessageType messageType)
Optional<IComplianceServiceReply>	getLatestStatus(UUID sagaEventId, String complianceRepository, String messageType)
Optional<IComplianceServiceReply>	getLatestStatus(UUID sagaEventId, String complianceRepository, Set<IMessageType> messageTypes)
ComplianceServiceReplyList	getLatestStatuses(UUID sagaEventId)
Optional<ComplianceServiceReply>	getReply(UUID sagaEventId, String complianceRepository, String replyIdentifier)
Optional<ComplianceServiceReply>	getStatus(UUID sagaEventId, String complianceRepository, String replyIdentifier)	Deprecated. use getReply(UUID, String, String)
ComplianceServiceReplyList	searchAllByEventId(String eventId)
Map<String,ComplianceServiceReplyList>	searchAllByEventIdMapped(String eventId)
ComplianceServiceReplyList	searchByEventId(String eventId)
void	validateComplianceRepository(String complianceRepository)

Methods inherited from class java.lang.Object

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

Constructor Details

ComplianceStatusService

@Inject
public ComplianceStatusService(StorageService storageService,
 EventFetchingService eventFetchingService,
 javax.inject.Provider<ComplianceSubModuleService> subModuleService)

Method Details

validateComplianceRepository

public void validateComplianceRepository(String complianceRepository)

getStatus

public Optional<ComplianceServiceReply> getStatus(UUID sagaEventId,
 String complianceRepository,
 String replyIdentifier)

Deprecated.

use getReply(UUID, String, String)

getReply

public Optional<ComplianceServiceReply> getReply(UUID sagaEventId,
 String complianceRepository,
 String replyIdentifier)

changeStatus

public void changeStatus(IComplianceServiceReply originalReply,
 MessageStatus newStatus,
 String message,
 ZonedDateTime replyTime)

Changes a compliance reply status, by creating a new reply with the new status, message and time.

Parameters:

originalReply - The reply that needs to be changed.

newStatus - The new status

message - A mandatory message stating the reason why this change was done.

replyTime - The time of the new reply.

getLatestStatus

public Optional<IComplianceServiceReply> getLatestStatus(UUID sagaEventId,
 String complianceRepository,
 IMessageType messageType)

Refactor:

Rename to getMostDominantReply()

getLatestStatus

public Optional<IComplianceServiceReply> getLatestStatus(UUID sagaEventId,
 String complianceRepository,
 String messageType)

Refactor:

Rename to getMostDominantReply()

getLatestStatus

public Optional<IComplianceServiceReply> getLatestStatus(UUID sagaEventId,
 String complianceRepository,
 Set<IMessageType> messageTypes)

Refactor:

Rename to getMostDominantReply()

getLatestStatus

public Optional<IComplianceServiceReply> getLatestStatus(UUID sagaEventId,
 String complianceRepository)

Refactor:

Rename to getMostDominantReply()

getLatestStatuses

public ComplianceServiceReplyList getLatestStatuses(UUID sagaEventId)

Refactor:

Rename to getMostDominantPerMessageTypeAndRepository()

getAllStatuses

public ComplianceServiceReplyList getAllStatuses(UUID sagaEventId,
 String complianceRepository)

Refactor:

Rename to getReplies()

getAllStatuses

public ComplianceServiceReplyList getAllStatuses(UUID sagaEventId)

Refactor:

Rename to getReplies()

getAllStatusesMapped

public Map<String,ComplianceServiceReplyList> getAllStatusesMapped(UUID sagaEventId)

Refactor:

Rename to getRepliesByRepository()

searchByEventId

public ComplianceServiceReplyList searchByEventId(String eventId)

searchAllByEventId

public ComplianceServiceReplyList searchAllByEventId(String eventId)

searchAllByEventIdMapped

public Map<String,ComplianceServiceReplyList> searchAllByEventIdMapped(String eventId)

getDominantComplianceReplies

public Map<UUID,Map<String,IComplianceServiceReply>> getDominantComplianceReplies(Collection<UUID> sagaEventIds,
 List<String> regulations)

getDominantComplianceRepliesByEventType

public Map<UUID,Map<String,Map<String,IComplianceServiceReply>>> getDominantComplianceRepliesByEventType(Collection<UUID> sagaEventIds,
 List<String> regulations)