ErrorPolicy 类
- 继承
-
builtins.objectErrorPolicy
构造函数
ErrorPolicy(max_retries=3, on_error=None)参数
- max_retries
默认值: 3
- on_error
默认值: None
方法
| on_connection_error | |
| on_link_error | |
| on_message_error | |
| on_unrecognized_error |
on_connection_error
on_connection_error(error)参数
- error
必需
on_link_error
on_link_error(error)参数
- error
必需
on_message_error
on_message_error(error)参数
- error
必需
on_unrecognized_error
on_unrecognized_error(error)参数
- error
必需
属性
no_retry
no_retry = (<ErrorCodes.DecodeError: b'amqp:decode-error'>, <ErrorCodes.LinkMessageSizeExceeded: b'amqp:link:message-size-exceeded'>, <ErrorCodes.NotFound: b'amqp:not-found'>, <ErrorCodes.NotImplemented: b'amqp:not-implemented'>, <ErrorCodes.LinkRedirect: b'amqp:link:redirect'>, <ErrorCodes.NotAllowed: b'amqp:not-allowed'>, <ErrorCodes.UnauthorizedAccess: b'amqp:unauthorized-access'>, <ErrorCodes.LinkStolen: b'amqp:link:stolen'>, <ErrorCodes.ResourceLimitExceeded: b'amqp:resource-limit-exceeded'>, <ErrorCodes.ConnectionRedirect: b'amqp:connection:redirect'>, <ErrorCodes.PreconditionFailed: b'amqp:precondition-failed'>, <ErrorCodes.InvalidField: b'amqp:invalid-field'>, <ErrorCodes.ResourceDeleted: b'amqp:resource-deleted'>, <ErrorCodes.IllegalState: b'amqp:illegal-state'>, <ErrorCodes.FrameSizeTooSmall: b'amqp:frame-size-too-small'>, <ErrorCodes.ConnectionFramingError: b'amqp:connection:framing-error'>, <ErrorCodes.SessionUnattachedHandle: b'amqp:session:unattached-handle'>, <ErrorCodes.SessionHandleInUse: b'amqp:session:handle-in-use'>, <ErrorCodes.SessionErrantLink: b'amqp:session:errant-link'>, <ErrorCodes.SessionWindowViolation: b'amqp:session:window-violation'>)