rabbitmq 结构体
amqp_basic_properties_t props;
props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG |
AMQP_BASIC_DELIVERY_MODE_FLAG | AMQP_BASIC_REPLY_TO_FLAG |
AMQP_BASIC_CORRELATION_ID_FLAG;
props.content_type = amqp_cstring_bytes("text/plain");
props.delivery_mode = 2; /* persistent delivery mode */
props.reply_to = amqp_bytes_malloc_dup(reply_to_queue);
if (props.reply_to.bytes == NULL) {
fprintf(stderr, "Out of memory while copying queue name");
return 1;
}
props.correlation_id = amqp_cstring_bytes("1");
2.
amqp_basic_properties_t props;
props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG | AMQP_BASIC_DELIVERY_MODE_FLAG;
props.content_type = amqp_cstring_bytes("text/plain");
props.delivery_mode = 2; /* persistent delivery mode */
typedef struct amqp_basic_properties_t_ {
amqp_flags_t _flags; /**< bit-mask of set fields */
amqp_bytes_t content_type; /**< content-type */
amqp_bytes_t content_encoding; /**< content-encoding */
amqp_table_t headers; /**< headers */
uint8_t delivery_mode; /**< delivery-mode */
uint8_t priority; /**< priority */
amqp_bytes_t correlation_id; /**< correlation-id */
amqp_bytes_t reply_to; /**< reply-to */
amqp_bytes_t expiration; /**< expiration */
amqp_bytes_t message_id; /**< message-id */
uint64_t timestamp; /**< timestamp */
amqp_bytes_t type; /**< type */
amqp_bytes_t user_id; /**< user-id */
amqp_bytes_t app_id; /**< app-id */
amqp_bytes_t cluster_id; /**< cluster-id */
} amqp_basic_properties_t;
最新文章
- 【原】Github系列之三：开源iOS下 渐变颜色的进度条WGradientProgress
- [MVC学习笔记]5.使用Controller来代替Filter完成登录验证（Session校验）
- C:\Program Files (x86)\Common Files\microsoft shared\DevServer\10.0
- MySQL, 创建一个只读用户和一个所有权限用户
- 《Photon》
- WPF ，listbox，平滑滚动的2种方式。
- java 内存机制简介
- 聊聊Dataguard的三种保护模式实验（上）
- git强制覆盖本地文件
- SharedPreferences的基本用法
- MySQL 5.6.22 win32 zip版安装
- ceph增加osd流程
- iOS 测试驱动开发
- WebApi(五)-Swagger接口文档①简单集成
- new和malloc
- Hamming Problem（hdu3199）
- spark优化：spark.serializer修改序列化方式
- （原创）JAVA阻塞队列LinkedBlockingQueue 以及非阻塞队列ConcurrentLinkedQueue 的区别
- Java_单例模式
- Chapter 3 Phenomenon——10