ErrorPolicy Class

Inheritance
builtins.object
ErrorPolicy

Constructor

ErrorPolicy(max_retries=3, on_error=None)

Parameters

Name Description
max_retries
default value: 3
on_error
default value: None

Methods

on_connection_error
on_link_error
on_message_error
on_unrecognized_error

on_connection_error

on_connection_error(error)

Parameters

Name Description
error
Required
on_link_error(error)

Parameters

Name Description
error
Required

on_message_error

on_message_error(error)

Parameters

Name Description
error
Required

on_unrecognized_error

on_unrecognized_error(error)

Parameters

Name Description
error
Required

Attributes

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'>)