Package com.persequor.extension.issue

Interface IIssueService

public interface IIssueService

  • Method Details

    • get

      Stream<Issue> get(UUID... ids)
      Fetch issues by IDs
      Parameters:
      ids - used to find issues
      Returns:
      issues found

    • deleteByIds

      void deleteByIds(UUID... ids)
      Deletes issues from saga based on issue IDs
      Parameters:
      ids - to be deleted

    • search

      Stream<Issue> search(IIssueService.SearchRequest searchRequest)
      Searches for issues based on different criteria
      Parameters:
      searchRequest - search
      Returns:
      issues found

    • replay

      void replay(Stream<Issue> issues)
      Replays stream of issues to the corresponding original queues. In case re-enqueueing succeeded the issue is deleted from the SAGA issue database.
      Parameters:
      issues - to be replayed

    • getOne

      default Optional<Issue> getOne(UUID id)

    • deleteByIds

      default void deleteByIds(Collection<UUID> ids)

    • delete

      default void delete(Issue... issues)

    • delete

      default void delete(Collection<Issue> issues)

    • raise

      void raise(@Nonnull String failedReason, @Nonnull String issueDetails)
      Raises a new issue programmatically.

      Issues raised in this manner will go through the normal issue handling hooks, but will not go through any delay queues. If any of the pre-persist hooks return re-enqueue, the issue will instead be persisted and a warning will be emitted.

      Issues raised in this manner cannot have a topic provided, and therefore cannot be retried/replayed.

      Parameters:
      failedReason - the reason for the issue, must be one of the ones registered in IFailedReasonRegistry
      issueDetails - the details of the issue

    • raise

      void raise(@Nonnull String failedReason, @Nonnull String issueDetails, @Nullable AdditionalData additionalData)
      Raises a new issue programmatically.

      Issues raised in this manner will go through the normal issue handling hooks, but will not go through any delay queues. If any of the pre-persist hooks return re-enqueue, the issue will instead be persisted and a warning will be emitted.

      Issues raised in this manner cannot have a topic provided, and therefore cannot be retried/replayed.

      Parameters:
      failedReason - the reason for the issue, must be one of the ones registered in IFailedReasonRegistry
      issueDetails - the details of the issue
      additionalData - any additional data to be stored with the issue