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
|
-define(COMMAND_DECLARE_PUBLISHER, 0).
-define(COMMAND_PUBLISH, 1).
-define(COMMAND_PUBLISH_CONFIRM, 2).
-define(COMMAND_PUBLISH_ERROR, 3).
-define(COMMAND_QUERY_PUBLISHER_SEQUENCE, 4).
-define(COMMAND_DELETE_PUBLISHER, 5).
-define(COMMAND_SUBSCRIBE, 6).
-define(COMMAND_DELIVER, 7).
-define(COMMAND_CREDIT, 8).
-define(COMMAND_COMMIT_OFFSET, 9).
-define(COMMAND_QUERY_OFFSET, 10).
-define(COMMAND_UNSUBSCRIBE, 11).
-define(COMMAND_CREATE_STREAM, 12).
-define(COMMAND_DELETE_STREAM, 13).
-define(COMMAND_METADATA, 14).
-define(COMMAND_METADATA_UPDATE, 15).
-define(COMMAND_PEER_PROPERTIES, 16).
-define(COMMAND_SASL_HANDSHAKE, 17).
-define(COMMAND_SASL_AUTHENTICATE, 18).
-define(COMMAND_TUNE, 19).
-define(COMMAND_OPEN, 20).
-define(COMMAND_CLOSE, 21).
-define(COMMAND_HEARTBEAT, 22).
-define(VERSION_0, 0).
-define(RESPONSE_CODE_OK, 0).
-define(RESPONSE_CODE_STREAM_DOES_NOT_EXIST, 1).
-define(RESPONSE_CODE_SUBSCRIPTION_ID_ALREADY_EXISTS, 2).
-define(RESPONSE_CODE_SUBSCRIPTION_ID_DOES_NOT_EXIST, 3).
-define(RESPONSE_CODE_STREAM_ALREADY_EXISTS, 4).
-define(RESPONSE_CODE_STREAM_NOT_AVAILABLE, 5).
-define(RESPONSE_SASL_MECHANISM_NOT_SUPPORTED, 6).
-define(RESPONSE_AUTHENTICATION_FAILURE, 7).
-define(RESPONSE_SASL_ERROR, 8).
-define(RESPONSE_SASL_CHALLENGE, 9).
-define(RESPONSE_SASL_AUTHENTICATION_FAILURE_LOOPBACK, 10).
-define(RESPONSE_VHOST_ACCESS_FAILURE, 11).
-define(RESPONSE_CODE_UNKNOWN_FRAME, 12).
-define(RESPONSE_CODE_FRAME_TOO_LARGE, 13).
-define(RESPONSE_CODE_INTERNAL_ERROR, 14).
-define(RESPONSE_CODE_ACCESS_REFUSED, 15).
-define(RESPONSE_CODE_PRECONDITION_FAILED, 16).
-define(RESPONSE_CODE_PUBLISHER_DOES_NOT_EXIST, 17).
-define(OFFSET_TYPE_FIRST, 0).
-define(OFFSET_TYPE_LAST, 1).
-define(OFFSET_TYPE_NEXT, 2).
-define(OFFSET_TYPE_OFFSET, 3).
-define(OFFSET_TYPE_TIMESTAMP, 4).
-define(DEFAULT_INITIAL_CREDITS, 50000).
-define(DEFAULT_CREDITS_REQUIRED_FOR_UNBLOCKING, 12500).
-define(DEFAULT_FRAME_MAX, 1048576). %% 1 MiB
-define(DEFAULT_HEARTBEAT, 60). %% 60 seconds
-define(INFO_ITEMS,
[conn_name,
port,
peer_port,
host,
peer_host,
user,
vhost,
subscriptions,
connection_state,
auth_mechanism,
heartbeat,
frame_max,
client_properties,
connected_at
]).
-define(STREAM_GUIDE_URL, <<"https://rabbitmq.com/stream.html">>).
|
