Package software.spool.publisher.internal.port.decorator

Class SafeInboxReader

java.lang.Object

software.spool.publisher.internal.port.decorator.SafeInboxReader

All Implemented Interfaces:

InboxReader

public class SafeInboxReader
extends Object
implements InboxReader

Decorator for InboxReader that normalises unchecked exceptions into typed InboxReadException instances.

If the delegate throws a SpoolException subclass, it is re-thrown as-is. Any other Exception is wrapped in a new InboxReadException.

Constructor Summary

Constructors

Constructor	Description
SafeInboxReader(InboxReader reader)

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.
static SafeInboxReader	of(InboxReader reader)	Creates a new SafeInboxReader wrapping the given delegate.

Methods inherited from class java.lang.Object

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

Constructor Details

SafeInboxReader

public SafeInboxReader(InboxReader reader)

Method Details

findByStatus

public Stream<software.spool.core.model.InboxItem> findByStatus(software.spool.core.model.InboxItemStatus status)

Description copied from interface: InboxReader

Returns all inbox items matching the given status.

Specified by:

findByStatus in interface InboxReader

Parameters:

status - the status to filter by; must not be null

Returns:

a stream of matching inbox items

of

public static SafeInboxReader of(InboxReader reader)

Creates a new SafeInboxReader wrapping the given delegate.

Parameters:

reader - the reader to wrap; must not be null

Returns:

a new SafeInboxReader instance