rocketmq_client_v4/protocols/
request_code.rs

1pub const SEND_MESSAGE: i16 = 10;
2pub const PULL_MESSAGE: i16 = 11;
3
4pub const QUERY_MESSAGE: i16 = 12;
5pub const QUERY_BROKER_OFFSET: i16 = 13;
6pub const QUERY_CONSUMER_OFFSET: i16 = 14;
7pub const UPDATE_CONSUMER_OFFSET: i16 = 15;
8pub const UPDATE_AND_CREATE_TOPIC: i16 = 17;
9pub const GET_ALL_TOPIC_CONFIG: i16 = 21;
10pub const GET_TOPIC_CONFIG_LIST: i16 = 22;
11
12pub const GET_TOPIC_NAME_LIST: i16 = 23;
13
14pub const UPDATE_BROKER_CONFIG: i16 = 25;
15
16pub const GET_BROKER_CONFIG: i16 = 26;
17
18pub const TRIGGER_DELETE_FILES: i16 = 27;
19
20pub const GET_BROKER_RUNTIME_INFO: i16 = 28;
21pub const SEARCH_OFFSET_BY_TIMESTAMP: i16 = 29;
22pub const GET_MAX_OFFSET: i16 = 30;
23pub const GET_MIN_OFFSET: i16 = 31;
24
25pub const GET_EARLIEST_MSG_STORE_TIME: i16 = 32;
26
27pub const VIEW_MESSAGE_BY_ID: i16 = 33;
28
29pub const HEART_BEAT: i16 = 34;
30
31pub const UNREGISTER_CLIENT: i16 = 35;
32
33pub const CONSUMER_SEND_MSG_BACK: i16 = 36;
34
35pub const END_TRANSACTION: i16 = 37;
36pub const GET_CONSUMER_LIST_BY_GROUP: i16 = 38;
37
38pub const CHECK_TRANSACTION_STATE: i16 = 39;
39
40pub const NOTIFY_CONSUMER_IDS_CHANGED: i16 = 40;
41
42pub const LOCK_BATCH_MQ: i16 = 41;
43
44pub const UNLOCK_BATCH_MQ: i16 = 42;
45pub const GET_ALL_CONSUMER_OFFSET: i16 = 43;
46
47pub const GET_ALL_DELAY_OFFSET: i16 = 45;
48
49pub const CHECK_CLIENT_CONFIG: i16 = 46;
50
51pub const PUT_KV_CONFIG: i16 = 100;
52
53pub const GET_KV_CONFIG: i16 = 101;
54
55pub const DELETE_KV_CONFIG: i16 = 102;
56
57pub const REGISTER_BROKER: i16 = 103;
58
59pub const UNREGISTER_BROKER: i16 = 104;
60pub const GET_ROUTE_BY_TOPIC: i16 = 105;
61
62pub const GET_BROKER_CLUSTER_INFO: i16 = 106;
63pub const UPDATE_AND_CREATE_SUBSCRIPTION_GROUP: i16 = 200;
64pub const GET_ALL_SUBSCRIPTION_GROUP_CONFIG: i16 = 201;
65pub const GET_TOPIC_STATS_INFO: i16 = 202;
66pub const GET_CONSUMER_CONNECTION_LIST: i16 = 203;
67pub const GET_PRODUCER_CONNECTION_LIST: i16 = 204;
68pub const WIPE_WRITE_PERM_OF_BROKER: i16 = 205;
69
70pub const GET_ALL_TOPIC_LIST_FROM_NAMESERVER: i16 = 206;
71
72pub const DELETE_SUBSCRIPTION_GROUP: i16 = 207;
73pub const GET_CONSUME_STATS: i16 = 208;
74
75pub const SUSPEND_CONSUMER: i16 = 209;
76
77pub const RESUME_CONSUMER: i16 = 210;
78pub const RESET_CONSUMER_OFFSET_IN_CONSUMER: i16 = 211;
79pub const RESET_CONSUMER_OFFSET_IN_BROKER: i16 = 212;
80
81pub const ADJUST_CONSUMER_THREAD_POOL: i16 = 213;
82
83pub const WHO_CONSUME_THE_MESSAGE: i16 = 214;
84
85pub const DELETE_TOPIC_IN_BROKER: i16 = 215;
86
87pub const DELETE_TOPIC_IN_NAME_SRV: i16 = 216;
88pub const GET_KV_LIST_BY_NAMESPACE: i16 = 219;
89
90pub const RESET_CONSUMER_CLIENT_OFFSET: i16 = 220;
91
92pub const GET_CONSUMER_STATUS_FROM_CLIENT: i16 = 221;
93
94pub const INVOKE_BROKER_TO_RESET_OFFSET: i16 = 222;
95
96pub const INVOKE_BROKER_TO_GET_CONSUMER_STATUS: i16 = 223;
97
98pub const QUERY_TOPIC_CONSUME_BY_WHO: i16 = 300;
99
100pub const GET_TOPICS_BY_CLUSTER: i16 = 224;
101
102pub const REGISTER_FILTER_SERVER: i16 = 301;
103pub const REGISTER_MESSAGE_FILTER_CLASS: i16 = 302;
104
105pub const QUERY_CONSUME_TIME_SPAN: i16 = 303;
106
107pub const GET_SYSTEM_TOPIC_LIST_FROM_NS: i16 = 304;
108pub const GET_SYSTEM_TOPIC_LIST_FROM_BROKER: i16 = 305;
109
110pub const CLEAN_EXPIRED_CONSUME_QUEUE: i16 = 306;
111
112pub const GET_CONSUMER_RUNNING_INFO: i16 = 307;
113
114pub const QUERY_CORRECTION_OFFSET: i16 = 308;
115pub const CONSUME_MESSAGE_DIRECTLY: i16 = 309;
116
117pub const SEND_MESSAGE_V2: i16 = 310;
118
119pub const GET_UNIT_TOPIC_LIST: i16 = 311;
120
121pub const GET_HAS_UNIT_SUB_TOPIC_LIST: i16 = 312;
122
123pub const GET_HAS_UNIT_SUB_UN_UNIT_TOPIC_LIST: i16 = 313;
124
125pub const CLONE_GROUP_OFFSET: i16 = 314;
126
127pub const VIEW_BROKER_STATS_DATA: i16 = 315;
128
129pub const CLEAN_UNUSED_TOPIC: i16 = 316;
130
131pub const GET_BROKER_CONSUME_STATS: i16 = 317;
132
133/**
134 * update the config of name server
135 */
136pub const UPDATE_NAME_SRV_CONFIG: i16 = 318;
137
138/**
139 * get config from name server
140 */
141pub const GET_NAME_SRV_CONFIG: i16 = 319;
142
143pub const SEND_BATCH_MESSAGE: i16 = 320;
144
145pub const QUERY_CONSUME_QUEUE: i16 = 321;
146
147pub const QUERY_DATA_VERSION: i16 = 322;
rocketmq_client_v4/protocols/request_code.rs

rocketmq_client_v4/protocols/
request_code.rs
