uamqp.constants — Azure SDK for Python 2.0.0 documentation

#-------------------------------------------------------------------------# Copyright (c) Microsoft Corporation. All rights reserved.# Licensed under the MIT License. See License.txt in the project root for# license information.#--------------------------------------------------------------------------from enum import Enumfrom uamqp import c_uamqpDEFAULT_AMQPS_PORT = 5671DEFAULT_AMQP_WSS_PORT = 443AUTH_EXPIRATION_SECS = c_uamqp.AUTH_EXPIRATION_SECSAUTH_REFRESH_SECS = c_uamqp.AUTH_REFRESH_SECSBATCH_MESSAGE_FORMAT = c_uamqp.AMQP_BATCH_MESSAGE_FORMATMAX_FRAME_SIZE_BYTES = c_uamqp.MAX_FRAME_SIZE_BYTESMAX_MESSAGE_LENGTH_BYTES = c_uamqp.MAX_MESSAGE_LENGTH_BYTESSTRING_FILTER = b"apache.org:selector-filter:string"OPERATION = b"operation"READ_OPERATION = b"READ"MGMT_TARGET = b"$management"# Deprecated - will be removed in future versionsMESSAGE_SEND_RETRIES = 3ERROR_CONNECTION_REDIRECT = b"amqp:connection:redirect"ERROR_LINK_REDIRECT = b"amqp:link:redirect"class MessageState(Enum): WaitingToBeSent = 0 WaitingForSendAck = 1 SendComplete = 2 SendFailed = 3 ReceivedUnsettled = 4 ReceivedSettled = 5DONE_STATES = (MessageState.SendComplete, MessageState.SendFailed)RECEIVE_STATES = (MessageState.ReceivedSettled, MessageState.ReceivedUnsettled)PENDING_STATES = (MessageState.WaitingForSendAck, MessageState.WaitingToBeSent)# Error Codesclass ErrorCodes(Enum): InternalServerError = b"amqp:internal-error" IllegalState = b"amqp:illegal-state" DecodeError = b"amqp:decode-error" NotFound = b"amqp:not-found" NotImplemented = b"amqp:not-implemented" NotAllowed = b"amqp:not-allowed" InvalidField = b"amqp:invalid-field" ResourceLocked = b"amqp:resource-locked" ResourceDeleted = b"amqp:resource-deleted" UnauthorizedAccess = b"amqp:unauthorized-access" FrameSizeTooSmall = b"amqp:frame-size-too-small" ResourceLimitExceeded = b"amqp:resource-limit-exceeded" PreconditionFailed = b"amqp:precondition-failed" ConnectionRedirect = b"amqp:connection:redirect" ConnectionCloseForced = b"amqp:connection:forced" ConnectionFramingError = b"amqp:connection:framing-error" SessionWindowViolation = b"amqp:session:window-violation" SessionErrantLink = b"amqp:session:errant-link" SessionHandleInUse = b"amqp:session:handle-in-use" SessionUnattachedHandle = b"amqp:session:unattached-handle" LinkRedirect = b"amqp:link:redirect" LinkStolen = b"amqp:link:stolen" LinkDetachForced = b"amqp:link:detach-forced" LinkTransferLimitExceeded = b"amqp:link:transfer-limit-exceeded" LinkMessageSizeExceeded = b"amqp:link:message-size-exceeded" ClientError = b"amqp:client-error" UnknownError = b"amqp:unknown-error" VendorError = b"amqp:vendor-error"class MessageReceiverState(Enum): Idle = c_uamqp.MESSAGE_RECEIVER_STATE_IDLE Opening = c_uamqp.MESSAGE_RECEIVER_STATE_OPENING Open = c_uamqp.MESSAGE_RECEIVER_STATE_OPEN Closing = c_uamqp.MESSAGE_RECEIVER_STATE_CLOSING Error = c_uamqp.MESSAGE_RECEIVER_STATE_ERRORclass MessageSendResult(Enum): Ok = c_uamqp.MESSAGE_SEND_OK Error = c_uamqp.MESSAGE_SEND_ERROR Timeout = c_uamqp.MESSAGE_SEND_TIMEOUT Cancelled = c_uamqp.MESSAGE_SEND_CANCELLEDclass MessageSenderState(Enum): Idle = c_uamqp.MESSAGE_SENDER_STATE_IDLE Opening = c_uamqp.MESSAGE_SENDER_STATE_OPENING Open = c_uamqp.MESSAGE_SENDER_STATE_OPEN Closing = c_uamqp.MESSAGE_SENDER_STATE_CLOSING Error = c_uamqp.MESSAGE_SENDER_STATE_ERRORclass ManagementLinkState(Enum): Ok = c_uamqp.AMQP_MANAGEMENT_OPEN_OK Error = c_uamqp.AMQP_MANAGEMENT_OPEN_ERROR Cancelled = c_uamqp.AMQP_MANAGEMENT_OPEN_CANCELLEDclass ManagementOperationResult(Enum): Ok = c_uamqp.AMQP_MANAGEMENT_EXECUTE_OPERATION_OK Error = c_uamqp.AMQP_MANAGEMENT_EXECUTE_OPERATION_ERROR BadStatus = c_uamqp.AMQP_MANAGEMENT_EXECUTE_OPERATION_FAILED_BAD_STATUS Closed = c_uamqp.AMQP_MANAGEMENT_EXECUTE_OPERATION_INSTANCE_CLOSEDclass Role(Enum): Sender = c_uamqp.ROLE_SENDER Receiver = c_uamqp.ROLE_RECEIVERclass SenderSettleMode(Enum): Unsettled = c_uamqp.SENDER_SETTLE_MODE_UNSETTLED Settled = c_uamqp.SENDER_SETTLE_MODE_SETTLED Mixed = c_uamqp.SENDER_SETTLE_MODE_MIXEDclass ReceiverSettleMode(Enum): PeekLock = c_uamqp.RECEIVER_SETTLE_MODE_PEEKLOCK ReceiveAndDelete = c_uamqp.RECEIVER_SETTLE_MODE_RECEIVEANDDELETEclass CBSOperationResult(Enum): Ok = c_uamqp.CBS_OPERATION_RESULT_OK Error = c_uamqp.CBS_OPERATION_RESULT_CBS_ERROR Failed = c_uamqp.CBS_OPERATION_RESULT_OPERATION_FAILED Closed = c_uamqp.CBS_OPERATION_RESULT_INSTANCE_CLOSEDclass CBSOpenState(Enum): Ok = c_uamqp.CBS_OPEN_COMPLETE_OK Error = c_uamqp.CBS_OPEN_COMPLETE_ERROR Cancelled = c_uamqp.CBS_OPEN_COMPLETE_CANCELLEDclass CBSAuthStatus(Enum): Ok = c_uamqp.AUTH_STATUS_OK Idle = c_uamqp.AUTH_STATUS_IDLE InProgress = c_uamqp.AUTH_STATUS_IN_PROGRESS Timeout = c_uamqp.AUTH_STATUS_TIMEOUT RefreshRequired = c_uamqp.AUTH_STATUS_REFRESH_REQUIRED Expired = c_uamqp.AUTH_STATUS_EXPIRED Error = c_uamqp.AUTH_STATUS_ERROR Failure = c_uamqp.AUTH_STATUS_FAILUREclass MgmtExecuteResult(Enum): Ok = c_uamqp.AMQP_MANAGEMENT_EXECUTE_OPERATION_OK Error = c_uamqp.AMQP_MANAGEMENT_EXECUTE_OPERATION_ERROR Failed = c_uamqp.AMQP_MANAGEMENT_EXECUTE_OPERATION_FAILED_BAD_STATUS Closed = c_uamqp.AMQP_MANAGEMENT_EXECUTE_OPERATION_INSTANCE_CLOSEDclass MgmtOpenStatus(Enum): Ok = c_uamqp.AMQP_MANAGEMENT_OPEN_OK Error = c_uamqp.AMQP_MANAGEMENT_OPEN_ERROR Cancelled = c_uamqp.AMQP_MANAGEMENT_OPEN_CANCELLED[docs]class TransportType(Enum): """Transport type The underlying transport protocol type: Amqp: AMQP over the default TCP transport protocol, it uses port 5671. AmqpOverWebsocket: Amqp over the Web Sockets transport protocol, it uses port 443. """ Amqp = 1 AmqpOverWebsocket = 2