Package software.spool.publisher.api.port

Interface InboxReader

All Known Implementing Classes:
SafeInboxReader
public interface InboxReader
Port for reading inbox items by status.

Implement this interface to connect the publisher to your inbox storage backend (database, in-memory store, etc.). The polling feeder calls findByStatus(InboxItemStatus) periodically to discover items ready for publishing.

  • Method Summary

    Modifier and Type
    Method
    Description
    Stream<software.spool.core.model.InboxItem>
    findByStatus(software.spool.core.model.InboxItemStatus status)
    Returns all inbox items matching the given status.

  • Method Details

    • findByStatus

      Stream<software.spool.core.model.InboxItem> findByStatus(software.spool.core.model.InboxItemStatus status) throws software.spool.core.exception.InboxReadException
      Returns all inbox items matching the given status.
      Parameters:
      status - the status to filter by; must not be null
      Returns:
      a stream of matching inbox items
      Throws:
      software.spool.core.exception.InboxReadException - if the query fails