声明消息队列 - MessageQueueDeclare

函数简介

声明消息队列并创建发布端句柄。
同一 queue_name 支持多个消费者竞争消费（非广播）。

接口名称

MessageQueueDeclare

DLL调用

int64_t MessageQueueDeclare(int64_t instance, int32_t type, int32_t connect_type,
                            char* ip, int32_t port, char* queue_name);

参数说明

参数名	类型	说明
instance	长整数型	OLA 实例句柄。
type	整数型	角色：CLIENT/SERVER（建议 CLIENT）。
connect_type	整数型	连接类型：TCP/PRO。
ip	字符串	TCP 模式服务地址；PRO 模式可为空。
port	整数型	TCP 端口；PRO 模式为 0。
queue_name	字符串	队列名（非空）。

示例

int64_t producer = MessageQueueDeclare(instance, OLA_PUBSUB_TYPE_CLIENT, OLA_PUBSUB_CONNECT_TCP,
                                       "127.0.0.1", 18990, "order.created");

返回值

大于 0 为队列发布句柄；<=0 为错误码。