micro-module/saga
Composer 安装命令:
composer require micro-module/saga
包简介
Micro module Saga common library
README 文档
README
Micro-module saga extension library. Provides abstract saga base class, DBAL saga repository, and command dispatching infrastructure following the Dependency Inversion Principle.
Installation
composer require micro-module/saga
Dispatcher Interfaces
SagaCommandDispatcherInterface
Abstraction for dispatching commands from within sagas. Two implementations are provided:
SyncSagaCommandDispatcher— dispatches synchronously via TacticianCommandBusOutboxSagaCommandDispatcher— enqueues asynchronously viaSagaCommandQueueInterface
SagaCommandQueueInterface
Abstract queue contract. The saga package does NOT depend on outbox-bundle or any concrete queue implementation. The outbox package (or any other package) implements this interface and is wired via DI.
Dependency Inversion Diagram
saga package
┌───────────────────────────────────────────────┐
│ │
│ SagaCommandDispatcherInterface │
│ ▲ ▲ │
│ │ │ │
│ OutboxSaga- SyncSaga- │
│ CommandDispatcher CommandDispatcher │
│ │ │ │
│ SagaCommandQueueInterface CommandBus │
│ │ │ │
└──────────┼──────────────┼─────────────────────┘
│ │
┌──────────┼──────────────┼─────────────────────┐
│ │ │ outbox-bundle / │
│ OutboxAwareTaskProducer tactician-bundle │
│ implements SagaCommandQueueInterface │
└───────────────────────────────────────────────┘
Key rule: The arrow from OutboxAwareTaskProducer points TO the saga package interface — the saga package has zero dependency on the outbox package. This is the Dependency Inversion Principle in action.
Usage
Sync dispatch (Tactician)
// DI wiring $dispatcher = new SyncSagaCommandDispatcher($commandBus); $dispatcher->dispatch(new CreateNewsCommand($id));
Async dispatch via outbox (DIP)
// The queue implementation (OutboxAwareTaskProducer) lives in outbox-bundle // and implements SagaCommandQueueInterface. // Wire via DI alias — never hard-code the concrete class in your saga. $dispatcher = new OutboxSagaCommandDispatcher($queue); // $queue is SagaCommandQueueInterface $dispatcher->dispatch(new PublishNewsCommand($id)); // command must implement Serializable
Requirements
- PHP 8.0+
league/tactician^1.0micro-module/broadway^2.6 (providesBroadway\Serializer\Serializable)
统计信息
- 总下载量: 3.5k
- 月度下载量: 0
- 日度下载量: 0
- 收藏数: 0
- 点击次数: 1
- 依赖项目数: 3
- 推荐数: 0
其他信息
- 授权协议: proprietary
- 更新时间: 2020-04-24