1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
|
#-------------------------------------------------------------------------
# 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
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
class MessageBodyType(Enum):
"""AMQP message body type
The body of an amqp message consists of either: one or more data sections, one or more amqp-sequence sections,
or a single amqp-value section:
`DataType`: The body consists of one or more data sections and each section contains opaque binary data.
`SequenceType`: The body consists of one or more sequence sections and each section contains an arbitrary
number of structured data elements.
`ValueType`: The body consists of one amqp-value section and the section contains a single AMQP value.
Please refer to the AMQP spec:
http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#section-message-format
for further information on the message body type.
"""
Data = c_uamqp.MessageBodyType.DataType
Value = c_uamqp.MessageBodyType.ValueType
Sequence = c_uamqp.MessageBodyType.SequenceType
BODY_TYPE_C_PYTHON_MAP = {
c_uamqp.MessageBodyType.DataType.value: MessageBodyType.Data,
c_uamqp.MessageBodyType.SequenceType.value: MessageBodyType.Sequence,
c_uamqp.MessageBodyType.ValueType.value: MessageBodyType.Value
}
|
