Skip to content

Commit

Permalink
🐞 fix: @catch_error -> @catch_error()
Browse files Browse the repository at this point in the history
  • Loading branch information
nowanti committed Apr 27, 2023
1 parent e29d6fd commit 9ba28b7
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[tool.poetry]
name = "onestep"
version = "0.1.79"
version = "0.1.80"
description = ""
authors = ["miclon <jcnd@163.com>"]
readme = "README.md"
Expand Down
6 changes: 3 additions & 3 deletions src/onestep/message.py
Original file line number Diff line number Diff line change
Expand Up @@ -111,17 +111,17 @@ def to_dict(self, include_exception=False) -> dict:
def to_json(self, include_exception=False) -> str:
return json.dumps(self.to_dict(include_exception))

@catch_error
@catch_error()
def confirm(self):
"""确认消息"""
self.broker.confirm(self)

@catch_error
@catch_error()
def reject(self):
"""拒绝消息"""
self.broker.reject(self)

@catch_error
@catch_error()
def requeue(self, is_source=False):
"""
重发消息:先拒绝 再 重入
Expand Down

0 comments on commit 9ba28b7

Please sign in to comment.