Onestep

- ✨ feat: Support assignment worker class mic1on
- ✨ feat: Broker support `cancel_consume` and `once` mic1on
- 🐞 fix: Throw DropMessage Error in job executed

- supports message bodies in any format nowanti mic1on
- [RedisBroker] add RedisBroker implement nowanti
- [RabbitMQ] can choose whether to create a queue mic1on
(sometimes queues are created in other ways)
- add unit tests mic1on

- `step`传参提示及类型注解
- 程序退出后自动清理任务
- 增加BaseLocalBroker中Queue的maxsize参数
- broker增加shutdown功能
mic1on

- 允许在中间件和任务中通过抛出`DropMessage`异常丢弃消息
- `before_receive`和`after_receive` => `before_consume`和`after_consume`
- 增加unique中间件
- 调整 `before_send` 触发时机，以运行对 `broker` 或 `result` 为 `None` 的情况进行中间件处理

14 mic1on