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 Enum from uamqp import c_uamqp DEFAULT_AMQPS_PORT = 5671 DEFAULT_AMQP_WSS_PORT = 443 AUTH_EXPIRATION_SECS = c_uamqp.AUTH_EXPIRATION_SECS AUTH_REFRESH_SECS = c_uamqp.AUTH_REFRESH_SECS BATCH_MESSAGE_FORMAT = c_uamqp.AMQP_BATCH_MESSAGE_FORMAT MAX_FRAME_SIZE_BYTES = c_uamqp.MAX_FRAME_SIZE_BYTES MAX_MESSAGE_LENGTH_BYTES = c_uamqp.MAX_MESSAGE_LENGTH_BYTES STRING_FILTER = b"apache.org:selector-filter:string" OPERATION = b"operation" READ_OPERATION = b"READ" MGMT_TARGET = b"$management" # Deprecated - will be removed in future versions MESSAGE_SEND_RETRIES = 3 ERROR_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 = 5 DONE_STATES = (MessageState.SendComplete, MessageState.SendFailed) RECEIVE_STATES = (MessageState.ReceivedSettled, MessageState.ReceivedUnsettled) PENDING_STATES = (MessageState.WaitingForSendAck, MessageState.WaitingToBeSent) # Error Codes class 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_ERROR class 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_CANCELLED class 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_ERROR class ManagementLinkState(Enum): Ok = c_uamqp.AMQP_MANAGEMENT_OPEN_OK Error = c_uamqp.AMQP_MANAGEMENT_OPEN_ERROR Cancelled = c_uamqp.AMQP_MANAGEMENT_OPEN_CANCELLED class 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_CLOSED class Role(Enum): Sender = c_uamqp.ROLE_SENDER Receiver = c_uamqp.ROLE_RECEIVER class SenderSettleMode(Enum): Unsettled = c_uamqp.SENDER_SETTLE_MODE_UNSETTLED Settled = c_uamqp.SENDER_SETTLE_MODE_SETTLED Mixed = c_uamqp.SENDER_SETTLE_MODE_MIXED class ReceiverSettleMode(Enum): PeekLock = c_uamqp.RECEIVER_SETTLE_MODE_PEEKLOCK ReceiveAndDelete = c_uamqp.RECEIVER_SETTLE_MODE_RECEIVEANDDELETE class 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_CLOSED class CBSOpenState(Enum): Ok = c_uamqp.CBS_OPEN_COMPLETE_OK Error = c_uamqp.CBS_OPEN_COMPLETE_ERROR Cancelled = c_uamqp.CBS_OPEN_COMPLETE_CANCELLED class 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_FAILURE class 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_CLOSED class 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 

ncG1vNJzZmiZqqq%2Fpr%2FDpJuom6Njr627wWeaqKqVY8SqusOorqxmnprBcHDWnploqKmptbC6jpqxrqqVYsCmvtWimp6apah8cXqUaWVsZ4%2BivKXBy56qaK2Ror6xe8KopayskaPBtHrHraSl