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
|
# Auto-generated, do not edit this file.
import re
# AMQP Protocol Frame Prefix
AMQP = b'AMQP'
# AMQP Protocol Version
VERSION = (0, 9, 1)
# RabbitMQ Defaults
DEFAULT_HOST = 'localhost'
DEFAULT_PORT = 5672
DEFAULT_USER = 'guest'
DEFAULT_PASS = 'guest'
DEFAULT_VHOST = '/'
# AMQP Constants
FRAME_METHOD = 1
FRAME_HEADER = 2
FRAME_BODY = 3
FRAME_HEARTBEAT = 8
FRAME_MIN_SIZE = 4096
FRAME_END = 206
# Indicates that the method completed successfully. This reply code is reserved
# for future use - the current protocol design does not use positive
# confirmation and reply codes are sent only in case of an error.
REPLY_SUCCESS = 200
# Not included in the spec XML or JSON files.
FRAME_END_CHAR = b'\xce'
FRAME_HEADER_SIZE = 7
FRAME_MAX_SIZE = 131072
# AMQP data types
DATA_TYPES = [
'bit', # single bit
'long', # 32-bit integer
'longlong', # 64-bit integer
'longstr', # long string
'octet', # single octet
'short', # 16-bit integer
'shortstr', # short string (max. 256 characters)
'table', # field table
'timestamp' # 64-bit timestamp
]
# AMQP domains
DOMAINS = {
'channel-id': 'longstr',
'class-id': 'short',
'consumer-tag': 'shortstr',
'delivery-tag': 'longlong',
'destination': 'shortstr',
'duration': 'longlong',
'exchange-name': 'shortstr',
'method-id': 'short',
'no-ack': 'bit',
'no-local': 'bit',
'offset': 'longlong',
'path': 'shortstr',
'peer-properties': 'table',
'queue-name': 'shortstr',
'redelivered': 'bit',
'reference': 'longstr',
'reject-code': 'short',
'reject-text': 'shortstr',
'reply-code': 'short',
'reply-text': 'shortstr',
'security-token': 'longstr'
}
# AMQP domain patterns
DOMAIN_REGEX = {
'exchange-name': re.compile(r'^[a-zA-Z0-9-_.:@#,/ ]*$'),
'queue-name': re.compile(r'^[a-zA-Z0-9-_.:@#,/ ]*$')
}
# Other constants
DEPRECATION_WARNING = 'This command is deprecated in AMQP 0-9-1'
|
