Releases: mic1on/onestep
Releases · mic1on/onestep
0.3.22
🐞 fix: `body` not in message
0.3.3a1
- 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
0.3.2
@step
传参提示及类型注解
- 程序退出后自动清理任务
- 增加BaseLocalBroker中Queue的maxsize参数
- broker增加shutdown功能
@mic1on
0.3.1
- 允许在中间件和任务中通过抛出
DropMessage
异常丢弃消息
before_receive
和after_receive
=> before_consume
和after_consume
- 增加unique中间件
- 调整
before_send
触发时机,以运行对 broker
或 result
为 None
的情况进行中间件处理
#14 @mic1on
0.2.0
🦄 refactor: use common rabbitmq component
0.1.80
🐞 fix: @catch_error -> @catch_error()