Index

C D E F H I O P R S W
All Classes and Interfaces|All Packages

C

ChannelRouter - Class in software.spool.publisher.api.utils

Routes events to named channels based on their type.

ChannelRouter() - Constructor for class software.spool.publisher.api.utils.ChannelRouter

create() - Method in class software.spool.publisher.api.builder.PollingFeederBuilder

Builds and returns the configured polling Feeder.

create() - Method in class software.spool.publisher.api.builder.ReactiveFeederBuilder

Builds and returns the configured reactive Feeder.

D

defaults(EventBusEmitter) - Static method in class software.spool.publisher.api.utils.FeederErrorRouter

Creates the default error router for publisher operations.

E

each(Duration) - Method in class software.spool.publisher.api.builder.PollingFeederBuilder

Sets the polling interval.

F

Feeder - Class in software.spool.publisher.api

Main API entry point for the publishing lifecycle.

Feeder(FeederStrategy, ErrorRouter) - Constructor for class software.spool.publisher.api.Feeder

Creates a new Feeder with the given strategy and error router.

FeederBuilderFactory - Class in software.spool.publisher.api.builder

Factory entry point for creating pre-configured feeder builders.

FeederBuilderFactory() - Constructor for class software.spool.publisher.api.builder.FeederBuilderFactory

FeederErrorRouter - Class in software.spool.publisher.api.utils

Provides the default ErrorRouter configuration for the publisher.

FeederErrorRouter() - Constructor for class software.spool.publisher.api.utils.FeederErrorRouter

FeederStrategy - Interface in software.spool.publisher.api.strategy

Strategy interface that defines how the publisher discovers and processes inbox items.

findByStatus(InboxItemStatus) - Method in interface software.spool.publisher.api.port.InboxReader

Returns all inbox items matching the given status.

findByStatus(InboxItemStatus) - Method in class software.spool.publisher.internal.port.decorator.SafeInboxReader

from(EventBusListener) - Method in class software.spool.publisher.api.builder.ReactiveFeederBuilder

Sets the event bus listener the feeder subscribes to.

from(InboxReader) - Method in class software.spool.publisher.api.builder.PollingFeederBuilder

Sets the inbox reader for querying items by status.

H

handle(InboxItemStored) - Method in class software.spool.publisher.internal.control.InboxItemStoredHandler

I

InboxItemStoredHandler - Class in software.spool.publisher.internal.control

Handler that processes InboxItemStored events by updating the inbox item status through a publishing lifecycle.

InboxItemStoredHandler(InboxUpdater, EventBusEmitter, ErrorRouter) - Constructor for class software.spool.publisher.internal.control.InboxItemStoredHandler

Creates a new handler with the given ports.

InboxReader - Interface in software.spool.publisher.api.port

Port for reading inbox items by status.

O

of(InboxReader) - Static method in class software.spool.publisher.internal.port.decorator.SafeInboxReader

Creates a new SafeInboxReader wrapping the given delegate.

on(EventBusEmitter) - Method in class software.spool.publisher.api.builder.PollingFeederBuilder

Sets the event bus emitter for publishing ItemPublished events.

on(EventBusEmitter) - Method in class software.spool.publisher.api.builder.ReactiveFeederBuilder

Sets the event bus emitter for publishing ItemPublished events.

P

polling() - Static method in class software.spool.publisher.api.builder.FeederBuilderFactory

Creates a builder for a polling-based feeder.

PollingFeeder - Class in software.spool.publisher.api.strategy

Polling-based FeederStrategy that periodically reads inbox items with PUBLISHING status and processes them.

PollingFeeder(InboxReader, Handler<InboxItemStored>, Duration) - Constructor for class software.spool.publisher.api.strategy.PollingFeeder

Creates a new polling feeder.

PollingFeederBuilder - Class in software.spool.publisher.api.builder

Fluent builder that configures and assembles a polling-based Feeder.

R

reactive() - Static method in class software.spool.publisher.api.builder.FeederBuilderFactory

Creates a builder for a reactive (event-driven) feeder.

ReactiveFeeder - Class in software.spool.publisher.api.strategy

Reactive FeederStrategy that listens for InboxItemStored events on the event bus and processes each one immediately.

ReactiveFeeder(EventBusListener, Handler<InboxItemStored>) - Constructor for class software.spool.publisher.api.strategy.ReactiveFeeder

Creates a new reactive feeder.

ReactiveFeederBuilder - Class in software.spool.publisher.api.builder

Fluent builder that configures and assembles a reactive Feeder.

resolve(Event) - Method in class software.spool.publisher.api.utils.ChannelRouter

Resolves the channel for the given event.

route(Class<T>, String) - Method in class software.spool.publisher.api.utils.ChannelRouter

Registers a channel mapping for the given event type.

S

SafeInboxReader - Class in software.spool.publisher.internal.port.decorator

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

SafeInboxReader(InboxReader) - Constructor for class software.spool.publisher.internal.port.decorator.SafeInboxReader

software.spool.publisher.api - package software.spool.publisher.api

software.spool.publisher.api.builder - package software.spool.publisher.api.builder

software.spool.publisher.api.port - package software.spool.publisher.api.port

software.spool.publisher.api.strategy - package software.spool.publisher.api.strategy

software.spool.publisher.api.utils - package software.spool.publisher.api.utils

software.spool.publisher.internal.control - package software.spool.publisher.internal.control

software.spool.publisher.internal.port.decorator - package software.spool.publisher.internal.port.decorator

start() - Method in interface software.spool.publisher.api.strategy.FeederStrategy

Starts the strategy and returns a subscription that can be cancelled.

start() - Method in class software.spool.publisher.api.strategy.PollingFeeder

Starts a scheduled executor that polls the inbox at the configured interval.

start() - Method in class software.spool.publisher.api.strategy.ReactiveFeeder

Subscribes to InboxItemStored events on the event bus.

startPublishing() - Method in class software.spool.publisher.api.Feeder

Starts the publishing process.

stop() - Method in interface software.spool.publisher.api.strategy.FeederStrategy

Stops the strategy and returns a null subscription.

stopPublishing() - Method in class software.spool.publisher.api.Feeder

Stops the publishing process.

W

with(InboxUpdater) - Method in class software.spool.publisher.api.builder.PollingFeederBuilder

Sets the inbox updater used to change inbox item statuses.

with(InboxUpdater) - Method in class software.spool.publisher.api.builder.ReactiveFeederBuilder

Sets the inbox updater used to change inbox item statuses.

withErrorRouter(ErrorRouter) - Method in class software.spool.publisher.api.builder.PollingFeederBuilder

Sets the error router for handling exceptions during publishing.

withErrorRouter(ErrorRouter) - Method in class software.spool.publisher.api.builder.ReactiveFeederBuilder

Sets the error router for handling exceptions during publishing.

C D E F H I O P R S W
All Classes and Interfaces|All Packages