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

Interface IPollingService

All Known Implementing Classes:
PollingService
public interface IPollingService

  • Method Details

    • enqueue

      void enqueue(ComplianceRepositoryReply reply)
      Add the given compliance reply to the queue.
      Parameters:
      reply - the reply to be added to the queue

    • hasQueuedEvents

      boolean hasQueuedEvents(UUID sagaEventId)
      Check if a given saga event id has related queued events.
      Parameters:
      sagaEventId - the id of the event
      Returns:
      true if there are queued events related to the saga event id, false otherwise

    • runQueuedEvents

      void runQueuedEvents(UUID sagaEventId) throws PollingServiceException
      Run all related queued events for a given saga event id.
      Parameters:
      sagaEventId - the id of the event
      Throws:
      PollingServiceException

    • runQueuedEvents

      void runQueuedEvents(UUID sagaEventId, String repositoryId) throws PollingServiceException
      Run all related queued events for a given saga event id and compliance repository id.
      Parameters:
      sagaEventId - the id of the event
      repositoryId - the id of the compliance repository
      Throws:
      PollingServiceException

    • runAllQueuedEvents

      void runAllQueuedEvents() throws PollingServiceException
      Run all pending queued events.
      Throws:
      PollingServiceException

    • resetQueuedEventTimeOut

      void resetQueuedEventTimeOut(UUID sagaEventId, String repositoryId)
      Reset the timeout of a queued event.
      Parameters:
      sagaEventId - the ID of the event
      repositoryId - the ID of the compliance repository

    • queuedEventHasTimedOut

      boolean queuedEventHasTimedOut(QueuedEvent queuedEvent)
      Check if a queued event has timed out.
      Parameters:
      queuedEvent - the queued event
      Returns:
      true if the queued event has timed out, false otherwise