rabbitmq-c
C AMQP Client library for RabbitMQ
 All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
amqp_framing.h
1 /* Generated code. Do not edit. Edit and re-run codegen.py instead.
2  *
3  * ***** BEGIN LICENSE BLOCK *****
4  * Version: MIT
5  *
6  * Portions created by Alan Antonuk are Copyright (c) 2012-2013
7  * Alan Antonuk. All Rights Reserved.
8  *
9  * Portions created by VMware are Copyright (c) 2007-2012 VMware, Inc.
10  * All Rights Reserved.
11  *
12  * Portions created by Tony Garnock-Jones are Copyright (c) 2009-2010
13  * VMware, Inc. and Tony Garnock-Jones. All Rights Reserved.
14  *
15  * Permission is hereby granted, free of charge, to any person
16  * obtaining a copy of this software and associated documentation
17  * files (the "Software"), to deal in the Software without
18  * restriction, including without limitation the rights to use, copy,
19  * modify, merge, publish, distribute, sublicense, and/or sell copies
20  * of the Software, and to permit persons to whom the Software is
21  * furnished to do so, subject to the following conditions:
22  *
23  * The above copyright notice and this permission notice shall be
24  * included in all copies or substantial portions of the Software.
25  *
26  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
27  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
28  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
29  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
30  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
31  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
32  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
33  * SOFTWARE.
34  * ***** END LICENSE BLOCK *****
35  */
36 
37 #ifndef AMQP_FRAMING_H
38 #define AMQP_FRAMING_H
39 
40 #include <amqp.h>
41 
42 AMQP_BEGIN_DECLS
43 
44 #define AMQP_PROTOCOL_VERSION_MAJOR 0
45 #define AMQP_PROTOCOL_VERSION_MINOR 9
46 #define AMQP_PROTOCOL_VERSION_REVISION 1
47 #define AMQP_PROTOCOL_PORT 5672
48 #define AMQP_FRAME_METHOD 1
49 #define AMQP_FRAME_HEADER 2
50 #define AMQP_FRAME_BODY 3
51 #define AMQP_FRAME_HEARTBEAT 8
52 #define AMQP_FRAME_MIN_SIZE 4096
53 #define AMQP_FRAME_END 206
54 #define AMQP_REPLY_SUCCESS 200
55 #define AMQP_CONTENT_TOO_LARGE 311
56 #define AMQP_NO_ROUTE 312
57 #define AMQP_NO_CONSUMERS 313
58 #define AMQP_ACCESS_REFUSED 403
59 #define AMQP_NOT_FOUND 404
60 #define AMQP_RESOURCE_LOCKED 405
61 #define AMQP_PRECONDITION_FAILED 406
62 #define AMQP_CONNECTION_FORCED 320
63 #define AMQP_INVALID_PATH 402
64 #define AMQP_FRAME_ERROR 501
65 #define AMQP_SYNTAX_ERROR 502
66 #define AMQP_COMMAND_INVALID 503
67 #define AMQP_CHANNEL_ERROR 504
68 #define AMQP_UNEXPECTED_FRAME 505
69 #define AMQP_RESOURCE_ERROR 506
70 #define AMQP_NOT_ALLOWED 530
71 #define AMQP_NOT_IMPLEMENTED 540
72 #define AMQP_INTERNAL_ERROR 541
73 
74 /* Function prototypes. */
75 
76 AMQP_PUBLIC_FUNCTION
77 char const *
78 AMQP_CALL amqp_constant_name(int constantNumber);
79 
80 AMQP_PUBLIC_FUNCTION
82 AMQP_CALL amqp_constant_is_hard_error(int constantNumber);
83 
84 AMQP_PUBLIC_FUNCTION
85 char const *
86 AMQP_CALL amqp_method_name(amqp_method_number_t methodNumber);
87 
88 AMQP_PUBLIC_FUNCTION
90 AMQP_CALL amqp_method_has_content(amqp_method_number_t methodNumber);
91 
92 AMQP_PUBLIC_FUNCTION
93 int
94 AMQP_CALL amqp_decode_method(amqp_method_number_t methodNumber,
95  amqp_pool_t *pool,
96  amqp_bytes_t encoded,
97  void **decoded);
98 
99 AMQP_PUBLIC_FUNCTION
100 int
101 AMQP_CALL amqp_decode_properties(uint16_t class_id,
102  amqp_pool_t *pool,
103  amqp_bytes_t encoded,
104  void **decoded);
105 
106 AMQP_PUBLIC_FUNCTION
107 int
108 AMQP_CALL amqp_encode_method(amqp_method_number_t methodNumber,
109  void *decoded,
110  amqp_bytes_t encoded);
111 
112 AMQP_PUBLIC_FUNCTION
113 int
114 AMQP_CALL amqp_encode_properties(uint16_t class_id,
115  void *decoded,
116  amqp_bytes_t encoded);
117 
118 /* Method field records. */
119 
120 #define AMQP_CONNECTION_START_METHOD ((amqp_method_number_t) 0x000A000A) /* 10, 10; 655370 */
121 typedef struct amqp_connection_start_t_ {
122  uint8_t version_major;
123  uint8_t version_minor;
124  amqp_table_t server_properties;
125  amqp_bytes_t mechanisms;
126  amqp_bytes_t locales;
128 
129 #define AMQP_CONNECTION_START_OK_METHOD ((amqp_method_number_t) 0x000A000B) /* 10, 11; 655371 */
130 typedef struct amqp_connection_start_ok_t_ {
131  amqp_table_t client_properties;
132  amqp_bytes_t mechanism;
133  amqp_bytes_t response;
134  amqp_bytes_t locale;
136 
137 #define AMQP_CONNECTION_SECURE_METHOD ((amqp_method_number_t) 0x000A0014) /* 10, 20; 655380 */
138 typedef struct amqp_connection_secure_t_ {
139  amqp_bytes_t challenge;
141 
142 #define AMQP_CONNECTION_SECURE_OK_METHOD ((amqp_method_number_t) 0x000A0015) /* 10, 21; 655381 */
143 typedef struct amqp_connection_secure_ok_t_ {
144  amqp_bytes_t response;
146 
147 #define AMQP_CONNECTION_TUNE_METHOD ((amqp_method_number_t) 0x000A001E) /* 10, 30; 655390 */
148 typedef struct amqp_connection_tune_t_ {
149  uint16_t channel_max;
150  uint32_t frame_max;
151  uint16_t heartbeat;
153 
154 #define AMQP_CONNECTION_TUNE_OK_METHOD ((amqp_method_number_t) 0x000A001F) /* 10, 31; 655391 */
155 typedef struct amqp_connection_tune_ok_t_ {
156  uint16_t channel_max;
157  uint32_t frame_max;
158  uint16_t heartbeat;
160 
161 #define AMQP_CONNECTION_OPEN_METHOD ((amqp_method_number_t) 0x000A0028) /* 10, 40; 655400 */
162 typedef struct amqp_connection_open_t_ {
163  amqp_bytes_t virtual_host;
164  amqp_bytes_t capabilities;
165  amqp_boolean_t insist;
167 
168 #define AMQP_CONNECTION_OPEN_OK_METHOD ((amqp_method_number_t) 0x000A0029) /* 10, 41; 655401 */
169 typedef struct amqp_connection_open_ok_t_ {
170  amqp_bytes_t known_hosts;
172 
173 #define AMQP_CONNECTION_CLOSE_METHOD ((amqp_method_number_t) 0x000A0032) /* 10, 50; 655410 */
174 typedef struct amqp_connection_close_t_ {
175  uint16_t reply_code;
176  amqp_bytes_t reply_text;
177  uint16_t class_id;
178  uint16_t method_id;
180 
181 #define AMQP_CONNECTION_CLOSE_OK_METHOD ((amqp_method_number_t) 0x000A0033) /* 10, 51; 655411 */
182 typedef struct amqp_connection_close_ok_t_ {
183  char dummy; /* Dummy field to avoid empty struct */
185 
186 #define AMQP_CHANNEL_OPEN_METHOD ((amqp_method_number_t) 0x0014000A) /* 20, 10; 1310730 */
187 typedef struct amqp_channel_open_t_ {
188  amqp_bytes_t out_of_band;
190 
191 #define AMQP_CHANNEL_OPEN_OK_METHOD ((amqp_method_number_t) 0x0014000B) /* 20, 11; 1310731 */
192 typedef struct amqp_channel_open_ok_t_ {
193  amqp_bytes_t channel_id;
195 
196 #define AMQP_CHANNEL_FLOW_METHOD ((amqp_method_number_t) 0x00140014) /* 20, 20; 1310740 */
197 typedef struct amqp_channel_flow_t_ {
198  amqp_boolean_t active;
200 
201 #define AMQP_CHANNEL_FLOW_OK_METHOD ((amqp_method_number_t) 0x00140015) /* 20, 21; 1310741 */
202 typedef struct amqp_channel_flow_ok_t_ {
203  amqp_boolean_t active;
205 
206 #define AMQP_CHANNEL_CLOSE_METHOD ((amqp_method_number_t) 0x00140028) /* 20, 40; 1310760 */
207 typedef struct amqp_channel_close_t_ {
208  uint16_t reply_code;
209  amqp_bytes_t reply_text;
210  uint16_t class_id;
211  uint16_t method_id;
213 
214 #define AMQP_CHANNEL_CLOSE_OK_METHOD ((amqp_method_number_t) 0x00140029) /* 20, 41; 1310761 */
215 typedef struct amqp_channel_close_ok_t_ {
216  char dummy; /* Dummy field to avoid empty struct */
218 
219 #define AMQP_ACCESS_REQUEST_METHOD ((amqp_method_number_t) 0x001E000A) /* 30, 10; 1966090 */
220 typedef struct amqp_access_request_t_ {
221  amqp_bytes_t realm;
222  amqp_boolean_t exclusive;
223  amqp_boolean_t passive;
224  amqp_boolean_t active;
225  amqp_boolean_t write;
226  amqp_boolean_t read;
228 
229 #define AMQP_ACCESS_REQUEST_OK_METHOD ((amqp_method_number_t) 0x001E000B) /* 30, 11; 1966091 */
230 typedef struct amqp_access_request_ok_t_ {
231  uint16_t ticket;
233 
234 #define AMQP_EXCHANGE_DECLARE_METHOD ((amqp_method_number_t) 0x0028000A) /* 40, 10; 2621450 */
235 typedef struct amqp_exchange_declare_t_ {
236  uint16_t ticket;
237  amqp_bytes_t exchange;
238  amqp_bytes_t type;
239  amqp_boolean_t passive;
240  amqp_boolean_t durable;
241  amqp_boolean_t auto_delete;
242  amqp_boolean_t internal;
243  amqp_boolean_t nowait;
244  amqp_table_t arguments;
246 
247 #define AMQP_EXCHANGE_DECLARE_OK_METHOD ((amqp_method_number_t) 0x0028000B) /* 40, 11; 2621451 */
248 typedef struct amqp_exchange_declare_ok_t_ {
249  char dummy; /* Dummy field to avoid empty struct */
251 
252 #define AMQP_EXCHANGE_DELETE_METHOD ((amqp_method_number_t) 0x00280014) /* 40, 20; 2621460 */
253 typedef struct amqp_exchange_delete_t_ {
254  uint16_t ticket;
255  amqp_bytes_t exchange;
256  amqp_boolean_t if_unused;
257  amqp_boolean_t nowait;
259 
260 #define AMQP_EXCHANGE_DELETE_OK_METHOD ((amqp_method_number_t) 0x00280015) /* 40, 21; 2621461 */
261 typedef struct amqp_exchange_delete_ok_t_ {
262  char dummy; /* Dummy field to avoid empty struct */
264 
265 #define AMQP_EXCHANGE_BIND_METHOD ((amqp_method_number_t) 0x0028001E) /* 40, 30; 2621470 */
266 typedef struct amqp_exchange_bind_t_ {
267  uint16_t ticket;
268  amqp_bytes_t destination;
269  amqp_bytes_t source;
270  amqp_bytes_t routing_key;
271  amqp_boolean_t nowait;
272  amqp_table_t arguments;
274 
275 #define AMQP_EXCHANGE_BIND_OK_METHOD ((amqp_method_number_t) 0x0028001F) /* 40, 31; 2621471 */
276 typedef struct amqp_exchange_bind_ok_t_ {
277  char dummy; /* Dummy field to avoid empty struct */
279 
280 #define AMQP_EXCHANGE_UNBIND_METHOD ((amqp_method_number_t) 0x00280028) /* 40, 40; 2621480 */
281 typedef struct amqp_exchange_unbind_t_ {
282  uint16_t ticket;
283  amqp_bytes_t destination;
284  amqp_bytes_t source;
285  amqp_bytes_t routing_key;
286  amqp_boolean_t nowait;
287  amqp_table_t arguments;
289 
290 #define AMQP_EXCHANGE_UNBIND_OK_METHOD ((amqp_method_number_t) 0x00280033) /* 40, 51; 2621491 */
291 typedef struct amqp_exchange_unbind_ok_t_ {
292  char dummy; /* Dummy field to avoid empty struct */
294 
295 #define AMQP_QUEUE_DECLARE_METHOD ((amqp_method_number_t) 0x0032000A) /* 50, 10; 3276810 */
296 typedef struct amqp_queue_declare_t_ {
297  uint16_t ticket;
298  amqp_bytes_t queue;
299  amqp_boolean_t passive;
300  amqp_boolean_t durable;
301  amqp_boolean_t exclusive;
302  amqp_boolean_t auto_delete;
303  amqp_boolean_t nowait;
304  amqp_table_t arguments;
306 
307 #define AMQP_QUEUE_DECLARE_OK_METHOD ((amqp_method_number_t) 0x0032000B) /* 50, 11; 3276811 */
308 typedef struct amqp_queue_declare_ok_t_ {
309  amqp_bytes_t queue;
310  uint32_t message_count;
311  uint32_t consumer_count;
313 
314 #define AMQP_QUEUE_BIND_METHOD ((amqp_method_number_t) 0x00320014) /* 50, 20; 3276820 */
315 typedef struct amqp_queue_bind_t_ {
316  uint16_t ticket;
317  amqp_bytes_t queue;
318  amqp_bytes_t exchange;
319  amqp_bytes_t routing_key;
320  amqp_boolean_t nowait;
321  amqp_table_t arguments;
323 
324 #define AMQP_QUEUE_BIND_OK_METHOD ((amqp_method_number_t) 0x00320015) /* 50, 21; 3276821 */
325 typedef struct amqp_queue_bind_ok_t_ {
326  char dummy; /* Dummy field to avoid empty struct */
328 
329 #define AMQP_QUEUE_PURGE_METHOD ((amqp_method_number_t) 0x0032001E) /* 50, 30; 3276830 */
330 typedef struct amqp_queue_purge_t_ {
331  uint16_t ticket;
332  amqp_bytes_t queue;
333  amqp_boolean_t nowait;
335 
336 #define AMQP_QUEUE_PURGE_OK_METHOD ((amqp_method_number_t) 0x0032001F) /* 50, 31; 3276831 */
337 typedef struct amqp_queue_purge_ok_t_ {
338  uint32_t message_count;
340 
341 #define AMQP_QUEUE_DELETE_METHOD ((amqp_method_number_t) 0x00320028) /* 50, 40; 3276840 */
342 typedef struct amqp_queue_delete_t_ {
343  uint16_t ticket;
344  amqp_bytes_t queue;
345  amqp_boolean_t if_unused;
346  amqp_boolean_t if_empty;
347  amqp_boolean_t nowait;
349 
350 #define AMQP_QUEUE_DELETE_OK_METHOD ((amqp_method_number_t) 0x00320029) /* 50, 41; 3276841 */
351 typedef struct amqp_queue_delete_ok_t_ {
352  uint32_t message_count;
354 
355 #define AMQP_QUEUE_UNBIND_METHOD ((amqp_method_number_t) 0x00320032) /* 50, 50; 3276850 */
356 typedef struct amqp_queue_unbind_t_ {
357  uint16_t ticket;
358  amqp_bytes_t queue;
359  amqp_bytes_t exchange;
360  amqp_bytes_t routing_key;
361  amqp_table_t arguments;
363 
364 #define AMQP_QUEUE_UNBIND_OK_METHOD ((amqp_method_number_t) 0x00320033) /* 50, 51; 3276851 */
365 typedef struct amqp_queue_unbind_ok_t_ {
366  char dummy; /* Dummy field to avoid empty struct */
368 
369 #define AMQP_BASIC_QOS_METHOD ((amqp_method_number_t) 0x003C000A) /* 60, 10; 3932170 */
370 typedef struct amqp_basic_qos_t_ {
371  uint32_t prefetch_size;
372  uint16_t prefetch_count;
373  amqp_boolean_t global;
375 
376 #define AMQP_BASIC_QOS_OK_METHOD ((amqp_method_number_t) 0x003C000B) /* 60, 11; 3932171 */
377 typedef struct amqp_basic_qos_ok_t_ {
378  char dummy; /* Dummy field to avoid empty struct */
380 
381 #define AMQP_BASIC_CONSUME_METHOD ((amqp_method_number_t) 0x003C0014) /* 60, 20; 3932180 */
382 typedef struct amqp_basic_consume_t_ {
383  uint16_t ticket;
384  amqp_bytes_t queue;
385  amqp_bytes_t consumer_tag;
386  amqp_boolean_t no_local;
387  amqp_boolean_t no_ack;
388  amqp_boolean_t exclusive;
389  amqp_boolean_t nowait;
390  amqp_table_t arguments;
392 
393 #define AMQP_BASIC_CONSUME_OK_METHOD ((amqp_method_number_t) 0x003C0015) /* 60, 21; 3932181 */
394 typedef struct amqp_basic_consume_ok_t_ {
395  amqp_bytes_t consumer_tag;
397 
398 #define AMQP_BASIC_CANCEL_METHOD ((amqp_method_number_t) 0x003C001E) /* 60, 30; 3932190 */
399 typedef struct amqp_basic_cancel_t_ {
400  amqp_bytes_t consumer_tag;
401  amqp_boolean_t nowait;
403 
404 #define AMQP_BASIC_CANCEL_OK_METHOD ((amqp_method_number_t) 0x003C001F) /* 60, 31; 3932191 */
405 typedef struct amqp_basic_cancel_ok_t_ {
406  amqp_bytes_t consumer_tag;
408 
409 #define AMQP_BASIC_PUBLISH_METHOD ((amqp_method_number_t) 0x003C0028) /* 60, 40; 3932200 */
410 typedef struct amqp_basic_publish_t_ {
411  uint16_t ticket;
412  amqp_bytes_t exchange;
413  amqp_bytes_t routing_key;
414  amqp_boolean_t mandatory;
415  amqp_boolean_t immediate;
417 
418 #define AMQP_BASIC_RETURN_METHOD ((amqp_method_number_t) 0x003C0032) /* 60, 50; 3932210 */
419 typedef struct amqp_basic_return_t_ {
420  uint16_t reply_code;
421  amqp_bytes_t reply_text;
422  amqp_bytes_t exchange;
423  amqp_bytes_t routing_key;
425 
426 #define AMQP_BASIC_DELIVER_METHOD ((amqp_method_number_t) 0x003C003C) /* 60, 60; 3932220 */
427 typedef struct amqp_basic_deliver_t_ {
428  amqp_bytes_t consumer_tag;
429  uint64_t delivery_tag;
430  amqp_boolean_t redelivered;
431  amqp_bytes_t exchange;
432  amqp_bytes_t routing_key;
434 
435 #define AMQP_BASIC_GET_METHOD ((amqp_method_number_t) 0x003C0046) /* 60, 70; 3932230 */
436 typedef struct amqp_basic_get_t_ {
437  uint16_t ticket;
438  amqp_bytes_t queue;
439  amqp_boolean_t no_ack;
441 
442 #define AMQP_BASIC_GET_OK_METHOD ((amqp_method_number_t) 0x003C0047) /* 60, 71; 3932231 */
443 typedef struct amqp_basic_get_ok_t_ {
444  uint64_t delivery_tag;
445  amqp_boolean_t redelivered;
446  amqp_bytes_t exchange;
447  amqp_bytes_t routing_key;
448  uint32_t message_count;
450 
451 #define AMQP_BASIC_GET_EMPTY_METHOD ((amqp_method_number_t) 0x003C0048) /* 60, 72; 3932232 */
452 typedef struct amqp_basic_get_empty_t_ {
453  amqp_bytes_t cluster_id;
455 
456 #define AMQP_BASIC_ACK_METHOD ((amqp_method_number_t) 0x003C0050) /* 60, 80; 3932240 */
457 typedef struct amqp_basic_ack_t_ {
458  uint64_t delivery_tag;
459  amqp_boolean_t multiple;
461 
462 #define AMQP_BASIC_REJECT_METHOD ((amqp_method_number_t) 0x003C005A) /* 60, 90; 3932250 */
463 typedef struct amqp_basic_reject_t_ {
464  uint64_t delivery_tag;
465  amqp_boolean_t requeue;
467 
468 #define AMQP_BASIC_RECOVER_ASYNC_METHOD ((amqp_method_number_t) 0x003C0064) /* 60, 100; 3932260 */
469 typedef struct amqp_basic_recover_async_t_ {
470  amqp_boolean_t requeue;
472 
473 #define AMQP_BASIC_RECOVER_METHOD ((amqp_method_number_t) 0x003C006E) /* 60, 110; 3932270 */
474 typedef struct amqp_basic_recover_t_ {
475  amqp_boolean_t requeue;
477 
478 #define AMQP_BASIC_RECOVER_OK_METHOD ((amqp_method_number_t) 0x003C006F) /* 60, 111; 3932271 */
479 typedef struct amqp_basic_recover_ok_t_ {
480  char dummy; /* Dummy field to avoid empty struct */
482 
483 #define AMQP_BASIC_NACK_METHOD ((amqp_method_number_t) 0x003C0078) /* 60, 120; 3932280 */
484 typedef struct amqp_basic_nack_t_ {
485  uint64_t delivery_tag;
486  amqp_boolean_t multiple;
487  amqp_boolean_t requeue;
489 
490 #define AMQP_TX_SELECT_METHOD ((amqp_method_number_t) 0x005A000A) /* 90, 10; 5898250 */
491 typedef struct amqp_tx_select_t_ {
492  char dummy; /* Dummy field to avoid empty struct */
494 
495 #define AMQP_TX_SELECT_OK_METHOD ((amqp_method_number_t) 0x005A000B) /* 90, 11; 5898251 */
496 typedef struct amqp_tx_select_ok_t_ {
497  char dummy; /* Dummy field to avoid empty struct */
499 
500 #define AMQP_TX_COMMIT_METHOD ((amqp_method_number_t) 0x005A0014) /* 90, 20; 5898260 */
501 typedef struct amqp_tx_commit_t_ {
502  char dummy; /* Dummy field to avoid empty struct */
504 
505 #define AMQP_TX_COMMIT_OK_METHOD ((amqp_method_number_t) 0x005A0015) /* 90, 21; 5898261 */
506 typedef struct amqp_tx_commit_ok_t_ {
507  char dummy; /* Dummy field to avoid empty struct */
509 
510 #define AMQP_TX_ROLLBACK_METHOD ((amqp_method_number_t) 0x005A001E) /* 90, 30; 5898270 */
511 typedef struct amqp_tx_rollback_t_ {
512  char dummy; /* Dummy field to avoid empty struct */
514 
515 #define AMQP_TX_ROLLBACK_OK_METHOD ((amqp_method_number_t) 0x005A001F) /* 90, 31; 5898271 */
516 typedef struct amqp_tx_rollback_ok_t_ {
517  char dummy; /* Dummy field to avoid empty struct */
519 
520 #define AMQP_CONFIRM_SELECT_METHOD ((amqp_method_number_t) 0x0055000A) /* 85, 10; 5570570 */
521 typedef struct amqp_confirm_select_t_ {
522  amqp_boolean_t nowait;
524 
525 #define AMQP_CONFIRM_SELECT_OK_METHOD ((amqp_method_number_t) 0x0055000B) /* 85, 11; 5570571 */
526 typedef struct amqp_confirm_select_ok_t_ {
527  char dummy; /* Dummy field to avoid empty struct */
529 
530 /* Class property records. */
531 #define AMQP_CONNECTION_CLASS (0x000A) /* 10 */
532 typedef struct amqp_connection_properties_t_ {
533  amqp_flags_t _flags;
534  char dummy; /* Dummy field to avoid empty struct */
536 
537 #define AMQP_CHANNEL_CLASS (0x0014) /* 20 */
538 typedef struct amqp_channel_properties_t_ {
539  amqp_flags_t _flags;
540  char dummy; /* Dummy field to avoid empty struct */
542 
543 #define AMQP_ACCESS_CLASS (0x001E) /* 30 */
544 typedef struct amqp_access_properties_t_ {
545  amqp_flags_t _flags;
546  char dummy; /* Dummy field to avoid empty struct */
548 
549 #define AMQP_EXCHANGE_CLASS (0x0028) /* 40 */
550 typedef struct amqp_exchange_properties_t_ {
551  amqp_flags_t _flags;
552  char dummy; /* Dummy field to avoid empty struct */
554 
555 #define AMQP_QUEUE_CLASS (0x0032) /* 50 */
556 typedef struct amqp_queue_properties_t_ {
557  amqp_flags_t _flags;
558  char dummy; /* Dummy field to avoid empty struct */
560 
561 #define AMQP_BASIC_CLASS (0x003C) /* 60 */
562 #define AMQP_BASIC_CONTENT_TYPE_FLAG (1 << 15)
563 #define AMQP_BASIC_CONTENT_ENCODING_FLAG (1 << 14)
564 #define AMQP_BASIC_HEADERS_FLAG (1 << 13)
565 #define AMQP_BASIC_DELIVERY_MODE_FLAG (1 << 12)
566 #define AMQP_BASIC_PRIORITY_FLAG (1 << 11)
567 #define AMQP_BASIC_CORRELATION_ID_FLAG (1 << 10)
568 #define AMQP_BASIC_REPLY_TO_FLAG (1 << 9)
569 #define AMQP_BASIC_EXPIRATION_FLAG (1 << 8)
570 #define AMQP_BASIC_MESSAGE_ID_FLAG (1 << 7)
571 #define AMQP_BASIC_TIMESTAMP_FLAG (1 << 6)
572 #define AMQP_BASIC_TYPE_FLAG (1 << 5)
573 #define AMQP_BASIC_USER_ID_FLAG (1 << 4)
574 #define AMQP_BASIC_APP_ID_FLAG (1 << 3)
575 #define AMQP_BASIC_CLUSTER_ID_FLAG (1 << 2)
576 typedef struct amqp_basic_properties_t_ {
577  amqp_flags_t _flags;
578  amqp_bytes_t content_type;
579  amqp_bytes_t content_encoding;
580  amqp_table_t headers;
581  uint8_t delivery_mode;
582  uint8_t priority;
583  amqp_bytes_t correlation_id;
584  amqp_bytes_t reply_to;
585  amqp_bytes_t expiration;
586  amqp_bytes_t message_id;
587  uint64_t timestamp;
588  amqp_bytes_t type;
589  amqp_bytes_t user_id;
590  amqp_bytes_t app_id;
591  amqp_bytes_t cluster_id;
593 
594 #define AMQP_TX_CLASS (0x005A) /* 90 */
595 typedef struct amqp_tx_properties_t_ {
596  amqp_flags_t _flags;
597  char dummy; /* Dummy field to avoid empty struct */
599 
600 #define AMQP_CONFIRM_CLASS (0x0055) /* 85 */
601 typedef struct amqp_confirm_properties_t_ {
602  amqp_flags_t _flags;
603  char dummy; /* Dummy field to avoid empty struct */
605 
606 /* API functions for methods */
607 
608 AMQP_PUBLIC_FUNCTION amqp_channel_open_ok_t * AMQP_CALL amqp_channel_open(amqp_connection_state_t state, amqp_channel_t channel);
609 AMQP_PUBLIC_FUNCTION amqp_channel_flow_ok_t * AMQP_CALL amqp_channel_flow(amqp_connection_state_t state, amqp_channel_t channel, amqp_boolean_t active);
610 AMQP_PUBLIC_FUNCTION amqp_exchange_declare_ok_t * AMQP_CALL amqp_exchange_declare(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t exchange, amqp_bytes_t type, amqp_boolean_t passive, amqp_boolean_t durable, amqp_table_t arguments);
611 AMQP_PUBLIC_FUNCTION amqp_exchange_delete_ok_t * AMQP_CALL amqp_exchange_delete(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t exchange, amqp_boolean_t if_unused);
612 AMQP_PUBLIC_FUNCTION amqp_exchange_bind_ok_t * AMQP_CALL amqp_exchange_bind(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t destination, amqp_bytes_t source, amqp_bytes_t routing_key, amqp_table_t arguments);
613 AMQP_PUBLIC_FUNCTION amqp_exchange_unbind_ok_t * AMQP_CALL amqp_exchange_unbind(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t destination, amqp_bytes_t source, amqp_bytes_t routing_key, amqp_table_t arguments);
614 AMQP_PUBLIC_FUNCTION amqp_queue_declare_ok_t * AMQP_CALL amqp_queue_declare(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_boolean_t passive, amqp_boolean_t durable, amqp_boolean_t exclusive, amqp_boolean_t auto_delete, amqp_table_t arguments);
615 AMQP_PUBLIC_FUNCTION amqp_queue_bind_ok_t * AMQP_CALL amqp_queue_bind(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_bytes_t exchange, amqp_bytes_t routing_key, amqp_table_t arguments);
616 AMQP_PUBLIC_FUNCTION amqp_queue_purge_ok_t * AMQP_CALL amqp_queue_purge(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue);
617 AMQP_PUBLIC_FUNCTION amqp_queue_delete_ok_t * AMQP_CALL amqp_queue_delete(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_boolean_t if_unused, amqp_boolean_t if_empty);
618 AMQP_PUBLIC_FUNCTION amqp_queue_unbind_ok_t * AMQP_CALL amqp_queue_unbind(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_bytes_t exchange, amqp_bytes_t routing_key, amqp_table_t arguments);
619 AMQP_PUBLIC_FUNCTION amqp_basic_qos_ok_t * AMQP_CALL amqp_basic_qos(amqp_connection_state_t state, amqp_channel_t channel, uint32_t prefetch_size, uint16_t prefetch_count, amqp_boolean_t global);
620 AMQP_PUBLIC_FUNCTION amqp_basic_consume_ok_t * AMQP_CALL amqp_basic_consume(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_bytes_t consumer_tag, amqp_boolean_t no_local, amqp_boolean_t no_ack, amqp_boolean_t exclusive, amqp_table_t arguments);
621 AMQP_PUBLIC_FUNCTION amqp_basic_cancel_ok_t * AMQP_CALL amqp_basic_cancel(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t consumer_tag);
622 AMQP_PUBLIC_FUNCTION amqp_basic_recover_ok_t * AMQP_CALL amqp_basic_recover(amqp_connection_state_t state, amqp_channel_t channel, amqp_boolean_t requeue);
623 AMQP_PUBLIC_FUNCTION amqp_tx_select_ok_t * AMQP_CALL amqp_tx_select(amqp_connection_state_t state, amqp_channel_t channel);
624 AMQP_PUBLIC_FUNCTION amqp_tx_commit_ok_t * AMQP_CALL amqp_tx_commit(amqp_connection_state_t state, amqp_channel_t channel);
625 AMQP_PUBLIC_FUNCTION amqp_tx_rollback_ok_t * AMQP_CALL amqp_tx_rollback(amqp_connection_state_t state, amqp_channel_t channel);
626 AMQP_PUBLIC_FUNCTION amqp_confirm_select_ok_t * AMQP_CALL amqp_confirm_select(amqp_connection_state_t state, amqp_channel_t channel);
627 
628 AMQP_END_DECLS
629 
630 #endif /* AMQP_FRAMING_H */