Package com.persequor.saga.modules.compliance.subscription

Class PollingService

java.lang.Object

com.persequor.saga.modules.compliance.subscription.PollingService

All Implemented Interfaces:

IPollingService

public class PollingService
extends Object
implements IPollingService

Constructor Summary

Constructors

Constructor

Description

PollingService(IQueueEventRepository repository, ExtraDetailsSerializer serializer, javax.inject.Provider<ComplianceRepositoryReply> replyProvider, StorageService storageService, com.persequor.extension.eventservice.IEventService eventService, com.persequor.extension.lock.ILockService lockService, ComplianceModuleConfig config, com.persequor.extension.util.Dates dates, List<IPollingAdapter> adapters, List<IPollingHooks> hooks)

Method Summary

Modifier and Type	Method	Description
void	enqueue(ComplianceRepositoryReply reply)	Add the given compliance reply to the queue.
boolean	hasQueuedEvents(UUID sagaEventId)	Check if a given saga event id has related queued events.
boolean	queuedEventHasTimedOut(QueuedEvent queuedEvent)	Check if a queued event has timed out.
void	resetQueuedEventTimeOut(UUID sagaEventId, String repositoryId)	Reset the timeout of a queued event.
void	runAllQueuedEvents()	Run all pending queued events.
void	runQueuedEvents(UUID sagaEventId)	Run all related queued events for a given saga event id.
void	runQueuedEvents(UUID sagaEventId, String repositoryId)	Run all related queued events for a given saga event id and compliance repository id.

Methods inherited from class java.lang.Object

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

Constructor Details

PollingService

@Inject
public PollingService(IQueueEventRepository repository,
 ExtraDetailsSerializer serializer,
 javax.inject.Provider<ComplianceRepositoryReply> replyProvider,
 StorageService storageService,
 com.persequor.extension.eventservice.IEventService eventService,
 com.persequor.extension.lock.ILockService lockService,
 ComplianceModuleConfig config,
 com.persequor.extension.util.Dates dates,
 List<IPollingAdapter> adapters,
 List<IPollingHooks> hooks)

Method Details

enqueue

public void enqueue(ComplianceRepositoryReply reply)

Description copied from interface: IPollingService

Add the given compliance reply to the queue.

Specified by:

enqueue in interface IPollingService

Parameters:

reply - the reply to be added to the queue

hasQueuedEvents

public boolean hasQueuedEvents(UUID sagaEventId)

Description copied from interface: IPollingService

Check if a given saga event id has related queued events.

Specified by:

hasQueuedEvents in interface IPollingService

Parameters:

sagaEventId - the id of the event

Returns:

true if there are queued events related to the saga event id, false otherwise

runQueuedEvents

public void runQueuedEvents(UUID sagaEventId)
                     throws PollingServiceException

Description copied from interface: IPollingService

Run all related queued events for a given saga event id.

Specified by:

runQueuedEvents in interface IPollingService

Parameters:

sagaEventId - the id of the event

Throws:

PollingServiceException

runQueuedEvents

public void runQueuedEvents(UUID sagaEventId,
 String repositoryId)
                     throws PollingServiceException

Description copied from interface: IPollingService

Run all related queued events for a given saga event id and compliance repository id.

Specified by:

runQueuedEvents in interface IPollingService

Parameters:

sagaEventId - the id of the event

repositoryId - the id of the compliance repository

Throws:

PollingServiceException

runAllQueuedEvents

public void runAllQueuedEvents()

Description copied from interface: IPollingService

Run all pending queued events.

Specified by:

runAllQueuedEvents in interface IPollingService

queuedEventHasTimedOut

public boolean queuedEventHasTimedOut(QueuedEvent queuedEvent)

Description copied from interface: IPollingService

Check if a queued event has timed out.

Specified by:

queuedEventHasTimedOut in interface IPollingService

Parameters:

queuedEvent - the queued event

Returns:

true if the queued event has timed out, false otherwise

resetQueuedEventTimeOut

public void resetQueuedEventTimeOut(UUID sagaEventId,
 String repositoryId)

Description copied from interface: IPollingService

Reset the timeout of a queued event.

Specified by:

resetQueuedEventTimeOut in interface IPollingService

Parameters:

sagaEventId - the ID of the event

repositoryId - the ID of the compliance repository